All Superinterfaces:

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

Enclosing interface: Block

public static interface Block.MultiOutImpl
extends [Block.OutImpl](/content/javadoc/com/rpl/rama/Block.OutImpl.html "interface in com.rpl.rama"/index.html)

Nested Class Summary

Nested classes/interfaces inherited from interface com.rpl.rama. [Block](/content/javadoc/com/rpl/rama/Block.html "interface in com.rpl.rama"/index.html)

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

Method Summary

All Methods Instance Methods Abstract Methods

Modifier and Type

Method

Description

Block.MultiOutImpl

outStream(String streamName, String anchor, String... vars)

Capture output of a non-default stream of previous node into vars.

Methods inherited from interface com.rpl.rama. [Block.Impl](/content/javadoc/com/rpl/rama/Block.Impl.html "interface in com.rpl.rama"/index.html)

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.Out](/content/javadoc/com/rpl/rama/Block.Out.html "interface in com.rpl.rama"/index.html)

out

Method Details

outStream

[Block.MultiOutImpl](/content/javadoc/com/rpl/rama/Block.MultiOutImpl.html "interface in com.rpl.rama"/index.html) outStream( String streamName,
String anchor,
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