Package | Description |
---|---|
org.apache.giraph.block_app.reducers.array |
Reducers for collecting arrays of objects.
|
org.apache.giraph.block_app.reducers.collect |
Reducers for distributed collection of objects.
|
org.apache.giraph.types.ops |
Type coercion, inference, and reflection.
|
org.apache.giraph.types.ops.collections.array |
WArrayList interfaces and implementations that extend fastutil
classes, and are provided by TypeOps classes.
|
Modifier and Type | Method and Description |
---|---|
WArrayList<R> |
BasicArrayReduce.createInitialValue() |
WArrayList<R> |
BasicArrayReduce.reduce(WArrayList<R> curValue,
org.apache.commons.lang3.tuple.Pair<PrimitiveRefs.IntRef,S> valueToReduce) |
WArrayList<R> |
BasicArrayReduce.reduceMerge(WArrayList<R> curValue,
WArrayList<R> valueToReduce) |
Modifier and Type | Method and Description |
---|---|
WArrayList<R> |
BasicArrayReduce.reduce(WArrayList<R> curValue,
org.apache.commons.lang3.tuple.Pair<PrimitiveRefs.IntRef,S> valueToReduce) |
WArrayList<R> |
BasicArrayReduce.reduceMerge(WArrayList<R> curValue,
WArrayList<R> valueToReduce) |
WArrayList<R> |
BasicArrayReduce.reduceMerge(WArrayList<R> curValue,
WArrayList<R> valueToReduce) |
Modifier and Type | Method and Description |
---|---|
WArrayList<S> |
CollectShardedPrimitiveReducerHandle.CollectShardedPrimitiveBroadcastHandle.createBroadcastResult(WorkerBroadcastUsage worker) |
WArrayList<S> |
CollectPrimitiveReduceOperation.createList() |
WArrayList<S> |
CollectShardedPrimitiveReducerHandle.createList(int size) |
WArrayList<S> |
CollectShardedPrimitiveReducerHandle.createReduceResult(MasterGlobalCommUsage master) |
WArrayList<S> |
CollectPrimitiveReduceOperation.createValue() |
Modifier and Type | Method and Description |
---|---|
BroadcastHandle<List<WArrayList>> |
CollectShardedTuplesOfPrimitivesReducerHandle.createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<List<WArrayList>>> broadcasts) |
BroadcastHandle<WArrayList<S>> |
CollectShardedPrimitiveReducerHandle.createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<WArrayList<S>>> broadcasts) |
List<WArrayList> |
CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesBroadcastHandle.createBroadcastResult(WorkerBroadcastUsage worker) |
List<WArrayList> |
CollectShardedTuplesOfPrimitivesReducerHandle.createLists(int size) |
ReduceOperation<List<Object>,KryoWritableWrapper<List<WArrayList>>> |
CollectShardedTuplesOfPrimitivesReducerHandle.createReduceOperation() |
ReduceOperation<S,KryoWritableWrapper<WArrayList<S>>> |
CollectShardedPrimitiveReducerHandle.createReduceOperation() |
List<WArrayList> |
CollectShardedTuplesOfPrimitivesReducerHandle.createReduceResult(MasterGlobalCommUsage master) |
List<WArrayList> |
CollectTuplesOfPrimitivesReduceOperation.createValue() |
List<WArrayList> |
CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesReduceBroadcast.getBroadcast(WorkerBroadcastUsage worker)
Get broadcasted value
|
List<WArrayList> |
CollectShardedTuplesOfPrimitivesReducerHandle.CollectShardedTuplesOfPrimitivesReduceBroadcast.getReducedValue(MasterGlobalCommUsage master)
Get reduced value
|
Modifier and Type | Method and Description |
---|---|
void |
CollectPrimitiveReduceOperation.reduce(WArrayList<S> reduceInto,
S value) |
void |
CollectPrimitiveReduceOperation.reduceMerge(WArrayList<S> reduceInto,
WArrayList<S> toReduce) |
void |
CollectPrimitiveReduceOperation.reduceMerge(WArrayList<S> reduceInto,
WArrayList<S> toReduce) |
Modifier and Type | Method and Description |
---|---|
BroadcastHandle<List<WArrayList>> |
CollectShardedTuplesOfPrimitivesReducerHandle.createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<List<WArrayList>>> broadcasts) |
BroadcastHandle<WArrayList<S>> |
CollectShardedPrimitiveReducerHandle.createBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<WArrayList<S>>> broadcasts) |
void |
CollectTuplesOfPrimitivesReduceOperation.reduce(List<WArrayList> reduceInto,
List<Object> value) |
void |
CollectTuplesOfPrimitivesReduceOperation.reduceMerge(List<WArrayList> reduceInto,
List<WArrayList> toReduce) |
void |
CollectTuplesOfPrimitivesReduceOperation.reduceMerge(List<WArrayList> reduceInto,
List<WArrayList> toReduce) |
Constructor and Description |
---|
CollectShardedPrimitiveBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<WArrayList<S>>> broadcasts) |
CollectShardedTuplesOfPrimitivesBroadcastHandle(BroadcastArrayHandle<KryoWritableWrapper<List<WArrayList>>> broadcasts) |
Modifier and Type | Method and Description |
---|---|
WArrayList<T> |
PrimitiveTypeOps.createArrayList()
Create WArrayList of type T.
|
WArrayList<T> |
PrimitiveTypeOps.createArrayList(int capacity)
Create WArrayList of type T, given capacity.
|
WArrayList<T> |
PrimitiveTypeOps.readNewArrayList(DataInput in)
Create WArrayList of type T by reading it from given input.
|
Modifier and Type | Class and Description |
---|---|
class |
WBooleanArrayList
Writable extension of BooleanArrayList, as well as
BooleanWritable implementation of WArrayList.
|
static class |
WBooleanArrayList.WReusableBooleanArrayList
Variant of WBooleanArrayList that doesn't reallocate smaller backing
array on consecutive readFields/readElements calls, and so is suitable for
reusable use.
|
class |
WByteArrayList
Writable extension of ByteArrayList, as well as
ByteWritable implementation of WArrayList.
|
static class |
WByteArrayList.WReusableByteArrayList
Variant of WByteArrayList that doesn't reallocate smaller backing
array on consecutive readFields/readElements calls, and so is suitable for
reusable use.
|
class |
WDoubleArrayList
Writable extension of DoubleArrayList, as well as
DoubleWritable implementation of WArrayList.
|
static class |
WDoubleArrayList.WReusableDoubleArrayList
Variant of WDoubleArrayList that doesn't reallocate smaller backing
array on consecutive readFields/readElements calls, and so is suitable for
reusable use.
|
class |
WFloatArrayList
Writable extension of FloatArrayList, as well as
FloatWritable implementation of WArrayList.
|
static class |
WFloatArrayList.WReusableFloatArrayList
Variant of WFloatArrayList that doesn't reallocate smaller backing
array on consecutive readFields/readElements calls, and so is suitable for
reusable use.
|
class |
WIntArrayList
Writable extension of IntArrayList, as well as
IntWritable implementation of WArrayList.
|
static class |
WIntArrayList.WReusableIntArrayList
Variant of WIntArrayList that doesn't reallocate smaller backing
array on consecutive readFields/readElements calls, and so is suitable for
reusable use.
|
class |
WLongArrayList
Writable extension of LongArrayList, as well as
LongWritable implementation of WArrayList.
|
static class |
WLongArrayList.WReusableLongArrayList
Variant of WLongArrayList that doesn't reallocate smaller backing
array on consecutive readFields/readElements calls, and so is suitable for
reusable use.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.