dos-group / flink-realtime-streaming

Mirror of Apache Flink
Apache License 2.0
3 stars 4 forks source link

Latency constraint fluent API with two edges #19

Open derSascha opened 9 years ago

derSascha commented 9 years ago

The API supports our twitter-sentiment-job only with a workaround mapper.

The following does not work:

DataStream stream1 = source
    .beginLatencyConstraint("one", 123)
    ....
    .finishLatencyConstraint();

DataStream stream2 = source
    .beginLatencyConstraint("two", 123)
    ....
    .finishLatencyConstraint();

In words: We have two constraints on two different paths from our source.

TODO: