expectedOutput.add(new StreamRecord<>(STR0,initialTime)); | expectedOutput.add(new StreamRecord<>(STR1,initialTime)); | new StreamRecord<>(STR0,initialTime) | new StreamRecord<>(STR1,initialTime) | flink | f76551180b6b6f4f72b9faf52f6f558cd2ef4955 | org.apache.flink.streaming.runtime.tasks.MultipleInputStreamTaskTest | | _1 | initialTime |
---|
_2 | initialTime |
---|
| | - org.apache.flink.streaming.runtime.streamrecord.StreamRecord
| | Uses | False |