Package | Description |
---|---|
org.apache.giraph.block_app.migration |
Migration utility for transforming standard Giraph applications, into
Block Applications.
|
org.apache.giraph.examples.block_app |
Package of Giraph examples for Block Applications.
|
Modifier and Type | Class and Description |
---|---|
static class |
MigrationAbstractComputation.MigrationBasicComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable>
Drop-in replacement for BasicComputation when migrating to
Blocks Framework, disallowing functions that are tied to
execution order.
|
static class |
MigrationAbstractComputation.MigrationFullAbstractComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M1 extends org.apache.hadoop.io.Writable,M2 extends org.apache.hadoop.io.Writable>
Drop-in replacement for AbstractComputation when migrating to
Blocks Framework.
|
static class |
MigrationAbstractComputation.MigrationFullBasicComputation<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable,M extends org.apache.hadoop.io.Writable>
Drop-in replacement for BasicComputation when migrating to
Blocks Framework.
|
Modifier and Type | Method and Description |
---|---|
Class<? extends MigrationAbstractComputation> |
MigrationMasterCompute.MigrationFullMasterCompute.getComputation() |
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,MR extends org.apache.hadoop.io.Writable,MS extends org.apache.hadoop.io.Writable> |
MigrationPiece.createMigrationPiece(Class<? extends MigrationAbstractComputation<I,V,E,MR,MS>> computationClass,
MigrationMasterCompute masterCompute,
Supplier<Iterable<MR>> previousMessagesSupplier,
Consumer<Iterable<MS>> currentMessagesConsumer,
Class<MS> messageClass,
Class<? extends MessageCombiner<? super I,MS>> messageCombinerClass) |
Modifier and Type | Class and Description |
---|---|
static class |
SimpleMigrationMasterBlockFactory.SimpleMigrationMasterComputation
Demonstrates a computation with a centralized part implemented via a
MasterCompute.
|
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.