Toggle navigation
Home
org.neo4j.kernel.impl.api.store.NodeProgression to org.neo4j.kernel.impl.api.store.Progression
No. of Instances - 9
No. of Commits - 1
No. of Projects - {'neo4j'}
Hierarchy/Composition: -
Primitive Info: -
NameSpace: Internal -> Internal
Mapping:
Update argument list (Class Instance Creation)
ParallelAllNodeProgression
to
ParallelAllNodeProgression
Cascading Type Change (Similar)
NodeProgression
to
Progression
Other
!state.nodeIsDeletedInThisTx(id)
to
FETCH
Update Anonymous class
{ private int i=0; @Override public boolean nextBatch( Batch batch){ while (i < ops.length) { Operation op=ops[i++]; if (op.fromDisk() || mode == FETCH) { batch.init(op.id(),op.id()); return true; } } batch.nothing(); return false; } @Override public Iterator<Long> addedNodes(){ return mode == APPEND && state != null ? state.addedAndRemovedNodes().getAdded().iterator() : null; } @Override public boolean fetchFromTxState( long id){ return mode == FETCH && state != null && state.nodeIsAddedInThisTx(id); } @Override public boolean fetchFromDisk( long id){ return state == null || !state.nodeIsDeletedInThisTx(id); } @Override public NodeState nodeState( long id){ return state == null ? NodeState.EMPTY : state.getNodeState(id); } }
to
{ private int i=0; @Override public boolean nextBatch( Batch batch){ while (i < ops.length) { Operation op=ops[i++]; if (op.fromDisk() || mode == FETCH) { batch.init(op.id(),op.id()); return true; } } batch.nothing(); return false; } @Override public boolean appendAdded(){ return mode == APPEND; } @Override public boolean fetchAdded(){ return mode == FETCH; } }
Add or Remove Method invocation
executorService.submit(() -> { HashSet<Long> ids=new HashSet<>(); try (Cursor<NodeItem> cursor=localStatements[id].acquireNodeCursor(progression)){ while (cursor.next()) { long nodeId=cursor.get().id(); assertTrue(ids.add(nodeId)); } } return ids; } )
to
executorService.submit(() -> { HashSet<Long> ids=new HashSet<>(); try (Cursor<NodeItem> cursor=localStatements[id].acquireNodeCursor(progression,stateView)){ while (cursor.next()) { long nodeId=cursor.get().id(); assertTrue(ids.add(nodeId)); } } return ids; } )
Rename Variable
nodeProgression
to
progression