com.rpl.rama

Interface Block.Impl

All Superinterfaces:

Block

All Known Subinterfaces:

Block.MultiOutImpl, Block.OutImpl

Enclosing interface:

Block

public static interface Block.Impl
extends Block

Nested Class Summary

Nested classes/interfaces inherited from interface com.rpl.rama.Block

Block.Impl, Block.MultiOutImpl, Block.Out, Block.OutImpl

Method Summary

Modifier and Type	Method and Description
Block.Impl	ackReturn(java.lang.Object arg) Accumulate value according to depot source options to return with depot appends done with AckLevel.ACK
Block.OutImpl	agg(Agg agg) Aggregates input in a batch block to a single value.
Block.Impl	agg(java.lang.String pstateVar, Agg agg) Update PState partition on current task with given aggregator.
Block.Impl	allPartition() Executes subsequent code on all tasks in module
Block.Impl	allPartition(java.lang.String pobjectVar) Executes subsequent code on all partitions of given depot or PState
Block.Impl	anchor(java.lang.String anchor) Attaches a no-op node with the given anchor
Block.Impl	atomicBlock(Block block) Runs subblock until it completes synchronously.
Block.Impl	batchBlock(Block batchBlock) Specifies a batch block.
Block.Impl	branch(java.lang.String anchor, Block block)
Block.OutImpl	compoundAgg(CompoundAgg compoundAgg) Aggregates input in a batch block to a single value.
Block.Impl	compoundAgg(java.lang.String pstateVar, CompoundAgg compoundAgg) Update PState partition on current task with given aggregation template.
Block.Impl	cond(Case... cases) Evaluates condition for each Case in order.
Block.Impl	continueLoop(java.lang.Object... args) Executes another iteration of the loop.
Block.Impl	customPartition(RamaFunction1<java.lang.Integer,java.lang.Integer> op) Changes task to task ID specified by custom partitioner function with one argument.
<T0> Block.Impl	customPartition(RamaFunction2<java.lang.Integer,T0,java.lang.Integer> op, java.lang.Object arg0) Changes task to task ID specified by custom partitioner function with two arguments.
<T0,T1> Block.Impl	customPartition(RamaFunction3<java.lang.Integer,T0,T1,java.lang.Integer> op, java.lang.Object arg0, java.lang.Object arg1) Changes task to task ID specified by custom partitioner function with three arguments.
<T0,T1,T2> Block.Impl	customPartition(RamaFunction4<java.lang.Integer,T0,T1,T2,java.lang.Integer> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2) Changes task to task ID specified by custom partitioner function with four arguments.
<T0,T1,T2,T3> Block.Impl	customPartition(RamaFunction5<java.lang.Integer,T0,T1,T2,T3,java.lang.Integer> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3) Changes task to task ID specified by custom partitioner function with five arguments.
<T0,T1,T2,T3,T4> Block.Impl	customPartition(RamaFunction6<java.lang.Integer,T0,T1,T2,T3,T4,java.lang.Integer> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4) Changes task to task ID specified by custom partitioner function with six arguments.
<T0,T1,T2,T3,T4,T5> Block.Impl	customPartition(RamaFunction7<java.lang.Integer,T0,T1,T2,T3,T4,T5,java.lang.Integer> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, java.lang.Object arg5) Changes task to task ID specified by custom partitioner function with seven arguments.
<T0,T1,T2,T3,T4,T5,T6> Block.Impl	customPartition(RamaFunction8<java.lang.Integer,T0,T1,T2,T3,T4,T5,T6,java.lang.Integer> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, java.lang.Object arg5, java.lang.Object arg6) Changes task to task ID specified by custom partitioner function with eight arguments.
Block.Impl	customPartition(java.lang.String pobjectVar, RamaFunction1<java.lang.Integer,java.lang.Integer> op) Changes to task containing PState partition specified by custom partitioner function with one argument.
<T0> Block.Impl	customPartition(java.lang.String pobjectVar, RamaFunction2<java.lang.Integer,T0,java.lang.Integer> op, java.lang.Object arg0) Changes to task containing PState partition specified by custom partitioner function with two arguments.
<T0,T1> Block.Impl	customPartition(java.lang.String pobjectVar, RamaFunction3<java.lang.Integer,T0,T1,java.lang.Integer> op, java.lang.Object arg0, java.lang.Object arg1) Changes to task containing PState partition specified by custom partitioner function with three arguments.
<T0,T1,T2> Block.Impl	customPartition(java.lang.String pobjectVar, RamaFunction4<java.lang.Integer,T0,T1,T2,java.lang.Integer> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2) Changes to task containing PState partition specified by custom partitioner function with four arguments.
<T0,T1,T2,T3> Block.Impl	customPartition(java.lang.String pobjectVar, RamaFunction5<java.lang.Integer,T0,T1,T2,T3,java.lang.Integer> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3) Changes to task containing PState partition specified by custom partitioner function with five arguments.
<T0,T1,T2,T3,T4> Block.Impl	customPartition(java.lang.String pobjectVar, RamaFunction6<java.lang.Integer,T0,T1,T2,T3,T4,java.lang.Integer> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4) Changes to task containing PState partition specified by custom partitioner function with six arguments.
<T0,T1,T2,T3,T4,T5> Block.Impl	customPartition(java.lang.String pobjectVar, RamaFunction7<java.lang.Integer,T0,T1,T2,T3,T4,T5,java.lang.Integer> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, java.lang.Object arg5) Changes to task containing PState partition specified by custom partitioner function with seven arguments.
<T0,T1,T2,T3,T4,T5,T6> Block.Impl	customPartition(java.lang.String pobjectVar, RamaFunction8<java.lang.Integer,T0,T1,T2,T3,T4,T5,T6,java.lang.Integer> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, java.lang.Object arg5, java.lang.Object arg6) Changes to task containing PState partition specified by custom partitioner function with eight arguments.
Block.OutImpl	depotPartitionAppend(java.lang.String depotVar, java.lang.Object arg) Append data to the partition of the depot represented by current task.
Block.OutImpl	depotPartitionAppend(java.lang.String depotVar, java.lang.Object arg, AckLevel ackLevel) Append data to the partition of the depot represented by current task.
Block.Impl	directPartition(java.lang.Object argTaskId) Changes to specified task ID
Block.Impl	directPartition(java.lang.String pobjectVar, java.lang.Object argPartitionId) Changes to specified partition of the given depot or PState
<R> Block.OutImpl	each(RamaFunction0<R> op) Invokes a function of zero arguments.
<T0,R> Block.OutImpl	each(RamaFunction1<T0,R> op, java.lang.Object arg0) Invokes a function of one argument.
<T0,T1,R> Block.OutImpl	each(RamaFunction2<T0,T1,R> op, java.lang.Object arg0, java.lang.Object arg1) Invokes a function of two arguments.
<T0,T1,T2,R> Block.OutImpl	each(RamaFunction3<T0,T1,T2,R> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2) Invokes a function of three arguments.
<T0,T1,T2,T3,R> Block.OutImpl	each(RamaFunction4<T0,T1,T2,T3,R> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3) Invokes a function of four arguments.
<T0,T1,T2,T3,T4,R> Block.OutImpl	each(RamaFunction5<T0,T1,T2,T3,T4,R> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4) Invokes a function of five arguments.
<T0,T1,T2,T3,T4,T5,R> Block.OutImpl	each(RamaFunction6<T0,T1,T2,T3,T4,T5,R> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, java.lang.Object arg5) Invokes a function of six arguments.
<T0,T1,T2,T3,T4,T5,T6,R> Block.OutImpl	each(RamaFunction7<T0,T1,T2,T3,T4,T5,T6,R> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, java.lang.Object arg5, java.lang.Object arg6) Invokes a function of seven arguments.
<T0,T1,T2,T3,T4,T5,T6,T7,R> Block.OutImpl	each(RamaFunction8<T0,T1,T2,T3,T4,T5,T6,T7,R> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, java.lang.Object arg5, java.lang.Object arg6, java.lang.Object arg7) Invokes a function of eight arguments.
Block.MultiOutImpl	each(RamaOperation0 op) Invokes an operation of zero arguments.
<T0> Block.MultiOutImpl	each(RamaOperation1<T0> op, java.lang.Object arg0) Invokes an operation of one argument.
<T0,T1> Block.MultiOutImpl	each(RamaOperation2<T0,T1> op, java.lang.Object arg0, java.lang.Object arg1) Invokes an operation of two arguments.
<T0,T1,T2> Block.MultiOutImpl	each(RamaOperation3<T0,T1,T2> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2) Invokes an operation of three arguments.
<T0,T1,T2,T3> Block.MultiOutImpl	each(RamaOperation4<T0,T1,T2,T3> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3) Invokes an operation of four arguments.
<T0,T1,T2,T3,T4> Block.MultiOutImpl	each(RamaOperation5<T0,T1,T2,T3,T4> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4) Invokes an operation of five arguments.
<T0,T1,T2,T3,T4,T5> Block.MultiOutImpl	each(RamaOperation6<T0,T1,T2,T3,T4,T5> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, java.lang.Object arg5) Invokes an operation of six arguments.
<T0,T1,T2,T3,T4,T5,T6> Block.MultiOutImpl	each(RamaOperation7<T0,T1,T2,T3,T4,T5,T6> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, java.lang.Object arg5, java.lang.Object arg6) Invokes an operation of seven arguments.
<T0,T1,T2,T3,T4,T5,T6,T7> Block.MultiOutImpl	each(RamaOperation8<T0,T1,T2,T3,T4,T5,T6,T7> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, java.lang.Object arg5, java.lang.Object arg6, java.lang.Object arg7) Invokes an operation of eight arguments.
Block.OutImpl	eachAsync(RamaFunction0<java.util.concurrent.CompletableFuture> op) Invokes a function of zero arguments that returns its result asynchronously via a returned CompletableFuture.
<T0> Block.OutImpl	eachAsync(RamaFunction1<T0,java.util.concurrent.CompletableFuture> op, java.lang.Object arg0) Invokes a function of one argument that returns its result asynchronously via a returned CompletableFuture.
<T0,T1> Block.OutImpl	eachAsync(RamaFunction2<T0,T1,java.util.concurrent.CompletableFuture> op, java.lang.Object arg0, java.lang.Object arg1) Invokes a function of two arguments that returns its result asynchronously via a returned CompletableFuture.
<T0,T1,T2> Block.OutImpl	eachAsync(RamaFunction3<T0,T1,T2,java.util.concurrent.CompletableFuture> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2) Invokes a function of three arguments that returns its result asynchronously via a returned CompletableFuture.
<T0,T1,T2,T3> Block.OutImpl	eachAsync(RamaFunction4<T0,T1,T2,T3,java.util.concurrent.CompletableFuture> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3) Invokes a function of four arguments that returns its result asynchronously via a returned CompletableFuture.
<T0,T1,T2,T3,T4> Block.OutImpl	eachAsync(RamaFunction5<T0,T1,T2,T3,T4,java.util.concurrent.CompletableFuture> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4) Invokes a function of five arguments that returns its result asynchronously via a returned CompletableFuture.
<T0,T1,T2,T3,T4,T5> Block.OutImpl	eachAsync(RamaFunction6<T0,T1,T2,T3,T4,T5,java.util.concurrent.CompletableFuture> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, java.lang.Object arg5) Invokes a function of six arguments that returns its result asynchronously via a returned CompletableFuture.
<T0,T1,T2,T3,T4,T5,T6> Block.OutImpl	eachAsync(RamaFunction7<T0,T1,T2,T3,T4,T5,T6,java.util.concurrent.CompletableFuture> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, java.lang.Object arg5, java.lang.Object arg6) Invokes a function of seven arguments that returns its result asynchronously via a returned CompletableFuture.
<T0,T1,T2,T3,T4,T5,T6,T7> Block.OutImpl	eachAsync(RamaFunction8<T0,T1,T2,T3,T4,T5,T6,T7,java.util.concurrent.CompletableFuture> op, java.lang.Object arg0, java.lang.Object arg1, java.lang.Object arg2, java.lang.Object arg3, java.lang.Object arg4, java.lang.Object arg5, java.lang.Object arg6, java.lang.Object arg7) Invokes a function of eight arguments that returns its result asynchronously via a returned CompletableFuture.
Block.Impl	emitLoop(java.lang.Object... args) Emits from a loop.
void	execute() Execute the given Block on the current thread.
Block.OutImpl	explodeMaterialized(java.lang.String pstateVar) Emits all tuples across all partitions of a temporary PState created from Block.materialize(java.lang.Object...).
Block.OutImpl	explodeMicrobatch(java.lang.String microbatchVar) Emits all data for this microbatch source across all partitions of depot
Block.Impl	freshBatchSource() Declares a new batch source within pre-agg portion of a batch block
Block.Impl	globalPartition() Changes to task 0
Block.Impl	globalPartition(java.lang.String pobjectVar) Changes to partition 0 of given depot or PState.
Block.Impl	groupBy(java.lang.String var0, Block groupByBlock) Groups input by one key and performs aggregations in the specified block on each group of data independently.
Block.Impl	groupBy(java.lang.String var0, java.lang.String var1, Block groupByBlock) Groups input by two keys and performs aggregations in the specified block on each group of data independently.
Block.Impl	groupBy(java.lang.String var0, java.lang.String var1, java.lang.String var2, Block groupByBlock) Groups input by three keys and performs aggregations in the specified block on each group of data independently.
Block.Impl	groupBy(java.lang.String var0, java.lang.String var1, java.lang.String var2, java.lang.String var3, Block groupByBlock) Groups input by four keys and performs aggregations in the specified block on each group of data independently.
Block.Impl	groupBy(java.lang.String var0, java.lang.String var1, java.lang.String var2, java.lang.String var3, java.lang.String var4, Block groupByBlock) Groups input by five keys and performs aggregations in the specified block on each group of data independently.
Block.Impl	groupBy(java.lang.String var0, java.lang.String var1, java.lang.String var2, java.lang.String var3, java.lang.String var4, java.lang.String var5, Block groupByBlock) Groups input by six keys and performs aggregations in the specified block on each group of data independently.
Block.Impl	hashPartition(java.lang.Object arg) Changes tasks based on hash of argument modulo number of tasks in module.
Block.Impl	hashPartition(java.lang.String pobjectVar, java.lang.Object arg) Changes tasks based on hash of argument modulo number of partitions of given depot or PState.
Block.Impl	hook(java.lang.String anchor) Changes attachment point for subsequent code to node with given anchor
Block.Impl	ifTrue(java.lang.Object arg, Block thenBlock) If argument is truthy (not null or boolean false), runs the given subblock.
Block.Impl	ifTrue(java.lang.Object arg, Block thenBlock, Block elseBlock) If argument is truthy (not null or boolean false), runs thenBlock.
Block.OutImpl	invokeQuery(java.lang.String queryVarOrTopologyName, java.lang.Object... args) Invokes a colocated or mirror query topology
Block.Impl	keepTrue(java.lang.Object arg) Continues dataflow execution only if arg is truthy (not null or boolean false).
Block.Impl	limitAgg(LimitAgg limitAgg) Limits incoming data to a fixed amount according to optional sort options.
Block.Impl	localClear(java.lang.String pstateVar) Removes all data from the PState partition on current task.
Block.OutImpl	localSelect(java.lang.String pstateVar, Path path) Navigates into the PState partition on current task using the given Path.
Block.OutImpl	localSelect(java.lang.String pstateVar, Path path, SelectOptions options) Navigates into the PState partition on current task using the given Path.
Block.Impl	localTransform(java.lang.String pstateVar, Path path) Executes transform Path on the PState partition on current task.
Block.OutImpl	loop(Block loopBlock) Creates a dataflow loop with the given body.
Block.OutImpl	loopWithVars(LoopVars loopVars, Block loopBlock) Creates a dataflow loop with the given vars and body.
Block.Impl	macro(Block block) Inserts all code from given Block into the current callsite.
Block.OutImpl	materialize(java.lang.Object... args) Produces a temporary PState of tuples within a batch block in a microbatch topology.
Block.Impl	originPartition() Changes back to starting task for a query topology invocation.
Block.Impl	pathPartition(java.lang.String pstateVar, Path path) Changes to task for given PState containing data for given Path
Block.OutImpl	select(java.lang.Object arg, Path path) Changes to task for given PState containing data for given Path and then performs a localSelect.
Block.OutImpl	select(java.lang.Object arg, Path path, SelectOptions options) Changes to task for given PState containing data for given Path and then performs a localSelect.
Block.Impl	shufflePartition() Changes to a random task chosen uniformly.
Block.OutImpl	subBatch(SubBatch subBatch) Use specified SubBatch as a batch source in a batch block.
Block.Impl	subSource(java.lang.Object arg, SubSource... subsources) Conditionally dispatch code based on type of input object
Block.Impl	unify(java.lang.String anchor1, java.lang.String anchor2, java.lang.String... anchors) Attaches subsequent code to each of the anchors specified, merging computation flowing out of those nodes.
Block.Impl	yieldIfOvertime() Yield the task thread if current event is using too much time.

Methods inherited from interface com.rpl.rama.Block

ackReturn, agg, agg, allPartition, allPartition, anchor, atomicBlock, batchBlock, branch, compoundAgg, compoundAgg, cond, continueLoop, create, customPartition, customPartition, customPartition, customPartition, customPartition, customPartition, customPartition, customPartition, customPartition, customPartition, customPartition, customPartition, customPartition, customPartition, customPartition, customPartition, depotPartitionAppend, depotPartitionAppend, directPartition, directPartition, each, each, each, each, each, each, each, each, each, each, each, each, each, each, each, each, each, each, eachAsync, eachAsync, eachAsync, eachAsync, eachAsync, eachAsync, eachAsync, eachAsync, eachAsync, emitLoop, explodeMaterialized, explodeMicrobatch, freshBatchSource, globalPartition, globalPartition, groupBy, groupBy, groupBy, groupBy, groupBy, groupBy, hashPartition, hashPartition, hook, ifTrue, ifTrue, invokeQuery, keepTrue, limitAgg, localClear, localSelect, localSelect, localTransform, loop, loopWithVars, macro, materialize, originPartition, pathPartition, select, select, shufflePartition, subBatch, subSource, unify, yieldIfOvertime

Method Detail

anchor

Block.Impl anchor(java.lang.String anchor)

