Skip to content

Commit

Permalink
Rename PropertyAccessor to NodePropertyAccessor
Browse files Browse the repository at this point in the history
  • Loading branch information
ragadeeshu committed Jun 15, 2018
1 parent 6b63c6f commit b3835bf
Show file tree
Hide file tree
Showing 64 changed files with 294 additions and 304 deletions.
Expand Up @@ -109,8 +109,8 @@ public void shouldEnforceUniqueConstraintsDirectly() throws Exception
IndexEntryUpdate.add( nodeId2, descriptor.schema(), value1, value2 ) ) ); IndexEntryUpdate.add( nodeId2, descriptor.schema(), value1, value2 ) ) );
try try
{ {
NodePropertyAccessor propertyAccessor = TestNodePropertyAccessor propertyAccessor =
new NodePropertyAccessor( nodeId1, descriptor.schema(), value1, value2 ); new TestNodePropertyAccessor( nodeId1, descriptor.schema(), value1, value2 );
propertyAccessor.addNode( nodeId2, descriptor.schema(), value1, value2 ); propertyAccessor.addNode( nodeId2, descriptor.schema(), value1, value2 );
p.verifyDeferredConstraints( propertyAccessor ); p.verifyDeferredConstraints( propertyAccessor );


Expand Down Expand Up @@ -138,8 +138,8 @@ public void shouldNotRestrictUpdatesDifferingOnSecondProperty() throws Exception
IndexEntryUpdate.add( nodeId1, descriptor.schema(), value1, value2 ), IndexEntryUpdate.add( nodeId1, descriptor.schema(), value1, value2 ),
IndexEntryUpdate.add( nodeId2, descriptor.schema(), value1, value3 ) ) ); IndexEntryUpdate.add( nodeId2, descriptor.schema(), value1, value3 ) ) );


NodePropertyAccessor propertyAccessor = TestNodePropertyAccessor propertyAccessor =
new NodePropertyAccessor( nodeId1, descriptor.schema(), value1, value2 ); new TestNodePropertyAccessor( nodeId1, descriptor.schema(), value1, value2 );
propertyAccessor.addNode( nodeId2, descriptor.schema(), value1, value3 ); propertyAccessor.addNode( nodeId2, descriptor.schema(), value1, value3 );


// then this should pass fine // then this should pass fine
Expand Down
Expand Up @@ -299,8 +299,8 @@ public void shouldProvidePopulatorThatEnforcesUniqueConstraints() throws Excepti
p.add( Arrays.asList( p.add( Arrays.asList(
add( nodeId1, descriptor.schema(), value ), add( nodeId1, descriptor.schema(), value ),
add( nodeId2, descriptor.schema(), value ) ) ); add( nodeId2, descriptor.schema(), value ) ) );
NodePropertyAccessor propertyAccessor = TestNodePropertyAccessor propertyAccessor =
new NodePropertyAccessor( nodeId1, descriptor.schema(), value ); new TestNodePropertyAccessor( nodeId1, descriptor.schema(), value );
propertyAccessor.addNode( nodeId2, descriptor.schema(), value ); propertyAccessor.addNode( nodeId2, descriptor.schema(), value );
p.verifyDeferredConstraints( propertyAccessor ); p.verifyDeferredConstraints( propertyAccessor );


Expand Down
Expand Up @@ -45,7 +45,7 @@
import org.neo4j.kernel.api.index.IndexPopulator; import org.neo4j.kernel.api.index.IndexPopulator;
import org.neo4j.kernel.api.index.IndexProvider; import org.neo4j.kernel.api.index.IndexProvider;
import org.neo4j.kernel.api.index.IndexUpdater; import org.neo4j.kernel.api.index.IndexUpdater;
import org.neo4j.kernel.api.index.PropertyAccessor; import org.neo4j.kernel.api.index.NodePropertyAccessor;
import org.neo4j.kernel.api.schema.SchemaDescriptorFactory; import org.neo4j.kernel.api.schema.SchemaDescriptorFactory;
import org.neo4j.kernel.api.schema.index.StoreIndexDescriptor; import org.neo4j.kernel.api.schema.index.StoreIndexDescriptor;
import org.neo4j.kernel.extension.KernelExtensionFactory; import org.neo4j.kernel.extension.KernelExtensionFactory;
Expand Down Expand Up @@ -214,12 +214,12 @@ public void add( Collection<? extends IndexEntryUpdate<?>> updates )
} }


