Thanks Fabian.Here are the final set of questions I have.
1. I see that we cannot use ValueState<T> since this is not a keyed stream. So we need to use Operator state ?
2. I see that the window endtime of both streams is same but not the start time(Is this the expected behavior). So the streams need to be joined over this timestamp.
3. When we connect the two streams and perform coprocess function, how can we perform join of the streams. There are two separate methods for each streams. Which stream state we need to store in the state and Will the coprocess function automatically trigger once the other stream data or should we set some timer to trigger. I am really confused how to implement this. Any example code will of great help. The documentation does not give details about how to perform join. Need help.
CoProcessFunction<ProcessedLogData, String, String>() {
public void processElement1(LogData logData, Context context, Collector<FinalResult> collector) throws Exception {
}
@Override
public void processElement2(AvgStdDev AvgSD, Context context, Collector<FinalResult> collector) throws Exception {
}
})
Locked