Attaches a no-op node with the given anchor

Parameters:

anchor - Label for the node

See Also:

Dataflow documentation

atomicBlock

Block.Impl atomicBlock(Block block)

Runs subblock until it completes synchronously. Then runs code following atomicBlock exactly one time.

Parameters:

block - Subblock

See Also:

Detailed atomicBlock documentation

branch

Block.Impl branch(java.lang.String anchor,
                  Block block)

each

<R> Block.OutImpl each(RamaFunction0<R> op)

Invokes a function of zero arguments. Each argument can be a value, var, or Expr. A function always emits exactly one time. Output can be captured with a call to out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

<T0,R> Block.OutImpl each(RamaFunction1<T0,R> op,
                          java.lang.Object arg0)

Invokes a function of one argument. Each argument can be a value, var, or Expr. A function always emits exactly one time. Output can be captured with a call to out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

<T0,T1,R> Block.OutImpl each(RamaFunction2<T0,T1,R> op,
                             java.lang.Object arg0,
                             java.lang.Object arg1)

Invokes a function of two arguments. Each argument can be a value, var, or Expr. A function always emits exactly one time. Output can be captured with a call to out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

<T0,T1,T2,R> Block.OutImpl each(RamaFunction3<T0,T1,T2,R> op,
                                java.lang.Object arg0,
                                java.lang.Object arg1,
                                java.lang.Object arg2)

Invokes a function of three arguments. Each argument can be a value, var, or Expr. A function always emits exactly one time. Output can be captured with a call to out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

<T0,T1,T2,T3,R> Block.OutImpl each(RamaFunction4<T0,T1,T2,T3,R> op,
                                   java.lang.Object arg0,
                                   java.lang.Object arg1,
                                   java.lang.Object arg2,
                                   java.lang.Object arg3)

Invokes a function of four arguments. Each argument can be a value, var, or Expr. A function always emits exactly one time. Output can be captured with a call to out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

<T0,T1,T2,T3,T4,R> Block.OutImpl each(RamaFunction5<T0,T1,T2,T3,T4,R> op,
                                      java.lang.Object arg0,
                                      java.lang.Object arg1,
                                      java.lang.Object arg2,
                                      java.lang.Object arg3,
                                      java.lang.Object arg4)

Invokes a function of five arguments. Each argument can be a value, var, or Expr. A function always emits exactly one time. Output can be captured with a call to out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

<T0,T1,T2,T3,T4,T5,R> Block.OutImpl each(RamaFunction6<T0,T1,T2,T3,T4,T5,R> op,
                                         java.lang.Object arg0,
                                         java.lang.Object arg1,
                                         java.lang.Object arg2,
                                         java.lang.Object arg3,
                                         java.lang.Object arg4,
                                         java.lang.Object arg5)

Invokes a function of six arguments. Each argument can be a value, var, or Expr. A function always emits exactly one time. Output can be captured with a call to out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

