Package | Description |
---|---|
org.apache.giraph.block_app.library |
Core library of Pieces and Suppliers, providing most common usages.
|
org.apache.giraph.block_app.library.internal |
Internal implementation of Pieces needed for Pieces utility class.
|
org.apache.giraph.block_app.library.striping |
Utilities for striping.
|
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 <I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> |
VertexSuppliers.vertexNeighborsSupplier(Predicate<I> toSupply)
Supplier which extracts and returns Iterator over neighbor IDs
that return true for given predicate.
|
Modifier and Type | Method and Description |
---|---|
Block |
SendMessageWithCombinerPiece.stripeByReceiver(int stripes,
Int2ObjFunction<Int2ObjFunction<Predicate<I>>> stripeSupplier)
Stripe message sending computation across multiple stripes, in
each stripe only part of the vertices will receive messages.
|
Block |
SendMessagePiece.stripeByReceiver(int stripes,
Int2ObjFunction<Int2ObjFunction<Predicate<I>>> stripeSupplier)
Stripe message sending computation across multiple stripes, in
each stripe only part of the vertices will receive messages.
|
Modifier and Type | Method and Description |
---|---|
static <I extends org.apache.hadoop.io.WritableComparable> |
StripingUtils.createSingleStripeBySendersFunction(Block block)
Given a block, creates a function that will given a predicate filter
calls to vertexSend function based on that predicate.
|
static Int2ObjFunction<Predicate<org.apache.hadoop.io.LongWritable>> |
StripingUtils.fastHashStripingPredicate(int stripes)
Fast hash-based striping for LongWritable IDs, returns a function
that for a given stripe index returns a predicate checking whether ID is
in that stripe.
|
Modifier and Type | Method and Description |
---|---|
static <I extends org.apache.hadoop.io.WritableComparable> |
StripingUtils.generateStripedBlock(int stripes,
Function<Predicate<I>,Block> blockGenerator,
Int2ObjFunction<Int2ObjFunction<Predicate<I>>> stripeSupplier)
Generate striped block, with given number of
stripes ,
using given blockGenerator to generate block for each stripe,
and using striping based on given stripeSupplier . |
static <I extends org.apache.hadoop.io.WritableComparable> |
StripingUtils.generateStripedBlock(int stripes,
Function<Predicate<I>,Block> blockGenerator,
Int2ObjFunction<Int2ObjFunction<Predicate<I>>> stripeSupplier)
Generate striped block, with given number of
stripes ,
using given blockGenerator to generate block for each stripe,
and using striping based on given stripeSupplier . |
static Block |
StripingUtils.generateStripedBlock(int stripes,
Function<Predicate<org.apache.hadoop.io.LongWritable>,Block> blockGenerator)
Generate striped block, with given number of
stripes ,
using given blockGenerator to generate block for each stripe. |
Modifier and Type | Method and Description |
---|---|
boolean |
WCollection.fastForEachWhileW(Predicate<T> f)
Traverse all elements of the collection, calling given function on each
element, or until predicate returns false.
|
Modifier and Type | Method and Description |
---|---|
boolean |
WBooleanArrayList.fastForEachWhileW(Predicate<org.apache.hadoop.io.BooleanWritable> f) |
boolean |
WByteArrayList.fastForEachWhileW(Predicate<org.apache.hadoop.io.ByteWritable> f) |
boolean |
WDoubleArrayList.fastForEachWhileW(Predicate<org.apache.hadoop.io.DoubleWritable> f) |
boolean |
WFloatArrayList.fastForEachWhileW(Predicate<org.apache.hadoop.io.FloatWritable> f) |
boolean |
WIntArrayList.fastForEachWhileW(Predicate<org.apache.hadoop.io.IntWritable> f) |
boolean |
WLongArrayList.fastForEachWhileW(Predicate<org.apache.hadoop.io.LongWritable> f) |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.