Package | Description |
---|---|
org.apache.giraph.utils |
Package of all generic utility classes.
|
org.apache.giraph.worker |
Package of all the worker related things
|
Modifier and Type | Method and Description |
---|---|
static <R> List<R> |
ProgressableUtils.getResultsWithNCallables(CallableFactory<R> callableFactory,
int numThreads,
String threadNameFormat,
org.apache.hadoop.util.Progressable progressable)
Create {#link numThreads} callables from {#link callableFactory},
execute them and gather results.
|
Modifier and Type | Class and Description |
---|---|
class |
EdgeInputSplitsCallableFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Factory for
EdgeInputSplitsCallable s. |
class |
MappingInputSplitsCallableFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,B extends org.apache.hadoop.io.Writable>
Factory for
MappingInputSplitsCallable s. |
class |
VertexInputSplitsCallableFactory<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Factory for
VertexInputSplitsCallable s. |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.