com.rpl.rama

Interface Block.MultiOutImpl

All Superinterfaces:

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

Enclosing interface:

Block

public static interface Block.MultiOutImpl
extends Block.OutImpl

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.MultiOutImpl	outStream(java.lang.String streamName, java.lang.String anchor, java.lang.String... vars) Capture output of a non-default stream of previous node into vars.

Methods inherited from interface com.rpl.rama.Block.Impl

ackReturn, agg, agg, allPartition, allPartition, anchor, atomicBlock, batchBlock, branch, compoundAgg, compoundAgg, cond, continueLoop, 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, execute, 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

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

Methods inherited from interface com.rpl.rama.Block.Out

out

Method Detail

outStream

Block.MultiOutImpl outStream(java.lang.String streamName,
                             java.lang.String anchor,
                             java.lang.String... vars)

Capture output of a non-default stream of previous node into vars. Number of vars captured must match output arity of that stream.

Parameters:

streamName - Name of stream to capture from previous operation

anchor - Label for this output node

vars - Vars to bind to output

See Also:

Dataflow documentation