Composable unit of execution.
Block without any pieces
|FilteringBlock<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
Block which filters out calls to vertexSend/vertexReceive functions of all pieces in a given block.
Block that executes one of two branches based on a condition
Number of pieces
Block that repeats another block given number of times.
Block that repeats another block until toQuit supplier returns true, but at most given number of times.
Block that executes provided blocks sequentially.
Copyright © 2011-2020 The Apache Software Foundation. All Rights Reserved.