@Override @Override
public void verifyDeferredConstraints( PropertyAccessor propertyAccessor ) public void verifyDeferredConstraints( NodePropertyAccessor nodePropertyAccessor )
{ {
} }


@Override @Override
public IndexUpdater newPopulatingUpdater( PropertyAccessor propertyAccessor ) public IndexUpdater newPopulatingUpdater( NodePropertyAccessor nodePropertyAccessor )
{ {
return newUpdater( IndexUpdateMode.ONLINE ); return newUpdater( IndexUpdateMode.ONLINE );
} }
Expand Down
Expand Up @@ -44,7 +44,7 @@
import org.neo4j.internal.kernel.api.exceptions.KernelException; import org.neo4j.internal.kernel.api.exceptions.KernelException;
import org.neo4j.internal.kernel.api.exceptions.schema.SchemaKernelException; import org.neo4j.internal.kernel.api.exceptions.schema.SchemaKernelException;
import org.neo4j.internal.kernel.api.schema.LabelSchemaDescriptor; import org.neo4j.internal.kernel.api.schema.LabelSchemaDescriptor;
import org.neo4j.kernel.api.index.PropertyAccessor; import org.neo4j.kernel.api.index.NodePropertyAccessor;
import org.neo4j.kernel.api.schema.SchemaDescriptorFactory; import org.neo4j.kernel.api.schema.SchemaDescriptorFactory;
import org.neo4j.kernel.api.schema.constaints.IndexBackedConstraintDescriptor; import org.neo4j.kernel.api.schema.constaints.IndexBackedConstraintDescriptor;
import org.neo4j.kernel.api.schema.index.IndexDescriptor; import org.neo4j.kernel.api.schema.index.IndexDescriptor;
Expand Down Expand Up @@ -179,7 +179,7 @@ public void rollBackIndexRuleShouldNotBeCommitted() throws Exception
public void shouldBeAbleToRemoveAConstraintIndexWithoutOwner() throws Exception public void shouldBeAbleToRemoveAConstraintIndexWithoutOwner() throws Exception
{ {
// given // given
PropertyAccessor propertyAccessor = mock( PropertyAccessor.class ); NodePropertyAccessor propertyAccessor = mock( NodePropertyAccessor.class );
AssertableLogProvider logProvider = new AssertableLogProvider(); AssertableLogProvider logProvider = new AssertableLogProvider();
ConstraintIndexCreator creator = new ConstraintIndexCreator( () -> kernel, indexingService, propertyAccessor, logProvider ); ConstraintIndexCreator creator = new ConstraintIndexCreator( () -> kernel, indexingService, propertyAccessor, logProvider );


Expand Down
Expand Up @@ -52,7 +52,7 @@
import org.neo4j.kernel.api.index.IndexEntryUpdate; import org.neo4j.kernel.api.index.IndexEntryUpdate;
import org.neo4j.kernel.api.index.IndexPopulator; import org.neo4j.kernel.api.index.IndexPopulator;
import org.neo4j.kernel.api.index.IndexUpdater; import org.neo4j.kernel.api.index.IndexUpdater;
import org.neo4j.kernel.api.index.PropertyAccessor; import org.neo4j.kernel.api.index.NodePropertyAccessor;
import org.neo4j.kernel.api.labelscan.NodeLabelUpdate; import org.neo4j.kernel.api.labelscan.NodeLabelUpdate;
import org.neo4j.kernel.api.schema.RelationTypeSchemaDescriptor; import org.neo4j.kernel.api.schema.RelationTypeSchemaDescriptor;
import org.neo4j.kernel.api.schema.SchemaDescriptorFactory; import org.neo4j.kernel.api.schema.SchemaDescriptorFactory;
Expand Down Expand Up @@ -567,7 +567,7 @@ void add( IndexEntryUpdate<?> update )
} }