<T0,T1,T2,T3,T4,T5,T6,R> Block.OutImpl each(RamaFunction7<T0,T1,T2,T3,T4,T5,T6,R> op,
                                            java.lang.Object arg0,
                                            java.lang.Object arg1,
                                            java.lang.Object arg2,
                                            java.lang.Object arg3,
                                            java.lang.Object arg4,
                                            java.lang.Object arg5,
                                            java.lang.Object arg6)

Invokes a function of seven arguments. Each argument can be a value, var, or Expr. A function always emits exactly one time. Output can be captured with a call to out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

<T0,T1,T2,T3,T4,T5,T6,T7,R> Block.OutImpl each(RamaFunction8<T0,T1,T2,T3,T4,T5,T6,T7,R> op,
                                               java.lang.Object arg0,
                                               java.lang.Object arg1,
                                               java.lang.Object arg2,
                                               java.lang.Object arg3,
                                               java.lang.Object arg4,
                                               java.lang.Object arg5,
                                               java.lang.Object arg6,
                                               java.lang.Object arg7)

Invokes a function of eight arguments. Each argument can be a value, var, or Expr. A function always emits exactly one time. Output can be captured with a call to out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

Block.MultiOutImpl each(RamaOperation0 op)

Invokes an operation of zero arguments. Each argument can be a value, var, or Expr. An operation can emit any number of times to any number of output streams. Output can be captured with calls to outStream and out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Operation to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

<T0> Block.MultiOutImpl each(RamaOperation1<T0> op,
                             java.lang.Object arg0)

Invokes an operation of one argument. Each argument can be a value, var, or Expr. An operation can emit any number of times to any number of output streams. Output can be captured with calls to outStream and out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Operation to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

<T0,T1> Block.MultiOutImpl each(RamaOperation2<T0,T1> op,
                                java.lang.Object arg0,
                                java.lang.Object arg1)

Invokes an operation of two arguments. Each argument can be a value, var, or Expr. An operation can emit any number of times to any number of output streams. Output can be captured with calls to outStream and out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Operation to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

<T0,T1,T2> Block.MultiOutImpl each(RamaOperation3<T0,T1,T2> op,
                                   java.lang.Object arg0,
                                   java.lang.Object arg1,
                                   java.lang.Object arg2)

Invokes an operation of three arguments. Each argument can be a value, var, or Expr. An operation can emit any number of times to any number of output streams. Output can be captured with calls to outStream and out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Operation to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

<T0,T1,T2,T3> Block.MultiOutImpl each(RamaOperation4<T0,T1,T2,T3> op,
                                      java.lang.Object arg0,
                                      java.lang.Object arg1,
                                      java.lang.Object arg2,
                                      java.lang.Object arg3)

Invokes an operation of four arguments. Each argument can be a value, var, or Expr. An operation can emit any number of times to any number of output streams. Output can be captured with calls to outStream and out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Operation to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

<T0,T1,T2,T3,T4> Block.MultiOutImpl each(RamaOperation5<T0,T1,T2,T3,T4> op,
                                         java.lang.Object arg0,
                                         java.lang.Object arg1,
                                         java.lang.Object arg2,
                                         java.lang.Object arg3,
                                         java.lang.Object arg4)

Invokes an operation of five arguments. Each argument can be a value, var, or Expr. An operation can emit any number of times to any number of output streams. Output can be captured with calls to outStream and out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Operation to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

<T0,T1,T2,T3,T4,T5> Block.MultiOutImpl each(RamaOperation6<T0,T1,T2,T3,T4,T5> op,
                                            java.lang.Object arg0,
                                            java.lang.Object arg1,
                                            java.lang.Object arg2,
                                            java.lang.Object arg3,
                                            java.lang.Object arg4,
                                            java.lang.Object arg5)

Invokes an operation of six arguments. Each argument can be a value, var, or Expr. An operation can emit any number of times to any number of output streams. Output can be captured with calls to outStream and out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Operation to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

<T0,T1,T2,T3,T4,T5,T6> Block.MultiOutImpl each(RamaOperation7<T0,T1,T2,T3,T4,T5,T6> op,
                                               java.lang.Object arg0,
                                               java.lang.Object arg1,
                                               java.lang.Object arg2,
                                               java.lang.Object arg3,
                                               java.lang.Object arg4,
                                               java.lang.Object arg5,
                                               java.lang.Object arg6)

Invokes an operation of seven arguments. Each argument can be a value, var, or Expr. An operation can emit any number of times to any number of output streams. Output can be captured with calls to outStream and out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Operation to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

each

<T0,T1,T2,T3,T4,T5,T6,T7> Block.MultiOutImpl each(RamaOperation8<T0,T1,T2,T3,T4,T5,T6,T7> op,
                                                  java.lang.Object arg0,
                                                  java.lang.Object arg1,
                                                  java.lang.Object arg2,
                                                  java.lang.Object arg3,
                                                  java.lang.Object arg4,
                                                  java.lang.Object arg5,
                                                  java.lang.Object arg6,
                                                  java.lang.Object arg7)

Invokes an operation of eight arguments. Each argument can be a value, var, or Expr. An operation can emit any number of times to any number of output streams. Output can be captured with calls to outStream and out following this node. Built-in functions and operations can be found as static fields of the Ops class.

Parameters:

op - Operation to execute. Can also be specified as a lambda or method reference.

See Also:

Tutorial

eachAsync

Block.OutImpl eachAsync(RamaFunction0<java.util.concurrent.CompletableFuture> op)

Invokes a function of zero arguments that returns its result asynchronously via a returned CompletableFuture. This is used to interact with external systems without blocking the task thread. Each argument can be a value, var, or Expr. Output can be captured with a call to out following this node. The var bound by out is the value delivered to the returned CompletableFuture.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Documentation on integrating external tools

eachAsync

<T0> Block.OutImpl eachAsync(RamaFunction1<T0,java.util.concurrent.CompletableFuture> op,
                             java.lang.Object arg0)

Invokes a function of one argument that returns its result asynchronously via a returned CompletableFuture. This is used to interact with external systems without blocking the task thread. Each argument can be a value, var, or Expr. Output can be captured with a call to out following this node. The var bound by out is the value delivered to the returned CompletableFuture.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Documentation on integrating external tools

eachAsync

<T0,T1> Block.OutImpl eachAsync(RamaFunction2<T0,T1,java.util.concurrent.CompletableFuture> op,
                                java.lang.Object arg0,
                                java.lang.Object arg1)

Invokes a function of two arguments that returns its result asynchronously via a returned CompletableFuture. This is used to interact with external systems without blocking the task thread. Each argument can be a value, var, or Expr. Output can be captured with a call to out following this node. The var bound by out is the value delivered to the returned CompletableFuture.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Documentation on integrating external tools

eachAsync

<T0,T1,T2> Block.OutImpl eachAsync(RamaFunction3<T0,T1,T2,java.util.concurrent.CompletableFuture> op,
                                   java.lang.Object arg0,
                                   java.lang.Object arg1,
                                   java.lang.Object arg2)

Invokes a function of three arguments that returns its result asynchronously via a returned CompletableFuture. This is used to interact with external systems without blocking the task thread. Each argument can be a value, var, or Expr. Output can be captured with a call to out following this node. The var bound by out is the value delivered to the returned CompletableFuture.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Documentation on integrating external tools

