Package | Description |
---|---|
org.apache.flink.streaming.api.scala |
Modifier and Type | Method and Description |
---|---|
<T> OutputTag<T> |
OutputTag$.apply(String id,
TypeInformation<T> evidence$2) |
static <T> OutputTag<T> |
OutputTag.apply(String id,
TypeInformation<T> evidence$2) |
Modifier and Type | Method and Description |
---|---|
<X> DataStream<X> |
DataStream.getSideOutput(OutputTag<X> tag,
TypeInformation<X> evidence$1) |
AllWindowedStream<T,W> |
AllWindowedStream.sideOutputLateData(OutputTag<T> outputTag)
Send late arriving data to the side output identified by the given
OutputTag . |
WindowedStream<T,K,W> |
WindowedStream.sideOutputLateData(OutputTag<T> outputTag)
Send late arriving data to the side output identified by the given
OutputTag . |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.