com.rpl.rama

Interface SubSource.MultiOutImpl

All Superinterfaces:

SubSource, SubSource.Impl, SubSource.Out, SubSource.OutImpl

Enclosing interface:

SubSource

public static interface SubSource.MultiOutImpl
extends SubSource.OutImpl

Nested Class Summary

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

SubSource.Impl, SubSource.MultiOutImpl, SubSource.Out, SubSource.OutImpl

Method Summary

Modifier and Type	Method and Description
SubSource.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.SubSource.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, localSelect, localTransform, loop, loopWithVars, macro, materialize, originPartition, pathPartition, select, select, shufflePartition, subBatch, subSource, unify, yieldIfOvertime

Methods inherited from interface com.rpl.rama.SubSource

create

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

out

Method Detail

outStream

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