Package | Description |
---|---|
org.apache.giraph.io |
Input/Output related things.
|
org.apache.giraph.io.formats |
Package of reusable library Giraph objects.
|
org.apache.giraph.io.formats.multi |
Package for Input formats which wrap several input formats and allow
reading data from multiple sources.
|
org.apache.giraph.io.internal |
Input/Output classes for internal use only.
|
org.apache.giraph.io.iterables |
Iterable wrappers for IO readers/writers
|
Modifier and Type | Class and Description |
---|---|
class |
ReverseEdgeDuplicator<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
An EdgeReader that creates the opposite direction edge for each edge read.
|
Modifier and Type | Method and Description |
---|---|
abstract EdgeReader<I,E> |
EdgeInputFormat.createEdgeReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context)
Create an edge reader for a given split.
|
EdgeReader<I,E> |
ReverseEdgeDuplicator.getBaseReader()
Get wrapped EdgeReader
|
Constructor and Description |
---|
ReverseEdgeDuplicator(EdgeReader<I,E> baseReader)
Constructor
|
Modifier and Type | Class and Description |
---|---|
class |
IntNullTextEdgeInputFormat.IntNullTextEdgeReader
EdgeReader associated with
IntNullTextEdgeInputFormat . |
protected class |
TextEdgeInputFormat.TextEdgeReader
|
protected class |
TextEdgeInputFormat.TextEdgeReaderFromEachLine
Abstract class to be implemented by the user to read an edge from each
text line.
|
protected class |
TextEdgeInputFormat.TextEdgeReaderFromEachLineProcessed<T>
Abstract class to be implemented by the user to read an edge from each
text line after preprocessing it.
|
Modifier and Type | Method and Description |
---|---|
EdgeReader<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable> |
IntNullReverseTextEdgeInputFormat.createEdgeReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
EdgeReader<org.apache.hadoop.io.IntWritable,org.apache.hadoop.io.NullWritable> |
IntNullTextEdgeInputFormat.createEdgeReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
EdgeReader<org.apache.hadoop.io.LongWritable,org.apache.hadoop.io.DoubleWritable> |
PseudoRandomEdgeInputFormat.createEdgeReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
Modifier and Type | Method and Description |
---|---|
EdgeReader<I,E> |
MultiEdgeInputFormat.createEdgeReader(org.apache.hadoop.mapreduce.InputSplit inputSplit,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
Modifier and Type | Class and Description |
---|---|
class |
WrappedEdgeReader<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
For internal use only.
|
Modifier and Type | Method and Description |
---|---|
EdgeReader<I,E> |
WrappedEdgeInputFormat.createEdgeReader(org.apache.hadoop.mapreduce.InputSplit split,
org.apache.hadoop.mapreduce.TaskAttemptContext context) |
Constructor and Description |
---|
WrappedEdgeReader(EdgeReader<I,E> baseEdgeReader,
ImmutableClassesGiraphConfiguration<I,org.apache.hadoop.io.Writable,E> conf)
Constructor
|
Modifier and Type | Class and Description |
---|---|
class |
EdgeReaderWrapper<I extends org.apache.hadoop.io.WritableComparable,E extends org.apache.hadoop.io.Writable>
Wraps
GiraphReader for edges into EdgeReader |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.