T- The type of the elements in this stream.
@Public public class SideOutputDataStream<T> extends DataStream<T>
DataStreamthat contains elements that are emitted from upstream into a side output with some tag.
|Constructor and Description|
Creates a new
|Modifier and Type||Method and Description|
Caches the intermediate result of the transformation.
addSink, assignTimestampsAndWatermarks, assignTimestampsAndWatermarks, assignTimestampsAndWatermarks, broadcast, broadcast, clean, coGroup, collectAsync, collectAsync, connect, connect, countWindowAll, countWindowAll, doTransform, executeAndCollect, executeAndCollect, executeAndCollect, executeAndCollect, filter, flatMap, flatMap, forward, getExecutionConfig, getExecutionEnvironment, getId, getMinResources, getParallelism, getPreferredResources, getTransformation, getType, global, iterate, iterate, join, keyBy, keyBy, keyBy, keyBy, map, map, partitionCustom, partitionCustom, partitionCustom, print, print, printToErr, printToErr, process, process, project, rebalance, rescale, setConnectionType, shuffle, sinkTo, sinkTo, sinkTo, sinkTo, timeWindowAll, timeWindowAll, transform, transform, union, windowAll, writeAsCsv, writeAsCsv, writeAsCsv, writeAsText, writeAsText, writeToSocket, writeUsingOutputFormat
public SideOutputDataStream(StreamExecutionEnvironment environment, SideOutputTransformation<T> transformation)
SideOutputDataStreamin the given execution environment.
environment- The StreamExecutionEnvironment
transformation- The SideOutputTransformation
@PublicEvolving public CachedDataStream<T> cache()
CachedDataStream.invalidate()called or the
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.