@Override @Override
public IndexUpdater newPopulatingUpdater( PropertyAccessor propertyAccessor ) public IndexUpdater newPopulatingUpdater( NodePropertyAccessor nodePropertyAccessor )
{ {
return new IndexUpdater() return new IndexUpdater()
{ {
Expand Down Expand Up @@ -638,7 +638,7 @@ void add( IndexEntryUpdate<?> update )
} }


@Override @Override
public IndexUpdater newPopulatingUpdater( PropertyAccessor propertyAccessor ) public IndexUpdater newPopulatingUpdater( NodePropertyAccessor nodePropertyAccessor )
{ {
return new IndexUpdater() return new IndexUpdater()
{ {
Expand Down
Expand Up @@ -64,7 +64,7 @@
import org.neo4j.kernel.api.exceptions.index.IndexEntryConflictException; import org.neo4j.kernel.api.exceptions.index.IndexEntryConflictException;
import org.neo4j.kernel.api.index.IndexPopulator; import org.neo4j.kernel.api.index.IndexPopulator;
import org.neo4j.kernel.api.index.IndexProvider; import org.neo4j.kernel.api.index.IndexProvider;
import org.neo4j.kernel.api.index.PropertyAccessor; import org.neo4j.kernel.api.index.NodePropertyAccessor;
import org.neo4j.kernel.api.labelscan.LabelScanStore; import org.neo4j.kernel.api.labelscan.LabelScanStore;
import org.neo4j.kernel.api.schema.index.IndexDescriptor; import org.neo4j.kernel.api.schema.index.IndexDescriptor;
import org.neo4j.kernel.api.schema.index.StoreIndexDescriptor; import org.neo4j.kernel.api.schema.index.StoreIndexDescriptor;
Expand Down Expand Up @@ -931,7 +931,7 @@ public void shouldRunIndexPopulationJobAtShutdown() throws Throwable
verify( populator ).create(); verify( populator ).create();
verify( populator ).add( argThat( matchesCollection( add( nodeId, internalIndex.schema(), verify( populator ).add( argThat( matchesCollection( add( nodeId, internalIndex.schema(),
Values.of( "Jakewins" ) ) ) ) ); Values.of( "Jakewins" ) ) ) ) );
verify( populator ).verifyDeferredConstraints( any( PropertyAccessor.class ) ); verify( populator ).verifyDeferredConstraints( any( NodePropertyAccessor.class ) );
verify( populator ).close( true ); verify( populator ).close( true );
verify( provider ).stop(); verify( provider ).stop();
verify( provider ).shutdown(); verify( provider ).shutdown();
Expand Down Expand Up @@ -965,7 +965,7 @@ public void shouldRunConstraintPopulationJobAtShutdown() throws Throwable
verify( provider ).getPopulator( any( StoreIndexDescriptor.class ), any( IndexSamplingConfig.class ) ); verify( provider ).getPopulator( any( StoreIndexDescriptor.class ), any( IndexSamplingConfig.class ) );
verify( populator ).create(); verify( populator ).create();
verify( populator ).add( argThat( matchesCollection( add( nodeId, internalUniqueIndex.schema(), Values.of( "Jakewins" ) ) ) ) ); verify( populator ).add( argThat( matchesCollection( add( nodeId, internalUniqueIndex.schema(), Values.of( "Jakewins" ) ) ) ) );
verify( populator ).verifyDeferredConstraints( any( PropertyAccessor.class ) ); verify( populator ).verifyDeferredConstraints( any( NodePropertyAccessor.class ) );
verify( populator ).close( true ); verify( populator ).close( true );
verify( provider ).stop(); verify( provider ).stop();
verify( provider ).shutdown(); verify( provider ).shutdown();
Expand Down Expand Up @@ -1001,7 +1001,7 @@ public void shouldRepopulatePreexistingIndexed() throws Throwable
verify( populator ).add( argThat( matchesCollection( verify( populator ).add( argThat( matchesCollection(
add( jakewins, internalIndex.schema(), Values.of( "Jakewins" ) ), add( jakewins, internalIndex.schema(), Values.of( "Jakewins" ) ),
add( boggle, internalIndex.schema(), Values.of( "b0ggl3" ) ) ) ) ); add( boggle, internalIndex.schema(), Values.of( "b0ggl3" ) ) ) ) );
verify( populator ).verifyDeferredConstraints( any( PropertyAccessor.class ) ); verify( populator ).verifyDeferredConstraints( any( NodePropertyAccessor.class ) );
verify( populator ).close( true ); verify( populator ).close( true );
verify( provider ).stop(); verify( provider ).stop();
verify( provider ).shutdown(); verify( provider ).shutdown();
Expand Down
Expand Up @@ -42,13 +42,13 @@
import org.neo4j.helpers.collection.BoundedIterable; import org.neo4j.helpers.collection.BoundedIterable;
import org.neo4j.helpers.progress.ProgressMonitorFactory; import org.neo4j.helpers.progress.ProgressMonitorFactory;
import org.neo4j.kernel.api.labelscan.LabelScanStore; import org.neo4j.kernel.api.labelscan.LabelScanStore;
import org.neo4j.kernel.api.schema.index.StoreIndexDescriptor;
import org.neo4j.kernel.impl.index.labelscan.NativeLabelScanStore; import org.neo4j.kernel.impl.index.labelscan.NativeLabelScanStore;
import org.neo4j.kernel.impl.store.RecordStore; import org.neo4j.kernel.impl.store.RecordStore;
import org.neo4j.kernel.impl.store.Scanner; import org.neo4j.kernel.impl.store.Scanner;
import org.neo4j.kernel.impl.store.SchemaStorage; import org.neo4j.kernel.impl.store.SchemaStorage;
import org.neo4j.kernel.impl.store.StoreAccess; import org.neo4j.kernel.impl.store.StoreAccess;
import org.neo4j.kernel.impl.store.record.AbstractBaseRecord; import org.neo4j.kernel.impl.store.record.AbstractBaseRecord;
import org.neo4j.kernel.api.schema.index.StoreIndexDescriptor;


import static java.lang.String.format; import static java.lang.String.format;
import static org.neo4j.consistency.checking.full.MultiPassStore.ARRAYS; import static org.neo4j.consistency.checking.full.MultiPassStore.ARRAYS;
Expand Down Expand Up @@ -138,7 +138,7 @@ public List<ConsistencyCheckerTask> createTasksForFullCheck( boolean checkLabelS
tasks.add( create( "RelationshipGroupStore-RelGrp", nativeStores.getRelationshipGroupStore(), tasks.add( create( "RelationshipGroupStore-RelGrp", nativeStores.getRelationshipGroupStore(),
relGrpProcessor, ROUND_ROBIN ) ); relGrpProcessor, ROUND_ROBIN ) );


PropertyReader propertyReader = new PropertyReader( nativeStores ); NodePropertyReader propertyReader = new NodePropertyReader( nativeStores );
tasks.add( recordScanner( CheckStage.Stage8_PS_Props.name(), tasks.add( recordScanner( CheckStage.Stage8_PS_Props.name(),
new IterableStore<>( nativeStores.getNodeStore(), true ), new IterableStore<>( nativeStores.getNodeStore(), true ),
new PropertyAndNode2LabelIndexProcessor( reporter, checkIndexes ? indexes : null, new PropertyAndNode2LabelIndexProcessor( reporter, checkIndexes ? indexes : null,
Expand Down
Expand Up @@ -24,7 +24,7 @@
import java.util.LinkedList; import java.util.LinkedList;
import java.util.List; import java.util.List;


import org.neo4j.kernel.api.index.PropertyAccessor; import org.neo4j.kernel.api.index.NodePropertyAccessor;
import org.neo4j.kernel.impl.store.NodeStore; import org.neo4j.kernel.impl.store.NodeStore;
import org.neo4j.kernel.impl.store.PropertyStore; import org.neo4j.kernel.impl.store.PropertyStore;
import org.neo4j.kernel.impl.store.StoreAccess; import org.neo4j.kernel.impl.store.StoreAccess;
Expand All @@ -37,12 +37,12 @@


import static org.neo4j.kernel.impl.store.record.RecordLoad.FORCE; import static org.neo4j.kernel.impl.store.record.RecordLoad.FORCE;


public class PropertyReader implements PropertyAccessor public class NodePropertyReader implements NodePropertyAccessor
{ {
private final PropertyStore propertyStore; private final PropertyStore propertyStore;
private final NodeStore nodeStore; private final NodeStore nodeStore;


public PropertyReader( StoreAccess storeAccess ) public NodePropertyReader( StoreAccess storeAccess )
{ {
this.propertyStore = storeAccess.getRawNeoStores().getPropertyStore(); this.propertyStore = storeAccess.getRawNeoStores().getPropertyStore();
this.nodeStore = storeAccess.getRawNeoStores().getNodeStore(); this.nodeStore = storeAccess.getRawNeoStores().getNodeStore();
Expand Down
Expand Up @@ -46,7 +46,7 @@ public class PropertyAndNode2LabelIndexProcessor extends RecordProcessor.Adapter


public PropertyAndNode2LabelIndexProcessor( ConsistencyReporter reporter, public PropertyAndNode2LabelIndexProcessor( ConsistencyReporter reporter,
IndexAccessors indexes, IndexAccessors indexes,
PropertyReader propertyReader, NodePropertyReader propertyReader,
CacheAccess cacheAccess, CacheAccess cacheAccess,
Function<NodeRecord,MandatoryProperties.Check<NodeRecord,ConsistencyReport.NodeConsistencyReport>> mandatoryProperties ) Function<NodeRecord,MandatoryProperties.Check<NodeRecord,ConsistencyReport.NodeConsistencyReport>> mandatoryProperties )
{ {
Expand Down
Expand Up @@ -41,8 +41,8 @@
import org.neo4j.internal.kernel.api.IndexQuery; import org.neo4j.internal.kernel.api.IndexQuery;
import org.neo4j.internal.kernel.api.schema.SchemaDescriptor; import org.neo4j.internal.kernel.api.schema.SchemaDescriptor;
import org.neo4j.kernel.api.exceptions.index.IndexNotApplicableKernelException; import org.neo4j.kernel.api.exceptions.index.IndexNotApplicableKernelException;
import org.neo4j.kernel.impl.api.LookupFilter;
import org.neo4j.kernel.api.schema.index.StoreIndexDescriptor; import org.neo4j.kernel.api.schema.index.StoreIndexDescriptor;
import org.neo4j.kernel.impl.api.LookupFilter;
import org.neo4j.kernel.impl.store.record.NodeRecord; import org.neo4j.kernel.impl.store.record.NodeRecord;
import org.neo4j.kernel.impl.store.record.PropertyBlock; import org.neo4j.kernel.impl.store.record.PropertyBlock;
import org.neo4j.kernel.impl.store.record.PropertyRecord; import org.neo4j.kernel.impl.store.record.PropertyRecord;
Expand All @@ -59,10 +59,10 @@
public class PropertyAndNodeIndexedCheck implements RecordCheck<NodeRecord, ConsistencyReport.NodeConsistencyReport> public class PropertyAndNodeIndexedCheck implements RecordCheck<NodeRecord, ConsistencyReport.NodeConsistencyReport>
{ {
private final IndexAccessors indexes; private final IndexAccessors indexes;
private final PropertyReader propertyReader; private final NodePropertyReader propertyReader;
private final CacheAccess cacheAccess; private final CacheAccess cacheAccess;


public PropertyAndNodeIndexedCheck( IndexAccessors indexes, PropertyReader propertyReader, CacheAccess cacheAccess ) public PropertyAndNodeIndexedCheck( IndexAccessors indexes, NodePropertyReader propertyReader, CacheAccess cacheAccess )
{ {
this.indexes = indexes; this.indexes = indexes;
this.propertyReader = propertyReader; this.propertyReader = propertyReader;
Expand Down
Expand Up @@ -43,7 +43,7 @@
import org.neo4j.kernel.api.InwardKernel; import org.neo4j.kernel.api.InwardKernel;
import org.neo4j.kernel.api.explicitindex.AutoIndexing; import org.neo4j.kernel.api.explicitindex.AutoIndexing;
import org.neo4j.kernel.api.index.IndexProvider; import org.neo4j.kernel.api.index.IndexProvider;
import org.neo4j.kernel.api.index.PropertyAccessor; import org.neo4j.kernel.api.index.NodePropertyAccessor;
import org.neo4j.kernel.api.labelscan.LabelScanStore; import org.neo4j.kernel.api.labelscan.LabelScanStore;
import org.neo4j.kernel.configuration.Config; import org.neo4j.kernel.configuration.Config;
import org.neo4j.kernel.extension.dependency.AllByPrioritySelectionStrategy; import org.neo4j.kernel.extension.dependency.AllByPrioritySelectionStrategy;
Expand Down Expand Up @@ -443,7 +443,7 @@ public void start() throws IOException
); );


// At the time of writing this comes from the storage engine (IndexStoreView) // At the time of writing this comes from the storage engine (IndexStoreView)
PropertyAccessor propertyAccessor = dependencies.resolveDependency( PropertyAccessor.class ); NodePropertyAccessor nodePropertyAccessor = dependencies.resolveDependency( NodePropertyAccessor.class );


final NeoStoreKernelModule kernelModule = buildKernel( final NeoStoreKernelModule kernelModule = buildKernel(
logFiles, logFiles,
Expand All @@ -455,8 +455,7 @@ public void start() throws IOException
indexConfigStore, indexConfigStore,
transactionIdStore, transactionIdStore,
availabilityGuard, availabilityGuard,
clock, clock, nodePropertyAccessor );
propertyAccessor );


kernelModule.satisfyDependencies( dependencies ); kernelModule.satisfyDependencies( dependencies );


Expand Down Expand Up @@ -632,7 +631,7 @@ private void buildRecovery(
private NeoStoreKernelModule buildKernel( LogFiles logFiles, TransactionAppender appender, private NeoStoreKernelModule buildKernel( LogFiles logFiles, TransactionAppender appender,
IndexingService indexingService, DatabaseSchemaState databaseSchemaState, LabelScanStore labelScanStore, IndexingService indexingService, DatabaseSchemaState databaseSchemaState, LabelScanStore labelScanStore,
StorageEngine storageEngine, IndexConfigStore indexConfigStore, TransactionIdStore transactionIdStore, StorageEngine storageEngine, IndexConfigStore indexConfigStore, TransactionIdStore transactionIdStore,
AvailabilityGuard availabilityGuard, SystemNanoClock clock, PropertyAccessor propertyAccessor ) AvailabilityGuard availabilityGuard, SystemNanoClock clock, NodePropertyAccessor nodePropertyAccessor )
{ {
AtomicReference<CpuClock> cpuClockRef = setupCpuClockAtomicReference(); AtomicReference<CpuClock> cpuClockRef = setupCpuClockAtomicReference();
AtomicReference<HeapAllocation> heapAllocationRef = setupHeapAllocationAtomicReference(); AtomicReference<HeapAllocation> heapAllocationRef = setupHeapAllocationAtomicReference();
Expand All @@ -646,7 +645,7 @@ private NeoStoreKernelModule buildKernel( LogFiles logFiles, TransactionAppender
*/ */
Supplier<Kernel> kernelProvider = () -> kernelModule.kernelAPI(); Supplier<Kernel> kernelProvider = () -> kernelModule.kernelAPI();


ConstraintIndexCreator constraintIndexCreator = new ConstraintIndexCreator( kernelProvider, indexingService, propertyAccessor, logProvider ); ConstraintIndexCreator constraintIndexCreator = new ConstraintIndexCreator( kernelProvider, indexingService, nodePropertyAccessor, logProvider );


ExplicitIndexStore explicitIndexStore = new ExplicitIndexStore( config, ExplicitIndexStore explicitIndexStore = new ExplicitIndexStore( config,
indexConfigStore, kernelProvider, explicitIndexProviderLookup ); indexConfigStore, kernelProvider, explicitIndexProviderLookup );
Expand Down
Expand Up @@ -30,7 +30,6 @@
import org.neo4j.kernel.api.exceptions.index.IndexEntryConflictException; import org.neo4j.kernel.api.exceptions.index.IndexEntryConflictException;
import org.neo4j.kernel.impl.api.index.IndexUpdateMode; import org.neo4j.kernel.impl.api.index.IndexUpdateMode;
import org.neo4j.kernel.impl.api.index.updater.SwallowingIndexUpdater; import org.neo4j.kernel.impl.api.index.updater.SwallowingIndexUpdater;
import org.neo4j.kernel.impl.util.Validator;
import org.neo4j.storageengine.api.schema.IndexReader; import org.neo4j.storageengine.api.schema.IndexReader;
import org.neo4j.values.storable.Value; import org.neo4j.values.storable.Value;


Expand Down Expand Up @@ -110,12 +109,12 @@ public interface IndexAccessor extends Closeable
* Verifies that each value in this index is unique. * Verifies that each value in this index is unique.
* Index is guaranteed to not change while this call executes. * Index is guaranteed to not change while this call executes.
* *
* @param propertyAccessor {@link PropertyAccessor} for accessing properties from database storage * @param nodePropertyAccessor {@link NodePropertyAccessor} for accessing properties from database storage
* in the event of conflicting values. * in the event of conflicting values.
* @throws IndexEntryConflictException for first detected uniqueness conflict, if any. * @throws IndexEntryConflictException for first detected uniqueness conflict, if any.
* @throws IOException on error reading from source files. * @throws IOException on error reading from source files.
*/ */
void verifyDeferredConstraints( PropertyAccessor propertyAccessor ) throws IndexEntryConflictException, IOException; void verifyDeferredConstraints( NodePropertyAccessor nodePropertyAccessor ) throws IndexEntryConflictException, IOException;


/** /**
* @return true if index was not shutdown properly and its internal state is dirty, false otherwise * @return true if index was not shutdown properly and its internal state is dirty, false otherwise
Expand Down Expand Up @@ -195,7 +194,7 @@ public ResourceIterator<File> snapshotFiles()
} }


@Override @Override
public void verifyDeferredConstraints( PropertyAccessor propertyAccessor ) public void verifyDeferredConstraints( NodePropertyAccessor nodePropertyAccessor )
{ {
} }


Expand Down Expand Up @@ -270,10 +269,10 @@ public String toString()
} }


@Override @Override
public void verifyDeferredConstraints( PropertyAccessor propertyAccessor ) public void verifyDeferredConstraints( NodePropertyAccessor nodePropertyAccessor )
throws IndexEntryConflictException, IOException throws IndexEntryConflictException, IOException
{ {
delegate.verifyDeferredConstraints( propertyAccessor ); delegate.verifyDeferredConstraints( nodePropertyAccessor );
} }


@Override @Override
Expand Down

0 comments on commit b3835bf

Please sign in to comment.