Package | Description |
---|---|
org.apache.giraph.ooc.data |
Package of classes related to data structures used for an out-of-core
mechanism
|
org.apache.giraph.ooc.persistence |
Package of classes related to IO abstraction or persistence layer used for
out-of-core mechanism
|
Modifier and Type | Method and Description |
---|---|
protected long |
DiskBackedMessageStore.loadInMemoryPartitionData(int partitionId,
int ioThreadId,
DataIndex index) |
protected long |
DiskBackedEdgeStore.loadInMemoryPartitionData(int partitionId,
int ioThreadId,
DataIndex index) |
protected abstract long |
DiskBackedDataStore.loadInMemoryPartitionData(int partitionId,
int ioThreadId,
DataIndex index)
Loads data of a partition into data store.
|
protected long |
DiskBackedPartitionStore.loadInMemoryPartitionData(int partitionId,
int ioThreadId,
DataIndex index) |
protected long |
DiskBackedDataStore.loadPartitionDataProxy(int partitionId,
DataIndex index)
The proxy method that does the actual operation for `loadPartitionData`,
but uses the data index given by the caller.
|
protected long |
DiskBackedDataStore.offloadBuffersProxy(int partitionId,
DataIndex index)
The proxy method that does the actual operation for `offloadBuffers`,
but uses the data index given by the caller.
|
protected long |
DiskBackedMessageStore.offloadInMemoryPartitionData(int partitionId,
int ioThreadId,
DataIndex index) |
protected long |
DiskBackedEdgeStore.offloadInMemoryPartitionData(int partitionId,
int ioThreadId,
DataIndex index) |
protected abstract long |
DiskBackedDataStore.offloadInMemoryPartitionData(int partitionId,
int ioThreadId,
DataIndex index)
Offloads data of a partition in data store to disk.
|
protected long |
DiskBackedPartitionStore.offloadInMemoryPartitionData(int partitionId,
int ioThreadId,
DataIndex index) |
protected long |
DiskBackedDataStore.offloadPartitionDataProxy(int partitionId,
DataIndex index)
The proxy method that does the actual operation for `offloadPartitionData`,
but uses the data index given by the caller.
|
Modifier and Type | Method and Description |
---|---|
DataIndex |
DataIndex.addIndex(DataIndex.DataIndexEntry entry)
Add an index to the index chain
|
DataIndex |
DataIndex.copy()
Create a copy of the existing DataIndex
|
DataIndex |
DataIndex.removeLastIndex()
Remove/Pop the last index in the index chain
|
Modifier and Type | Method and Description |
---|---|
boolean |
InMemoryDataAccessor.dataExist(int threadId,
DataIndex index) |
boolean |
LocalDiskDataAccessor.dataExist(int threadId,
DataIndex index) |
boolean |
OutOfCoreDataAccessor.dataExist(int threadId,
DataIndex index)
Whether the data for the given thread and index chain exists?
|
OutOfCoreDataAccessor.DataInputWrapper |
InMemoryDataAccessor.prepareInput(int threadId,
DataIndex index) |
OutOfCoreDataAccessor.DataInputWrapper |
LocalDiskDataAccessor.prepareInput(int threadId,
DataIndex index) |
OutOfCoreDataAccessor.DataInputWrapper |
OutOfCoreDataAccessor.prepareInput(int threadId,
DataIndex index)
Prepare a wrapper containing
DataInput representation for a
given thread involved in persistence for a given index chain for data. |
OutOfCoreDataAccessor.DataOutputWrapper |
InMemoryDataAccessor.prepareOutput(int threadId,
DataIndex index,
boolean shouldAppend) |
OutOfCoreDataAccessor.DataOutputWrapper |
LocalDiskDataAccessor.prepareOutput(int threadId,
DataIndex index,
boolean shouldAppend) |
OutOfCoreDataAccessor.DataOutputWrapper |
OutOfCoreDataAccessor.prepareOutput(int threadId,
DataIndex index,
boolean shouldAppend)
Prepare a wrapper containing
DataOutput representation for a
given thread involved in persistence for a given index chain for data. |
Constructor and Description |
---|
InMemoryDataInputWrapper(BigDataInput input,
DataIndex index)
Constructor
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.