I
- Vertex idV
- Vertex valueE
- Edge valuepublic class VertexInputSplitsCallableFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> extends Object implements CallableFactory<VertexEdgeCount>
VertexInputSplitsCallable
s.Constructor and Description |
---|
VertexInputSplitsCallableFactory(VertexInputFormat<I,V,E> vertexInputFormat,
org.apache.hadoop.mapreduce.Mapper.Context context,
ImmutableClassesGiraphConfiguration<I,V,E> configuration,
BspServiceWorker<I,V,E> bspServiceWorker,
WorkerInputSplitsHandler splitsHandler)
Constructor.
|
Modifier and Type | Method and Description |
---|---|
InputSplitsCallable<I,V,E> |
newCallable(int threadId)
Create new callable
|
public VertexInputSplitsCallableFactory(VertexInputFormat<I,V,E> vertexInputFormat, org.apache.hadoop.mapreduce.Mapper.Context context, ImmutableClassesGiraphConfiguration<I,V,E> configuration, BspServiceWorker<I,V,E> bspServiceWorker, WorkerInputSplitsHandler splitsHandler)
vertexInputFormat
- Vertex input formatcontext
- Mapper contextconfiguration
- ConfigurationbspServiceWorker
- Calling BspServiceWorker
splitsHandler
- Handler for input splitspublic InputSplitsCallable<I,V,E> newCallable(int threadId)
CallableFactory
newCallable
in interface CallableFactory<VertexEdgeCount>
threadId
- Id of the callableCopyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.