eachAsync

<T0,T1,T2,T3> Block.OutImpl eachAsync(RamaFunction4<T0,T1,T2,T3,java.util.concurrent.CompletableFuture> op,
                                      java.lang.Object arg0,
                                      java.lang.Object arg1,
                                      java.lang.Object arg2,
                                      java.lang.Object arg3)

Invokes a function of four arguments that returns its result asynchronously via a returned CompletableFuture. This is used to interact with external systems without blocking the task thread. Each argument can be a value, var, or Expr. Output can be captured with a call to out following this node. The var bound by out is the value delivered to the returned CompletableFuture.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Documentation on integrating external tools

eachAsync

<T0,T1,T2,T3,T4> Block.OutImpl eachAsync(RamaFunction5<T0,T1,T2,T3,T4,java.util.concurrent.CompletableFuture> op,
                                         java.lang.Object arg0,
                                         java.lang.Object arg1,
                                         java.lang.Object arg2,
                                         java.lang.Object arg3,
                                         java.lang.Object arg4)

Invokes a function of five arguments that returns its result asynchronously via a returned CompletableFuture. This is used to interact with external systems without blocking the task thread. Each argument can be a value, var, or Expr. Output can be captured with a call to out following this node. The var bound by out is the value delivered to the returned CompletableFuture.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Documentation on integrating external tools

eachAsync

<T0,T1,T2,T3,T4,T5> Block.OutImpl eachAsync(RamaFunction6<T0,T1,T2,T3,T4,T5,java.util.concurrent.CompletableFuture> op,
                                            java.lang.Object arg0,
                                            java.lang.Object arg1,
                                            java.lang.Object arg2,
                                            java.lang.Object arg3,
                                            java.lang.Object arg4,
                                            java.lang.Object arg5)

Invokes a function of six arguments that returns its result asynchronously via a returned CompletableFuture. This is used to interact with external systems without blocking the task thread. Each argument can be a value, var, or Expr. Output can be captured with a call to out following this node. The var bound by out is the value delivered to the returned CompletableFuture.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Documentation on integrating external tools

eachAsync

<T0,T1,T2,T3,T4,T5,T6> Block.OutImpl eachAsync(RamaFunction7<T0,T1,T2,T3,T4,T5,T6,java.util.concurrent.CompletableFuture> op,
                                               java.lang.Object arg0,
                                               java.lang.Object arg1,
                                               java.lang.Object arg2,
                                               java.lang.Object arg3,
                                               java.lang.Object arg4,
                                               java.lang.Object arg5,
                                               java.lang.Object arg6)

Invokes a function of seven arguments that returns its result asynchronously via a returned CompletableFuture. This is used to interact with external systems without blocking the task thread. Each argument can be a value, var, or Expr. Output can be captured with a call to out following this node. The var bound by out is the value delivered to the returned CompletableFuture.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Documentation on integrating external tools

eachAsync

<T0,T1,T2,T3,T4,T5,T6,T7> Block.OutImpl eachAsync(RamaFunction8<T0,T1,T2,T3,T4,T5,T6,T7,java.util.concurrent.CompletableFuture> op,
                                                  java.lang.Object arg0,
                                                  java.lang.Object arg1,
                                                  java.lang.Object arg2,
                                                  java.lang.Object arg3,
                                                  java.lang.Object arg4,
                                                  java.lang.Object arg5,
                                                  java.lang.Object arg6,
                                                  java.lang.Object arg7)

Invokes a function of eight arguments that returns its result asynchronously via a returned CompletableFuture. This is used to interact with external systems without blocking the task thread. Each argument can be a value, var, or Expr. Output can be captured with a call to out following this node. The var bound by out is the value delivered to the returned CompletableFuture.

Parameters:

op - Function to execute. Can also be specified as a lambda or method reference.

See Also:

Documentation on integrating external tools

customPartition

Block.Impl customPartition(RamaFunction1<java.lang.Integer,java.lang.Integer> op)

Changes task to task ID specified by custom partitioner function with one argument. Custom partitioner function receives all dataflow arguments followed by the number of tasks in the module.

Parameters:

op - Custom partitioner function. Can also be specified as a lambda or method reference.

See Also:

Partitioners documentation

customPartition

<T0> Block.Impl customPartition(RamaFunction2<java.lang.Integer,T0,java.lang.Integer> op,
                                java.lang.Object arg0)

Changes task to task ID specified by custom partitioner function with two arguments. Custom partitioner function receives all dataflow arguments followed by the number of tasks in the module.

Parameters:

op - Custom partitioner function. Can also be specified as a lambda or method reference.

See Also:

Partitioners documentation

customPartition

<T0,T1> Block.Impl customPartition(RamaFunction3<java.lang.Integer,T0,T1,java.lang.Integer> op,
                                   java.lang.Object arg0,
                                   java.lang.Object arg1)

Changes task to task ID specified by custom partitioner function with three arguments. Custom partitioner function receives all dataflow arguments followed by the number of tasks in the module.

Parameters:

op - Custom partitioner function. Can also be specified as a lambda or method reference.

See Also:

Partitioners documentation

customPartition

<T0,T1,T2> Block.Impl customPartition(RamaFunction4<java.lang.Integer,T0,T1,T2,java.lang.Integer> op,
                                      java.lang.Object arg0,
                                      java.lang.Object arg1,
                                      java.lang.Object arg2)

Changes task to task ID specified by custom partitioner function with four arguments. Custom partitioner function receives all dataflow arguments followed by the number of tasks in the module.

Parameters:

op - Custom partitioner function. Can also be specified as a lambda or method reference.

See Also:

Partitioners documentation

customPartition

<T0,T1,T2,T3> Block.Impl customPartition(RamaFunction5<java.lang.Integer,T0,T1,T2,T3,java.lang.Integer> op,
                                         java.lang.Object arg0,
                                         java.lang.Object arg1,
                                         java.lang.Object arg2,
                                         java.lang.Object arg3)

Changes task to task ID specified by custom partitioner function with five arguments. Custom partitioner function receives all dataflow arguments followed by the number of tasks in the module.

Parameters:

op - Custom partitioner function. Can also be specified as a lambda or method reference.

See Also:

Partitioners documentation

customPartition

<T0,T1,T2,T3,T4> Block.Impl customPartition(RamaFunction6<java.lang.Integer,T0,T1,T2,T3,T4,java.lang.Integer> op,
                                            java.lang.Object arg0,
                                            java.lang.Object arg1,
                                            java.lang.Object arg2,
                                            java.lang.Object arg3,
                                            java.lang.Object arg4)

Changes task to task ID specified by custom partitioner function with six arguments. Custom partitioner function receives all dataflow arguments followed by the number of tasks in the module.

Parameters:

op - Custom partitioner function. Can also be specified as a lambda or method reference.

See Also:

Partitioners documentation

customPartition

<T0,T1,T2,T3,T4,T5> Block.Impl customPartition(RamaFunction7<java.lang.Integer,T0,T1,T2,T3,T4,T5,java.lang.Integer> op,
                                               java.lang.Object arg0,
                                               java.lang.Object arg1,
                                               java.lang.Object arg2,
                                               java.lang.Object arg3,
                                               java.lang.Object arg4,
                                               java.lang.Object arg5)

