org.neo4j.kernel.impl.store.NodeStore.openPageCursorForReading()方法的使用及代码示例

x33g5p2x  于2022-01-25 转载在 其他  
字(3.8k)|赞(0)|评价(0)|浏览(87)

本文整理了Java中org.neo4j.kernel.impl.store.NodeStore.openPageCursorForReading()方法的一些代码示例,展示了NodeStore.openPageCursorForReading()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。NodeStore.openPageCursorForReading()方法的具体详情如下:
包路径:org.neo4j.kernel.impl.store.NodeStore
类名称:NodeStore
方法名:openPageCursorForReading

NodeStore.openPageCursorForReading介绍

暂无

代码示例

代码示例来源:origin: neo4j/neo4j

private PageCursor nodePage( long reference )
{
  return read.openPageCursorForReading( reference );
}

代码示例来源:origin: neo4j/neo4j

NodeSetFirstGroupStep( StageControl control, Configuration config, NodeStore nodeStore, ByteArray cache )
{
  super( control, "FIRST", config, 1 );
  this.cache = cache;
  this.batchSize = config.batchSize();
  this.nodeStore = nodeStore;
  this.nodeCursor = nodeStore.openPageCursorForReading( 0 );
  newBatch();
}

代码示例来源:origin: neo4j/neo4j

@Test
void nodeCursorShouldClosePageCursor()
{
  NodeStore store = mock( NodeStore.class );
  PageCursor pageCursor = mock( PageCursor.class );
  when( store.openPageCursorForReading( anyLong() ) ).thenReturn( pageCursor );
  try ( RecordNodeCursor cursor = new RecordNodeCursor( store ) )
  {
    cursor.single( 0 );
  }
  verify( pageCursor ).close();
}

代码示例来源:origin: neo4j/neo4j

@Test
public void shouldBeAbleToForceStoreScan() throws Exception
{
  when( labelScanStore.newReader() ).thenThrow( new RuntimeException( "Should not be used" ) );
  when( nodeStore.getHighestPossibleIdInUse() ).thenReturn( 200L );
  when( nodeStore.getHighId() ).thenReturn( 20L );
  when( nodeStore.openPageCursorForReading( anyLong() ) ).thenReturn( mock( PageCursor.class ) );
  mockLabelNodeCount( countStore, 2 );
  mockLabelNodeCount( countStore, 6 );
  DynamicIndexStoreView storeView = dynamicIndexStoreView();
  StoreScan<Exception> storeScan = storeView
      .visitNodes( new int[]{2, 6}, propertyKeyIdFilter, propertyUpdateVisitor, labelUpdateVisitor, true );
  storeScan.run();
  Mockito.verify( nodeStore, times( 1 ) )
      .getRecordByCursor( anyLong(), any( NodeRecord.class ), any( RecordLoad.class ), any( PageCursor.class ) );
  Mockito.verify( nodeStore, times( 200 ) )
      .nextRecordByCursor( any( NodeRecord.class ), any( RecordLoad.class ), any( PageCursor.class ) );
}

代码示例来源:origin: neo4j/neo4j

@Test
public void visitOnlyLabeledNodes() throws Exception
{
  LabelScanReader labelScanReader = mock( LabelScanReader.class );
  when( labelScanStore.newReader() ).thenReturn( labelScanReader );
  when( nodeLabelRanges.maxCount() ).thenReturn( 1L );
  PrimitiveLongResourceIterator labeledNodesIterator = PrimitiveLongResourceCollections.iterator( null, 1, 2, 3, 4, 5, 6, 7, 8 );
  when( nodeStore.getHighestPossibleIdInUse() ).thenReturn( 200L );
  when( nodeStore.getHighId() ).thenReturn( 20L );
  when( labelScanReader.nodesWithAnyOfLabels( new int[] {2, 6} ) ).thenReturn( labeledNodesIterator );
  when( nodeStore.openPageCursorForReading( anyLong() ) ).thenReturn( mock( PageCursor.class ) );
  mockLabelNodeCount( countStore, 2 );
  mockLabelNodeCount( countStore, 6 );
  DynamicIndexStoreView storeView = dynamicIndexStoreView();
  StoreScan<Exception> storeScan = storeView
      .visitNodes( new int[]{2, 6}, propertyKeyIdFilter, propertyUpdateVisitor, labelUpdateVisitor, false );
  storeScan.run();
  Mockito.verify( nodeStore, times( 8 ) )
      .getRecordByCursor( anyLong(), any( NodeRecord.class ), any( RecordLoad.class ), any( PageCursor.class ) );
}

代码示例来源:origin: neo4j/neo4j

try ( PageCursor cursor = nodeStore.openPageCursorForReading( 0 );
   PageCursor propertyCursor = propertyStore.openPageCursorForReading( 0 ) )

代码示例来源:origin: org.neo4j/neo4j-kernel

private PageCursor nodePage( long reference )
{
  return read.openPageCursorForReading( reference );
}

代码示例来源:origin: org.neo4j/neo4j-kernel

NodeSetFirstGroupStep( StageControl control, Configuration config, NodeStore nodeStore, ByteArray cache )
{
  super( control, "FIRST", config, 1 );
  this.cache = cache;
  this.batchSize = config.batchSize();
  this.nodeStore = nodeStore;
  this.nodeCursor = nodeStore.openPageCursorForReading( 0 );
  newBatch();
}

代码示例来源:origin: org.neo4j/neo4j-kernel

try ( PageCursor cursor = nodeStore.openPageCursorForReading( 0 );
   PageCursor propertyCursor = propertyStore.openPageCursorForReading( 0 ) )

相关文章