| Package | Description |
|---|---|
| org.apache.giraph.comm.messages |
Package of classes for storing messages.
|
| org.apache.giraph.conf |
Package of Giraph configuration related things.
|
| org.apache.giraph.utils.io |
Package of utility classes which add the functionality to the ones from
java.io package.
|
| Modifier and Type | Method and Description |
|---|---|
protected DataInputOutput |
ByteArrayMessagesPerVertexStore.readFieldsForMessages(DataInput in) |
| Modifier and Type | Method and Description |
|---|---|
protected Iterable<M> |
ByteArrayMessagesPerVertexStore.getMessagesAsIterable(DataInputOutput dataInputOutput) |
protected void |
ByteArrayMessagesPerVertexStore.writeMessages(DataInputOutput dataInputOutput,
DataOutput out) |
| Modifier and Type | Method and Description |
|---|---|
protected int |
ByteArrayMessagesPerVertexStore.getNumberOfMessagesIn(ConcurrentMap<I,DataInputOutput> partitionMap) |
| Modifier and Type | Method and Description |
|---|---|
DataInputOutput |
ImmutableClassesGiraphConfiguration.createMessagesInputOutput()
Create DataInputOutput to store messages
|
| Modifier and Type | Class and Description |
|---|---|
class |
BigDataInputOutput
DataInputOutput which uses BigDataInput and BigDataOutput to support larger than allowed array size streams. |
class |
ExtendedDataInputOutput
Wraps
ExtendedDataOutput and ExtendedDataOutput to be able
to write data and later read data from the same place |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.