THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||||
---|---|---|---|---|
| ||||
/** This class take response for collecting data to output stream. */ public interface Collector<OUT> { /** * Collect record to output stream. * * @param record to be collected. */ void collect(OUT record); /** * Collect record Overwrite the timestamp of this record and collect it to output stream. * * @param record to be collected. * @param timestamp of the processed data. */ void collectcollectAndOverwriteTimestamp(OUT record, long timestamp); } |
OneInputStreamProcessFunction
...