Package | Description |
---|---|
org.apache.giraph.comm.messages |
Package of classes for storing messages.
|
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.
|
Constructor and Description |
---|
MessagesIterable(Factory<? extends ExtendedDataInput> dataInputFactory,
MessageValueFactory<M> messageValueFactory)
Constructor
|
Modifier and Type | Field and Description |
---|---|
protected Factory<? extends ExtendedDataInput> |
ByteStructIterable.dataInputFactory
Factory for data input
|
Constructor and Description |
---|
ByteStructIterable(Factory<? extends ExtendedDataInput> dataInputFactory)
Constructor
|
RepresentativeByteStructIterable(Factory<? extends ExtendedDataInput> dataInputFactory)
Constructor
|
Modifier and Type | Class and Description |
---|---|
class |
BigDataInputOutput
DataInputOutput which uses BigDataInput and BigDataOutput to support larger than allowed array size streams. |
class |
DataInputOutput
Provides both DataOutput which we can write to and DataInputs which are
going to read data which was written to DataOutput.
|
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.