Changes task to task ID specified by custom partitioner function with seven arguments. Custom partitioner function receives all dataflow arguments followed by the number of tasks in the module.

Parameters:

op - Custom partitioner function. Can also be specified as a lambda or method reference.

See Also:

Partitioners documentation

customPartition

<T0,T1,T2,T3,T4,T5,T6> Block.Impl customPartition(RamaFunction8<java.lang.Integer,T0,T1,T2,T3,T4,T5,T6,java.lang.Integer> op,
                                                  java.lang.Object arg0,
                                                  java.lang.Object arg1,
                                                  java.lang.Object arg2,
                                                  java.lang.Object arg3,
                                                  java.lang.Object arg4,
                                                  java.lang.Object arg5,
                                                  java.lang.Object arg6)

Changes task to task ID specified by custom partitioner function with eight arguments. Custom partitioner function receives all dataflow arguments followed by the number of tasks in the module.

Parameters:

op - Custom partitioner function. Can also be specified as a lambda or method reference.

See Also:

Partitioners documentation

customPartition

Block.Impl customPartition(java.lang.String pobjectVar,
                           RamaFunction1<java.lang.Integer,java.lang.Integer> op)

Changes to task containing PState partition specified by custom partitioner function with one argument. Custom partitioner function receives all dataflow arguments followed by the number of partitions of the PState.

Parameters:

op - Custom partitioner function. Can also be specified as a lambda or method reference.

See Also:

Partitioners documentation

customPartition

<T0> Block.Impl customPartition(java.lang.String pobjectVar,
                                RamaFunction2<java.lang.Integer,T0,java.lang.Integer> op,
                                java.lang.Object arg0)

Changes to task containing PState partition specified by custom partitioner function with two arguments. Custom partitioner function receives all dataflow arguments followed by the number of partitions of the PState.

Parameters:

op - Custom partitioner function. Can also be specified as a lambda or method reference.

See Also:

Partitioners documentation

customPartition

<T0,T1> Block.Impl customPartition(java.lang.String pobjectVar,
                                   RamaFunction3<java.lang.Integer,T0,T1,java.lang.Integer> op,
                                   java.lang.Object arg0,
                                   java.lang.Object arg1)

Changes to task containing PState partition specified by custom partitioner function with three arguments. Custom partitioner function receives all dataflow arguments followed by the number of partitions of the PState.

Parameters:

op - Custom partitioner function. Can also be specified as a lambda or method reference.

See Also:

Partitioners documentation

customPartition

<T0,T1,T2> Block.Impl customPartition(java.lang.String pobjectVar,
                                      RamaFunction4<java.lang.Integer,T0,T1,T2,java.lang.Integer> op,
                                      java.lang.Object arg0,
                                      java.lang.Object arg1,
                                      java.lang.Object arg2)

Changes to task containing PState partition specified by custom partitioner function with four arguments. Custom partitioner function receives all dataflow arguments followed by the number of partitions of the PState.

Parameters:

op - Custom partitioner function. Can also be specified as a lambda or method reference.

See Also:

Partitioners documentation

customPartition

<T0,T1,T2,T3> Block.Impl customPartition(java.lang.String pobjectVar,
                                         RamaFunction5<java.lang.Integer,T0,T1,T2,T3,java.lang.Integer> op,
                                         java.lang.Object arg0,
                                         java.lang.Object arg1,
                                         java.lang.Object arg2,
                                         java.lang.Object arg3)

Changes to task containing PState partition specified by custom partitioner function with five arguments. Custom partitioner function receives all dataflow arguments followed by the number of partitions of the PState.

Parameters:

op - Custom partitioner function. Can also be specified as a lambda or method reference.

See Also:

Partitioners documentation

customPartition

<T0,T1,T2,T3,T4> Block.Impl customPartition(java.lang.String pobjectVar,
                                            RamaFunction6<java.lang.Integer,T0,T1,T2,T3,T4,java.lang.Integer> op,
                                            java.lang.Object arg0,
                                            java.lang.Object arg1,
                                            java.lang.Object arg2,
                                            java.lang.Object arg3,
                                            java.lang.Object arg4)

Changes to task containing PState partition specified by custom partitioner function with six arguments. Custom partitioner function receives all dataflow arguments followed by the number of partitions of the PState.

Parameters:

op - Custom partitioner function. Can also be specified as a lambda or method reference.

See Also:

Partitioners documentation

customPartition

<T0,T1,T2,T3,T4,T5> Block.Impl customPartition(java.lang.String pobjectVar,
                                               RamaFunction7<java.lang.Integer,T0,T1,T2,T3,T4,T5,java.lang.Integer> op,
                                               java.lang.Object arg0,
                                               java.lang.Object arg1,
                                               java.lang.Object arg2,
                                               java.lang.Object arg3,
                                               java.lang.Object arg4,
                                               java.lang.Object arg5)

Changes to task containing PState partition specified by custom partitioner function with seven arguments. Custom partitioner function receives all dataflow arguments followed by the number of partitions of the PState.

Parameters:

op - Custom partitioner function. Can also be specified as a lambda or method reference.

See Also:

Partitioners documentation

customPartition

<T0,T1,T2,T3,T4,T5,T6> Block.Impl customPartition(java.lang.String pobjectVar,
                                                  RamaFunction8<java.lang.Integer,T0,T1,T2,T3,T4,T5,T6,java.lang.Integer> op,
                                                  java.lang.Object arg0,
                                                  java.lang.Object arg1,
                                                  java.lang.Object arg2,
                                                  java.lang.Object arg3,
                                                  java.lang.Object arg4,
                                                  java.lang.Object arg5,
                                                  java.lang.Object arg6)

Changes to task containing PState partition specified by custom partitioner function with eight arguments. Custom partitioner function receives all dataflow arguments followed by the number of partitions of the PState.

Parameters:

op - Custom partitioner function. Can also be specified as a lambda or method reference.

See Also:

Partitioners documentation

groupBy

Block.Impl groupBy(java.lang.String var0,
                   Block groupByBlock)

Groups input by one key and performs aggregations in the specified block on each group of data independently. Only usable in batchBlock. Emits into postagg the vars for keys and results of aggregations.

Parameters:

groupByBlock - Block containing aggregation code

See Also:

Detailed groupBy documentation

groupBy

Block.Impl groupBy(java.lang.String var0,
                   java.lang.String var1,
                   Block groupByBlock)

Groups input by two keys and performs aggregations in the specified block on each group of data independently. Only usable in batchBlock. Emits into postagg the vars for keys and results of aggregations.

Parameters:

groupByBlock - Block containing aggregation code

See Also:

Detailed groupBy documentation

groupBy

Block.Impl groupBy(java.lang.String var0,
                   java.lang.String var1,
                   java.lang.String var2,
                   Block groupByBlock)

Groups input by three keys and performs aggregations in the specified block on each group of data independently. Only usable in batchBlock. Emits into postagg the vars for keys and results of aggregations.

Parameters:

groupByBlock - Block containing aggregation code

See Also:

Detailed groupBy documentation

groupBy

