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.block_app.reducers.map |
Reducers for collecting map of objects.
|
org.apache.giraph.types.ops |
Type coercion, inference, and reflection.
|
org.apache.giraph.types.ops.collections |
Collection interfaces and implementations provided by TypeOps classes.
|
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 |
---|---|
static <V extends org.apache.hadoop.io.Writable> |
HugeArrayUtils.broadcast(int count,
Int2ObjFunction<V> valueSupplier,
PrimitiveTypeOps<V> typeOps,
BlockMasterApi master)
Broadcast a huge array, by splitting into NUM_STRIPES number of parts.
|
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,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> |
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. |
Constructor and Description |
---|
BasicArrayReduce(int fixedSize,
PrimitiveTypeOps<R> typeOps,
ReduceOperation<S,R> elementReduceOp)
Create ReduceOperation that reduces BasicArrays by reducing individual
elements, with predefined size.
|
BasicArrayReduce(PrimitiveTypeOps<R> typeOps,
ReduceOperation<S,R> elementReduceOp)
Create ReduceOperation that reduces BasicArrays by reducing individual
elements, with unbounded size.
|
Constructor and Description |
---|
CollectPrimitiveReduceOperation(PrimitiveTypeOps<S> typeOps) |
Constructor and Description |
---|
CollectTuplesOfPrimitivesReduceOperation(List<PrimitiveTypeOps> typeOpsList) |
Modifier and Type | Method and Description |
---|---|
static <K extends org.apache.hadoop.io.WritableComparable,S,R extends org.apache.hadoop.io.Writable> |
BasicMapReduce.createLocalMapHandles(PrimitiveIdTypeOps<K> keyTypeOps,
PrimitiveTypeOps<R> typeOps,
ReduceOperation<S,R> elementReduceOp,
CreateReducersApi reduceApi)
Registers one new local reducer, that will reduce BasicMap,
by reducing individual elements corresponding to the same key
using
elementReduceOp . |
static <K extends org.apache.hadoop.io.WritableComparable,S,R extends org.apache.hadoop.io.Writable> |
BasicMapReduce.createMapHandles(PrimitiveIdTypeOps<K> keyTypeOps,
PrimitiveTypeOps<R> typeOps,
ReduceOperation<S,R> elementReduceOp,
CreateReducersApi.CreateReducerFunctionApi createFunction)
Registers one new reducer, that will reduce BasicMap,
by reducing individual elements corresponding to the same key
using
elementReduceOp . |
Constructor and Description |
---|
BasicMapReduce(PrimitiveIdTypeOps<K> keyTypeOps,
PrimitiveTypeOps<R> typeOps,
ReduceOperation<S,R> elementReduceOp)
Create ReduceOperation that reduces BasicMaps by reducing individual
elements corresponding to the same key.
|
Modifier and Type | Interface and Description |
---|---|
interface |
PrimitiveIdTypeOps<T>
Additional type operations to TypeOps for types that can be IDs,
and so can be used as keys in maps and values in sets.
|
Modifier and Type | Class and Description |
---|---|
class |
BooleanTypeOps
TypeOps implementation for working with BooleanWritable type
|
class |
ByteTypeOps
TypeOps implementation for working with ByteWritable type
|
class |
DoubleTypeOps
TypeOps implementation for working with DoubleWritable type
|
class |
FloatTypeOps
TypeOps implementation for working with FloatWritable type
|
class |
IntTypeOps
TypeOps implementation for working with IntWritable type
|
class |
LongTypeOps
TypeOps implementation for working with LongWritable type
|
Modifier and Type | Method and Description |
---|---|
static <T> PrimitiveTypeOps<T> |
TypeOpsUtils.getPrimitiveTypeOps(Class<T> type)
Get PrimitiveTypeOps for given type.
|
static <T> PrimitiveTypeOps<T> |
TypeOpsUtils.getPrimitiveTypeOpsOrNull(Class<T> type)
Get PrimitiveTypeOps for given type, or null if there is none.
|
Modifier and Type | Method and Description |
---|---|
PrimitiveTypeOps<T> |
WCollection.getElementTypeOps()
TypeOps for type of elements this object holds
|
Modifier and Type | Method and Description |
---|---|
PrimitiveTypeOps<org.apache.hadoop.io.ByteWritable> |
WByteArrayList.getElementTypeOps() |
PrimitiveTypeOps<org.apache.hadoop.io.IntWritable> |
WIntArrayList.getElementTypeOps() |
PrimitiveTypeOps<org.apache.hadoop.io.BooleanWritable> |
WBooleanArrayList.getElementTypeOps() |
PrimitiveTypeOps<org.apache.hadoop.io.DoubleWritable> |
WDoubleArrayList.getElementTypeOps() |
PrimitiveTypeOps<org.apache.hadoop.io.FloatWritable> |
WFloatArrayList.getElementTypeOps() |
PrimitiveTypeOps<org.apache.hadoop.io.LongWritable> |
WLongArrayList.getElementTypeOps() |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.