Package | Description |
---|---|
org.apache.giraph.block_app.framework.api |
Interfaces representing full API to the underlying graph processing system.
|
org.apache.giraph.block_app.framework.internal |
Implementation of execution logic, guiding internal execution of
Block Application.
|
org.apache.giraph.block_app.migration |
Migration utility for transforming standard Giraph applications, into
Block Applications.
|
Modifier and Type | Interface and Description |
---|---|
interface |
BlockMasterApi
Block computation API available for the master methods.
|
interface |
BlockWorkerApi<I extends org.apache.hadoop.io.WritableComparable>
Block computation API available for worker methods.
|
interface |
BlockWorkerContextApi<I extends org.apache.hadoop.io.WritableComparable>
Block computation API available for worker context methods.
|
interface |
BlockWorkerContextReceiveApi<I extends org.apache.hadoop.io.WritableComparable>
Block computation API available for worker context receive methods.
|
interface |
BlockWorkerContextSendApi<I extends org.apache.hadoop.io.WritableComparable,WM extends org.apache.hadoop.io.Writable>
Block computation API available for worker send methods.
|
interface |
BlockWorkerReceiveApi<I extends org.apache.hadoop.io.WritableComparable>
Block computation API available for worker receive methods.
|
interface |
BlockWorkerSendApi<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>
Block computation API available for worker send methods.
|
Modifier and Type | Method and Description |
---|---|
static void |
BlockCounters.setMasterTimeCounter(PairedPieceAndStage<?> masterPiece,
long superstep,
long millis,
StatusReporter reporter,
BlockMasterLogic.TimeStatsPerEvent timeStats) |
static void |
BlockCounters.setStageCounters(String prefix,
Object stage,
StatusReporter reporter)
Takes all fields from stage object, and puts them into counters,
if possible.
|
static void |
BlockCounters.setWorkerTimeCounter(BlockWorkerPieces<?> workerPieces,
long superstep,
long millis,
StatusReporter reporter,
BlockMasterLogic.TimeStatsPerEvent timeStats) |
Modifier and Type | Method and Description |
---|---|
StatusReporter |
MigrationMasterCompute.getContext() |
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.