Package | Description |
---|---|
org.apache.giraph.block_app.reducers.array |
Reducers for collecting arrays of objects.
|
Modifier and Type | Class and Description |
---|---|
static class |
ArrayOfHandles.ArrayOfReducers<S,R>
ReducerArrayHandle implemented as an array of separate reducer handles.
|
Modifier and Type | Method and Description |
---|---|
static <S,R extends org.apache.hadoop.io.Writable> |
BasicArrayReduce.createArrayHandles(int fixedSize,
PrimitiveTypeOps<R> typeOps,
ReduceOperation<S,R> elementReduceOp,
CreateReducersApi.CreateReducerFunctionApi createFunction)
Registers one new reducer, that will reduce BasicArray,
by reducing individual elements using
elementReduceOp ,
with predefined size. |
static <S,T extends org.apache.hadoop.io.Writable> |
ArrayReduce.createArrayHandles(int fixedSize,
ReduceOperation<S,T> elementReduceOp,
CreateReducersApi.CreateReducerFunctionApi createFunction)
Registers one new reducer, that will reduce array of objects,
by reducing individual elements using
elementReduceOp . |
static <S,R extends org.apache.hadoop.io.Writable> |
BasicArrayReduce.createArrayHandles(PrimitiveTypeOps<R> typeOps,
ReduceOperation<S,R> elementReduceOp,
CreateReducersApi.CreateReducerFunctionApi createFunction)
Registers one new reducer, that will reduce BasicArray,
by reducing individual elements using
elementReduceOp ,
with unbounded size. |
static <S,R extends org.apache.hadoop.io.Writable> |
HugeArrayUtils.createGlobalReducerArrayHandle(int fixedSize,
ReduceOperation<S,R> elementReduceOp,
CreateReducersApi reduceApi)
Create global array of reducers, by splitting the huge array
into NUM_STRIPES number of parts.
|
static <S,R extends org.apache.hadoop.io.Writable> |
HugeArrayUtils.createGlobalReducerArrayHandle(int fixedSize,
ReduceOperation<S,R> elementReduceOp,
CreateReducersApi reduceApi,
int maxNumStripes)
Create global array of reducers, by splitting the huge array
into
maxNumStripes number of parts. |
static <S,R extends org.apache.hadoop.io.Writable> |
BasicArrayReduce.createLocalArrayHandles(int fixedSize,
PrimitiveTypeOps<R> typeOps,
ReduceOperation<S,R> elementReduceOp,
CreateReducersApi reduceApi)
Registers one new local reducer, that will reduce BasicArray,
by reducing individual elements using
elementReduceOp ,
with predefined size. |
static <S,R extends org.apache.hadoop.io.Writable> |
BasicArrayReduce.createLocalArrayHandles(PrimitiveTypeOps<R> typeOps,
ReduceOperation<S,R> elementReduceOp,
CreateReducersApi reduceApi)
Registers one new local reducer, that will reduce BasicArray,
by reducing individual elements using
elementReduceOp ,
with unbounded size. |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.