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.