com.rpl.rama

Interface Case.MultiOutImpl

All Superinterfaces:

Case, Case.Impl, Case.Out, Case.OutImpl

Enclosing interface:

Case

public static interface Case.MultiOutImpl
extends Case.OutImpl

Nested Class Summary

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

Case.Impl, Case.MultiOutImpl, Case.Out, Case.OutImpl

Method Summary

Modifier and Type	Method and Description
Case.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.Case.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, explodeMaterialized, explodeMicrobatch, freshBatchSource, globalPartition, globalPartition, groupBy, groupBy, groupBy, groupBy, groupBy, groupBy, hashPartition, hashPartition, hook, ifTrue, ifTrue, invokeQuery, keepTrue, limitAgg, localClear, localSelect, localTransform, loop, loopWithVars, macro, materialize, originPartition, pathPartition, select, shufflePartition, subBatch, subSource, unify, yieldIfOvertime

Methods inherited from interface com.rpl.rama.Case

create

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

out

Method Detail

outStream

Case.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