Aljoscha Krettek created FLINK-3714:
---------------------------------------
Summary: Add Support for "Allowed Lateness"
Key: FLINK-3714
URL: https://issues.apache.org/jira/browse/FLINK-3714
Project: Flink
Issue Type: Sub-task
Components: Streaming
Reporter: Aljoscha Krettek
As mentioned in
https://docs.google.com/document/d/1Xp-YBf87vLTduYSivgqWVEMjYUmkA-hyb4muX3KRl08/edit#
we should add support for an allowed lateness setting.
This includes several things:
- API for setting allowed lateness
- Dropping of late elements
- Garbage collection of event-time windows
Lateness only makes sense for event-time windows. So we also have to figure out
what the API for this should look like and especially what should happen with
the "stream-time characteristic" switch. For example in this:
{code}
env.setStreamTimeCharacteristic(ProcessingTime)
...
DataStream in = ...
result = in
.keyBy()
.timeWindow()
.allowedLateness()
.apply()
{code}
I think the setting can be silently ignored when doing processing-time
windowing.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
