I
- Vertex index valueV
- Vertex valueE
- Edge valuepublic abstract class BasicPartition<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> extends Object implements Partition<I,V,E>
Constructor and Description |
---|
BasicPartition() |
Modifier and Type | Method and Description |
---|---|
void |
addPartitionVertices(VertexIterator<I,V,E> vertexIterator)
Add vertices to a partition.
|
ImmutableClassesGiraphConfiguration<I,V,E> |
getConf()
Return the configuration used by this object.
|
int |
getId()
Get the partition id.
|
VertexValueCombiner<V> |
getVertexValueCombiner() |
void |
initialize(int partitionId,
org.apache.hadoop.util.Progressable progressable)
Initialize the partition.
|
void |
progress()
Report progress.
|
void |
readFields(DataInput input) |
void |
setConf(ImmutableClassesGiraphConfiguration<I,V,E> configuration)
Set the configuration to be used by this object.
|
void |
setId(int id)
Set the partition id.
|
void |
setProgressable(org.apache.hadoop.util.Progressable progressable)
Set the context.
|
void |
write(DataOutput output) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
addPartition, getEdgeCount, getVertex, getVertexCount, putOrCombine, putVertex, removeVertex, saveVertex
forEach, iterator, spliterator
public void initialize(int partitionId, org.apache.hadoop.util.Progressable progressable)
Partition
initialize
in interface Partition<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
partitionId
- Partition idprogressable
- Progressable to call progresspublic void setConf(ImmutableClassesGiraphConfiguration<I,V,E> configuration)
GiraphConfigurationSettable
setConf
in interface GiraphConfigurationSettable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
configuration
- Set configurationpublic ImmutableClassesGiraphConfiguration<I,V,E> getConf()
ImmutableClassesGiraphConfigurable
getConf
in interface ImmutableClassesGiraphConfigurable<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
public int getId()
Partition
public void setId(int id)
Partition
public void progress()
Partition
public void setProgressable(org.apache.hadoop.util.Progressable progressable)
Partition
setProgressable
in interface Partition<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
progressable
- Progressablepublic VertexValueCombiner<V> getVertexValueCombiner()
public void addPartitionVertices(VertexIterator<I,V,E> vertexIterator)
Partition
addPartitionVertices
in interface Partition<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
vertexIterator
- Vertices to addpublic void write(DataOutput output) throws IOException
write
in interface org.apache.hadoop.io.Writable
IOException
public void readFields(DataInput input) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
IOException
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.