public class SplitStream<T> extends DataStream<T>
OutputSelector
.
Named outputs can be selected using the SplitStream#select()
function.
To apply a transformation on the whole output simply call
the appropriate method on this stream.Constructor and Description |
---|
SplitStream(SplitStream<T> javaStream) |
Modifier and Type | Method and Description |
---|---|
DataStream<T> |
select(scala.collection.Seq<String> outputNames)
Sets the output names for which the next operator will receive values.
|
addSink, addSink, assignAscendingTimestamps, assignTimestamps, assignTimestampsAndWatermarks, assignTimestampsAndWatermarks, broadcast, clean, coGroup, connect, countWindowAll, countWindowAll, dataType, disableChaining, executionConfig, executionEnvironment, filter, filter, flatMap, flatMap, flatMap, forward, getExecutionConfig, getExecutionEnvironment, getId, getName, getParallelism, getSideOutput, getType, global, iterate, iterate, javaStream, join, keyBy, keyBy, keyBy, map, map, minResources, name, name, parallelism, partitionCustom, partitionCustom, partitionCustom, preferredResources, print, printToErr, process, rebalance, rescale, setBufferTimeout, setMaxParallelism, setParallelism, setUidHash, shuffle, slotSharingGroup, split, split, startNewChain, timeWindowAll, timeWindowAll, transform, uid, union, windowAll, writeAsCsv, writeAsCsv, writeAsCsv, writeAsText, writeAsText, writeToSocket, writeUsingOutputFormat
public SplitStream(SplitStream<T> javaStream)
public DataStream<T> select(scala.collection.Seq<String> outputNames)
outputNames
- (undocumented)Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.