Skip to content
This repository has been archived by the owner on Oct 30, 2023. It is now read-only.

Commit

Permalink
closes #59
Browse files Browse the repository at this point in the history
  • Loading branch information
Maja Kabiljo committed Feb 13, 2018
1 parent 1484572 commit 94a3ac5
Showing 1 changed file with 4 additions and 0 deletions.
Original file line number Diff line number Diff line change
Expand Up @@ -244,6 +244,9 @@ private void readOutEdges(DataInput in, Partition<I, V, E> partition)
I id = conf.createVertexId();
id.readFields(in);
Vertex<I, V, E> v = partition.getVertex(id);
checkNotNull(v, "Vertex with ID " + id + " not found in partition " +
partition.getId() + " which has " + partition.getVertexCount() +
" vertices and " + partition.getEdgeCount() + " edges.");
OutEdges<I, E> edges = (OutEdges<I, E>) v.getEdges();
edges.readFields(in);
partition.saveVertex(v);
Expand Down Expand Up @@ -365,6 +368,7 @@ protected long offloadInMemoryPartitionData(
partitionStore.getPartitionEdgeCount(partitionId));
Partition<I, V, E> partition =
partitionStore.removePartition(partitionId);
LOG.debug("Offloading partition " + partition + " DataIndex[" + index + "]");
index.addIndex(DataIndex.TypeIndexEntry.PARTITION_VERTICES);
OutOfCoreDataAccessor.DataOutputWrapper outputWrapper =
dataAccessor.prepareOutput(ioThreadId, index.copy(), false);
Expand Down

0 comments on commit 94a3ac5

Please sign in to comment.