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 |
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 | Method and Description |
---|---|
ExtendedDataInput |
ImmutableClassesGiraphConfiguration.createExtendedDataInput(byte[] buf)
Create an extended data input (can be subclassed)
|
ExtendedDataInput |
ImmutableClassesGiraphConfiguration.createExtendedDataInput(byte[] buf,
int off,
int length)
Create an extended data input (can be subclassed)
|
ExtendedDataInput |
ImmutableClassesGiraphConfiguration.createExtendedDataInput(ExtendedDataOutput extendedDataOutput)
Create extendedDataInput based on extendedDataOutput
|
Modifier and Type | Class and Description |
---|---|
class |
ExtendedByteArrayDataInput
Provides access to a internals of ByteArrayInputStream
|
class |
UnsafeArrayReads
Byte array input stream that uses Unsafe methods to deserialize
much faster
|
class |
UnsafeByteArrayInputStream
UnsafeByteArrayInputStream
This stream now extends com.esotericsoftware.kryo.io.Input so that kryo
serialization can directly read from this stream without using an
additional buffer, providing a faster serialization.
|
class |
UnsafeReads
Byte array input stream that uses Unsafe methods to deserialize
much faster
|
class |
UnsafeReusableByteArrayInput
UnsafeReusableByteArrayInput is a data structure to read from a
byte buffer with a read pointer that can be moved to desired location
|
Modifier and Type | Field and Description |
---|---|
protected ExtendedDataInput |
ByteStructIterator.extendedDataInput
Data input
|
protected ExtendedDataInput |
ByteStructVertexIdIterator.extendedDataInput
Reader of the serialized edges
|
Modifier and Type | Field and Description |
---|---|
protected Factory<? extends ExtendedDataInput> |
ByteStructIterable.dataInputFactory
Factory for data input
|
Modifier and Type | Method and Description |
---|---|
void |
ByteArrayVertexIdEdges.readData(ExtendedDataInput in,
Edge<I,E> edge) |
void |
ByteArrayVertexIdMessages.readData(ExtendedDataInput in,
M message) |
void |
ByteArrayOneMessageToManyIds.readData(ExtendedDataInput in,
M message) |
void |
VertexIdData.readData(ExtendedDataInput in,
T data)
Read a data object's fields from an
ExtendedDataInput . |
Constructor and Description |
---|
ByteStructIterator(ExtendedDataInput extendedDataInput)
Wrap ExtendedDataInput in ByteArrayIterator
|
RepresentativeByteStructIterator(ExtendedDataInput extendedDataInput)
Wrap ExtendedDataInput in ByteArrayIterator
|
Constructor and Description |
---|
ByteStructIterable(Factory<? extends ExtendedDataInput> dataInputFactory)
Constructor
|
RepresentativeByteStructIterable(Factory<? extends ExtendedDataInput> dataInputFactory)
Constructor
|
Modifier and Type | Class and Description |
---|---|
class |
BigDataInput
Implementations of
ExtendedDataInput are limited because they can
only handle up to 1GB of data. |
Modifier and Type | Method and Description |
---|---|
ExtendedDataInput |
DataInputOutput.create() |
ExtendedDataInput |
BigDataInputOutput.createDataInput() |
ExtendedDataInput |
ExtendedDataInputOutput.createDataInput() |
abstract ExtendedDataInput |
DataInputOutput.createDataInput()
Create DataInput which reads data from underlying DataOutput
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.