Block.Impl groupBy(java.lang.String var0,
                   java.lang.String var1,
                   java.lang.String var2,
                   java.lang.String var3,
                   Block groupByBlock)

Groups input by four keys and performs aggregations in the specified block on each group of data independently. Only usable in batchBlock. Emits into postagg the vars for keys and results of aggregations.

Parameters:

groupByBlock - Block containing aggregation code

See Also:

Detailed groupBy documentation

groupBy

Block.Impl groupBy(java.lang.String var0,
                   java.lang.String var1,
                   java.lang.String var2,
                   java.lang.String var3,
                   java.lang.String var4,
                   Block groupByBlock)

Groups input by five keys and performs aggregations in the specified block on each group of data independently. Only usable in batchBlock. Emits into postagg the vars for keys and results of aggregations.

Parameters:

groupByBlock - Block containing aggregation code

See Also:

Detailed groupBy documentation

groupBy

Block.Impl groupBy(java.lang.String var0,
                   java.lang.String var1,
                   java.lang.String var2,
                   java.lang.String var3,
                   java.lang.String var4,
                   java.lang.String var5,
                   Block groupByBlock)

Groups input by six keys and performs aggregations in the specified block on each group of data independently. Only usable in batchBlock. Emits into postagg the vars for keys and results of aggregations.

Parameters:

groupByBlock - Block containing aggregation code

See Also:

Detailed groupBy documentation

hook

Block.Impl hook(java.lang.String anchor)

Changes attachment point for subsequent code to node with given anchor

Parameters:

anchor - Label of node to attach to

See Also:

Dataflow documentation

ifTrue

Block.Impl ifTrue(java.lang.Object arg,
                  Block thenBlock)

If argument is truthy (not null or boolean false), runs the given subblock. In either case, continues to the code following the ifTrue.

Parameters:

arg - Value, var, or Expr to test for truthiness (not null or boolean false). Common to use an Expr here.

thenBlock - Subblock run if condition passes

See Also:

Dataflow documentation

ifTrue

Block.Impl ifTrue(java.lang.Object arg,
                  Block thenBlock,
                  Block elseBlock)

If argument is truthy (not null or boolean false), runs thenBlock. Otherwise, runs elseBlock. In either case, continues to the code following the ifTrue.

Parameters:

arg - Value, var, or Expr to test for truthiness (not null or boolean false). Common to use an Expr here.

thenBlock - Subblock run if condition passes

elseBlock - Subblock run if condition does not pass

See Also:

Dataflow documentation

keepTrue

Block.Impl keepTrue(java.lang.Object arg)

Continues dataflow execution only if arg is truthy (not null or boolean false).

Parameters:

arg - Value, var, or Expr

See Also:

Detailed keepTrue documentation

unify

Block.Impl unify(java.lang.String anchor1,
                 java.lang.String anchor2,
                 java.lang.String... anchors)

Attaches subsequent code to each of the anchors specified, merging computation flowing out of those nodes. After the unify the only vars in scope are vars that exist in all parent branches. Must unify at least two nodes.

See Also:

Unify documentation

loop

Block.OutImpl loop(Block loopBlock)

Creates a dataflow loop with the given body. emitLoop is used to emit from the loop, and continueLoop is used to execute the loop body again. A loop call can be optionally followed by a call to out to capture any output emitted as vars.

Parameters:

loopBlock - Body of the loop

See Also:

Dataflow documentation

loopWithVars

Block.OutImpl loopWithVars(LoopVars loopVars,
                           Block loopBlock)

Creates a dataflow loop with the given vars and body. emitLoop is used to emit from the loop, and continueLoop is used to execute the loop body again. The vars are given initial values and updated with each call to continueLoop. A loopWithVars call can be optionally followed by a call to out to capture any output emitted as vars.

Parameters:

loopVars - Declaration of vars for each iteration of loop

loopBlock - Body of the loop

See Also:

Dataflow documentation

continueLoop

Block.Impl continueLoop(java.lang.Object... args)

Executes another iteration of the loop. Can only be used within loop or loopWithVars. When used with loopWithVars, must provide as input values for all loop vars for the next loop iteration.

Parameters:

args - Values for loop vars for next iteration of loop

See Also:

Dataflow documentation

emitLoop

Block.Impl emitLoop(java.lang.Object... args)

Emits from a loop. Can only be used within loop or loopWithVars. This is only way for code following loop or loopWithVars to execute.

Parameters:

args - Values to emit

See Also:

Dataflow documentation

select

Block.OutImpl select(java.lang.Object arg,
                     Path path)

Changes to task for given PState containing data for given Path and then performs a localSelect. PState reference can be colocated PState or mirror PState. Code after select stays on new task and does not go back to original task.

Parameters:

arg - PState or object to query. Only changes tasks if PState var.

path - Path definition

See Also:

Path documentation, PState documentation

select

Block.OutImpl select(java.lang.Object arg,
                     Path path,
                     SelectOptions options)

Changes to task for given PState containing data for given Path and then performs a localSelect. PState reference can be colocated PState or mirror PState. Code after select stays on new task and does not go back to original task.

Parameters:

arg - PState or object to query. Only changes tasks if PState var.

path - Path definition

options - Options for select call

See Also:

Path documentation, PState documentation

localSelect

Block.OutImpl localSelect(java.lang.String pstateVar,
                          Path path)

Navigates into the PState partition on current task using the given Path. Emits once for every value navigated to. Use out to capture emits into subsequent dataflow code.

Parameters:

pstateVar - PState to query

path - Path definition

See Also:

Path documentation, PState documentation

localSelect

Block.OutImpl localSelect(java.lang.String pstateVar,
                          Path path,
                          SelectOptions options)

Navigates into the PState partition on current task using the given Path. Emits once for every value navigated to. Use out to capture emits into subsequent dataflow code.

Parameters:

pstateVar - PState to query

path - Path definition

options - Options for localSelect call

See Also:

Path documentation, PState documentation

localTransform

Block.Impl localTransform(java.lang.String pstateVar,
                          Path path)

Executes transform Path on the PState partition on current task.

Parameters:

pstateVar - PState to modify

path - Path definition

See Also:

Path documentation, PState documentation

localClear

Block.Impl localClear(java.lang.String pstateVar)

Removes all data from the PState partition on current task. Can only be used with PStates owned by stream topologies. Extremely expensive to run for large PState partitions.

Parameters:

pstateVar - PState to clear

See Also:

Path documentation, PState documentation

hashPartition

Block.Impl hashPartition(java.lang.Object arg)

Changes tasks based on hash of argument modulo number of tasks in module. The same argument always hashes to the same task.

Parameters:

arg - Value, var, or Expr

See Also:

Partitioners documentation

hashPartition

Block.Impl hashPartition(java.lang.String pobjectVar,
                         java.lang.Object arg)

Changes tasks based on hash of argument modulo number of partitions of given depot or PState. The same argument always hashes to the same task.

Parameters:

pobjectVar - Depot or PState reference

arg - Value, var, or Expr

See Also:

Partitioners documentation

allPartition

Block.Impl allPartition()

Executes subsequent code on all tasks in module

See Also:

Partitioners documentation

allPartition

Block.Impl allPartition(java.lang.String pobjectVar)

