Package | Description |
---|---|
org.apache.giraph.comm.aggregators |
Package for classes which are used to handle aggregators.
|
org.apache.giraph.comm.requests |
Package for requests.
|
org.apache.giraph.conf |
Package of Giraph configuration related things.
|
org.apache.giraph.ooc.data |
Package of classes related to data structures used for an out-of-core
mechanism
|
org.apache.giraph.partition |
Package of partitioning related objects.
|
org.apache.giraph.utils |
Package of all generic utility classes.
|
org.apache.giraph.utils.io |
Package of utility classes which add the functionality to the ones from
java.io package.
|
Modifier and Type | Field and Description |
---|---|
protected ExtendedDataOutput |
CountingOutputStream.dataOutput
DataOutput to which subclasses will be writing data
|
Constructor and Description |
---|
SendWorkerVerticesRequest(ImmutableClassesGiraphConfiguration<I,V,E> conf,
PairList<Integer,ExtendedDataOutput> workerPartitions)
Constructor for sending a request.
|
Modifier and Type | Method and Description |
---|---|
ExtendedDataOutput |
ImmutableClassesGiraphConfiguration.createExtendedDataOutput()
Create an extended data output (can be subclassed)
|
ExtendedDataOutput |
ImmutableClassesGiraphConfiguration.createExtendedDataOutput(byte[] buf,
int pos)
Create an extended data output (can be subclassed)
|
ExtendedDataOutput |
ImmutableClassesGiraphConfiguration.createExtendedDataOutput(int expectedSize)
Create an extended data output (can be subclassed)
|
Modifier and Type | Method and Description |
---|---|
ExtendedDataInput |
ImmutableClassesGiraphConfiguration.createExtendedDataInput(ExtendedDataOutput extendedDataOutput)
Create extendedDataInput based on extendedDataOutput
|
Modifier and Type | Method and Description |
---|---|
protected ExtendedDataOutput |
DiskBackedPartitionStore.readNextEntry(DataInput in) |
Modifier and Type | Method and Description |
---|---|
protected void |
DiskBackedPartitionStore.addEntryToInMemoryPartitionData(int partitionId,
ExtendedDataOutput vertices) |
void |
DiskBackedPartitionStore.addPartitionVertices(Integer partitionId,
ExtendedDataOutput extendedDataOutput) |
protected int |
DiskBackedPartitionStore.entrySerializedSize(ExtendedDataOutput vertices) |
protected void |
DiskBackedPartitionStore.writeEntry(ExtendedDataOutput vertices,
DataOutput out) |
Modifier and Type | Method and Description |
---|---|
void |
SimplePartitionStore.addPartitionVertices(Integer partitionId,
ExtendedDataOutput extendedDataOutput) |
void |
PartitionStore.addPartitionVertices(Integer partitionId,
ExtendedDataOutput extendedDataOutput)
Add vertices to a given partition from a given DataOutput instance.
|
Modifier and Type | Class and Description |
---|---|
class |
ExtendedByteArrayDataOutput
Adds some functionality to ByteArrayOutputStream,
such as an option to write int value over previously written data
and directly get the byte array.
|
class |
UnsafeByteArrayOutputStream
Byte array output stream that uses Unsafe methods to serialize/deserialize
much faster.
|
Modifier and Type | Field and Description |
---|---|
protected ExtendedDataOutput |
AbstractVertexIdData.extendedDataOutput
Extended data output
|
Modifier and Type | Method and Description |
---|---|
ExtendedDataOutput |
ExtendedByteArrayOutputBuffer.IndexAndDataOut.getDataOutput() |
ExtendedDataOutput |
ExtendedByteArrayOutputBuffer.getDataOutput(int index)
Get dataoutput from bytearrayOutputs
|
static ExtendedDataOutput |
WritableUtils.readExtendedDataOutput(DataInput in,
ImmutableClassesGiraphConfiguration conf)
Read ExtendedDataOutput from DataInput
|
Modifier and Type | Method and Description |
---|---|
void |
ByteArrayVertexIdEdges.writeData(ExtendedDataOutput out,
Edge<I,E> edge) |
void |
ByteArrayVertexIdMessages.writeData(ExtendedDataOutput out,
M message) |
void |
ByteArrayOneMessageToManyIds.writeData(ExtendedDataOutput out,
M message) |
void |
VertexIdData.writeData(ExtendedDataOutput out,
T data)
Write a data object to an
ExtendedDataOutput . |
static void |
WritableUtils.writeExtendedDataOutput(ExtendedDataOutput extendedDataOutput,
DataOutput out)
Write ExtendedDataOutput to DataOutput
|
Constructor and Description |
---|
ByteStructVertexIdIterator(ExtendedDataOutput extendedDataOutput,
ImmutableClassesGiraphConfiguration<I,?,?> conf)
Constructor.
|
IndexAndDataOut(int index,
ExtendedDataOutput dataOutput)
Constructor
|
VertexIterator(ExtendedDataOutput extendedDataOutput,
ImmutableClassesGiraphConfiguration<I,V,E> configuration)
Constructor.
|
Modifier and Type | Field and Description |
---|---|
protected ExtendedDataOutput |
BigDataOutput.currentDataOutput
Data output which we are currently writing to
|
Modifier and Type | Field and Description |
---|---|
protected List<ExtendedDataOutput> |
BigDataOutput.dataOutputs
List of filled outputs, will be null until we get a lot of data
|
Modifier and Type | Method and Description |
---|---|
protected ExtendedDataOutput |
BigDataOutput.createOutput(int size)
Create next data output
|
Modifier and Type | Method and Description |
---|---|
Iterable<ExtendedDataOutput> |
BigDataOutput.getDataOutputs()
Get DataOutputs which contain written data.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.