Hi Soheil,
The `getSideOutput()` method is defined on the operator instead of the
datastream.
You can invoke it after any action (e.g., map, window) performed on a
datastream.
Best,
Xingcan
> On Jul 17, 2018, at 3:36 PM, Soheil Pourbafrani wrote:
>
> Hi, according to the documents I tried to
Hi Soheil,
The /getSideOutput/ method is part of /SingleOutputStreamOperator/ which
extends /DataStream///. Try using /SingleOutputStreamOperator/ as the
type for your res variable.
Best,
Dawid
On 17/07/18 09:36, Soheil Pourbafrani wrote:
> Hi, according to the documents I tried to get late da
Hi, according to the documents I tried to get late data using side output.
final OutputTag> lateOutputTag = new
OutputTag>("late-data"){};
DataStream> res = aggregatedTuple
.assignTimestampsAndWatermarks(new Bound())
}).keyBy(1).timeWindow(Time.milliseconds(160))/*.countWi
