Skip to content

Commit

Permalink
Moves DirectRecordAccess+Set to .internal
Browse files Browse the repository at this point in the history
  • Loading branch information
tinwelint committed Aug 8, 2017
1 parent 4ec9399 commit ead6459
Show file tree
Hide file tree
Showing 9 changed files with 9 additions and 15 deletions.
1 change: 1 addition & 0 deletions community/kernel/pom.xml
Expand Up @@ -145,6 +145,7 @@ the relevant Commercial Agreement.
</includes>
<excludes>
<exclude>org/neo4j/unsafe/batchinsert/DirectRecordAccess</exclude>
<exclude>org/neo4j/unsafe/batchinsert/DirectRecordAccessSet</exclude>

This comment has been minimized.

Copy link
@klaren

klaren Aug 8, 2017

Member

You have to add /internal/ as well after the move.

</excludes>
</configuration>
</plugin>
Expand Down
Expand Up @@ -31,11 +31,8 @@
* deciding when to make a record heavy and when to consider it changed for inclusion in the
* transaction as a command.
*
* @author Mattias Persson
*
* @param <KEY>
* @param <RECORD>
* @param <ADDITIONAL>
* @param <RECORD> type of record
* @param <ADDITIONAL> additional payload
*/
public class RecordChanges<RECORD,ADDITIONAL> implements RecordAccess<RECORD,ADDITIONAL>
{
Expand Down
Expand Up @@ -160,7 +160,6 @@
import org.neo4j.storageengine.api.schema.SchemaRule;
import org.neo4j.unsafe.batchinsert.BatchInserter;
import org.neo4j.unsafe.batchinsert.BatchRelationship;
import org.neo4j.unsafe.batchinsert.DirectRecordAccessSet;
import org.neo4j.values.storable.Value;
import org.neo4j.values.storable.Values;

Expand Down
Expand Up @@ -17,10 +17,9 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package org.neo4j.unsafe.batchinsert;
package org.neo4j.unsafe.batchinsert.internal;

import java.util.ArrayList;
import java.util.Collections;
import java.util.HashMap;
import java.util.List;
import java.util.Map;
Expand Down Expand Up @@ -234,7 +233,7 @@ public void commit()
}

List<DirectRecordProxy> directRecordProxies = new ArrayList<>( batch.values() );
Collections.sort(directRecordProxies, ( o1, o2 ) -> Long.compare( -o1.getKey(), o2.getKey() ) );
directRecordProxies.sort( ( o1, o2 ) -> Long.compare( -o1.getKey(), o2.getKey() ) );
for ( DirectRecordProxy proxy : directRecordProxies )
{
proxy.store();
Expand Down
Expand Up @@ -17,7 +17,7 @@
* You should have received a copy of the GNU General Public License
* along with this program. If not, see <http://www.gnu.org/licenses/>.
*/
package org.neo4j.unsafe.batchinsert;
package org.neo4j.unsafe.batchinsert.internal;

import org.neo4j.kernel.impl.store.NeoStores;
import org.neo4j.kernel.impl.store.PropertyStore;
Expand Down
Expand Up @@ -32,7 +32,7 @@
import org.neo4j.kernel.impl.store.record.Record;
import org.neo4j.kernel.impl.transaction.state.RecordAccess.Loader;
import org.neo4j.kernel.impl.transaction.state.RecordAccess.RecordProxy;
import org.neo4j.unsafe.batchinsert.DirectRecordAccess;
import org.neo4j.unsafe.batchinsert.internal.DirectRecordAccess;
import org.neo4j.unsafe.impl.batchimport.store.BatchingIdSequence;
import org.neo4j.values.storable.Value;
import org.neo4j.values.storable.Values;
Expand Down
Expand Up @@ -52,7 +52,7 @@
import org.neo4j.storageengine.api.schema.SchemaRule;
import org.neo4j.test.rule.DatabaseRule;
import org.neo4j.test.rule.ImpermanentDatabaseRule;
import org.neo4j.unsafe.batchinsert.DirectRecordAccessSet;
import org.neo4j.unsafe.batchinsert.internal.DirectRecordAccessSet;

import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertFalse;
Expand Down
Expand Up @@ -38,7 +38,7 @@
import org.neo4j.logging.NullLogProvider;
import org.neo4j.test.rule.PageCacheRule;
import org.neo4j.test.rule.fs.EphemeralFileSystemRule;
import org.neo4j.unsafe.batchinsert.DirectRecordAccess;
import org.neo4j.unsafe.batchinsert.internal.DirectRecordAccess;

import static org.junit.Assert.assertEquals;
import static org.junit.Assert.assertNull;
Expand Down
Expand Up @@ -22,8 +22,6 @@
import org.junit.Test;
import org.mockito.Mockito;

import org.neo4j.unsafe.batchinsert.DirectRecordAccessSet;

public class BatchedFlushStrategyTest
{

Expand Down

1 comment on commit ead6459

@klaren
Copy link
Member

@klaren klaren commented on ead6459 Aug 8, 2017

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

Everything else looks good, approved!

Please sign in to comment.