Executes subsequent code on all partitions of given depot or PState

Parameters:

pobjectVar - Depot or PState reference

See Also:

Partitioners documentation

globalPartition

Block.Impl globalPartition()

Changes to task 0

See Also:

Partitioners documentation

globalPartition

Block.Impl globalPartition(java.lang.String pobjectVar)

Changes to partition 0 of given depot or PState. For colocated depots and PStates this will be task 0.

Parameters:

pobjectVar - Depot or PState reference

See Also:

Partitioners documentation

shufflePartition

Block.Impl shufflePartition()

Changes to a random task chosen uniformly.

See Also:

Partitioners documentation

directPartition

Block.Impl directPartition(java.lang.Object argTaskId)

Changes to specified task ID

Parameters:

argTaskId - Value, var, or Expr

See Also:

Partitioners documentation

directPartition

Block.Impl directPartition(java.lang.String pobjectVar,
                           java.lang.Object argPartitionId)

Changes to specified partition of the given depot or PState

Parameters:

pobjectVar - Depot or PState reference

argPartitionId - Value, var, or Expr

See Also:

Partitioners documentation

pathPartition

Block.Impl pathPartition(java.lang.String pstateVar,
                         Path path)

Changes to task for given PState containing data for given Path

Parameters:

pstateVar - PState reference

path - Path definition

See Also:

Partitioners documentation

originPartition

Block.Impl originPartition()

Changes back to starting task for a query topology invocation. Can only be used in query topologies and must be final partitioner used.

See Also:

Query topology documentation

agg

Block.OutImpl agg(Agg agg)

Aggregates input in a batch block to a single value. Capture output with out.

Parameters:

agg - Aggregator to use

See Also:

Aggregator documentation, Batch block documentation

agg

Block.Impl agg(java.lang.String pstateVar,
               Agg agg)

Update PState partition on current task with given aggregator. Can be used in batch blocks or regular blocks.

Parameters:

pstateVar - PState reference

agg - Aggregator to use

See Also:

Aggregator documentation

limitAgg

Block.Impl limitAgg(LimitAgg limitAgg)

Limits incoming data to a fixed amount according to optional sort options. Only usable in batch blocks and operates during agg and post-agg phases.

Parameters:

limitAgg - Definition of aggregator

See Also:

Detailed limitAgg documentation, Batch block documentation

compoundAgg

Block.OutImpl compoundAgg(CompoundAgg compoundAgg)

Aggregates input in a batch block to a single value. Aggregation specified using a data structure template. Capture output with out.

Parameters:

compoundAgg - Data structure template of aggregation

See Also:

Aggregator documentation, Batch block documentation

compoundAgg

Block.Impl compoundAgg(java.lang.String pstateVar,
                       CompoundAgg compoundAgg)

Update PState partition on current task with given aggregation template. Can be used in batch blocks or regular blocks.

Parameters:

pstateVar - PState reference

compoundAgg - Data structure template of aggregation

See Also:

Aggregator documentation

batchBlock

Block.Impl batchBlock(Block batchBlock)

Specifies a batch block. A batch block is partially declarative and supports joins, multiple step aggregation, and more. See the extended documentation for details.

Parameters:

batchBlock - Body of batch block

See Also:

Batch block documentation

freshBatchSource

Block.Impl freshBatchSource()

Declares a new batch source within pre-agg portion of a batch block

See Also:

Batch block documentation

materialize

Block.OutImpl materialize(java.lang.Object... args)

Produces a temporary PState of tuples within a batch block in a microbatch topology. Use subsequent out call to name the PState.

Parameters:

args - Values to capture into tuples

See Also:

Detailed materialize documentation

explodeMaterialized

Block.OutImpl explodeMaterialized(java.lang.String pstateVar)

Emits all tuples across all partitions of a temporary PState created from Block.materialize(java.lang.Object...). Use subsequent out call to assign vars to each element of materialized tuples.

Parameters:

pstateVar - Temporary PState reference

See Also:

Detailed materialize documentation

explodeMicrobatch

Block.OutImpl explodeMicrobatch(java.lang.String microbatchVar)

Emits all data for this microbatch source across all partitions of depot

Parameters:

microbatchVar - Var representing microbatch coming from depot source

See Also:

Microbatch documentation

invokeQuery

Block.OutImpl invokeQuery(java.lang.String queryVarOrTopologyName,
                          java.lang.Object... args)

Invokes a colocated or mirror query topology

Parameters:

queryVarOrTopologyName - Either the name of a query topology in same module or var for another module's query topology assigned when calling clusterQuery

args - Arguments to query topology

See Also:

Query topology documentation

depotPartitionAppend

Block.OutImpl depotPartitionAppend(java.lang.String depotVar,
                                   java.lang.Object arg,
                                   AckLevel ackLevel)

Append data to the partition of the depot represented by current task. Note that this does not use the built-in partitioning scheme of the depot. To append to a mirror depot, must partition to the mirror depot with a partitioner.

Parameters:

depotVar - Depot reference

arg - Value, var, or Expr

ackLevel - AckLevel

See Also:

Depot documentation, Mirror objects documentation

depotPartitionAppend

Block.OutImpl depotPartitionAppend(java.lang.String depotVar,
                                   java.lang.Object arg)

Append data to the partition of the depot represented by current task. Note that this does not use the built-in partitioning scheme of the depot. To append to a mirror depot, must partition to the mirror depot with a partitioner. Defaults to AckLevel.APPEND_ACK.

Parameters:

depotVar - Depot reference

arg - Value, var, or Expr

See Also:

Depot documentation, Mirror objects documentation

subBatch

Block.OutImpl subBatch(SubBatch subBatch)

Use specified SubBatch as a batch source in a batch block. Capture output of SubBatch into vars using subsequent out call.

See Also:

Batch block documentation

macro

Block.Impl macro(Block block)

Inserts all code from given Block into the current callsite. This facility allows dataflow code to be broken up into reusable chunks.

Parameters:

block - Dataflow code

See Also:

Macro documentation

subSource

Block.Impl subSource(java.lang.Object arg,
                     SubSource... subsources)

Conditionally dispatch code based on type of input object

Parameters:

arg - Object to dispatch on

subsources - Any number of declarations specifying a matching type and dataflow code

See Also:

Detailed subSource documentation

cond

Block.Impl cond(Case... cases)

Evaluates condition for each Case in order. Stops checking on first matching condition and evaluates that case's dataflow code. If no condition matches, dataflow stops.

Parameters:

cases - Any number of Case declarations

yieldIfOvertime

Block.Impl yieldIfOvertime()

Yield the task thread if current event is using too much time. Commonly used in loop bodies.

See Also:

Detailed yieldifOvertime documentation

ackReturn

Block.Impl ackReturn(java.lang.Object arg)

Accumulate value according to depot source options to return with depot appends done with AckLevel.ACK

Parameters:

arg - Value to accumulate

See Also:

Depot documentation

execute

void execute()

Execute the given Block on the current thread. Should not be used in modules. Can only execute code that doesn't use parallel capabilities (e.g. partitioners).

Note that since this method compiles the Block from scratch each invocation, it is not representative of the performance of dataflow code in a deployed module.