|
Change Return Type Writer<T> to StringWriter<T> in method public duplicate() : StringWriter<T> in class org.apache.flink.streaming.connectors.fs.StringWriter |
From |
To |
|
Change Return Type Writer<T> to StreamWriterWithConfigCheck<T> in method public duplicate() : StreamWriterWithConfigCheck<T> in class org.apache.flink.streaming.connectors.fs.RollingSinkITCase.StreamWriterWithConfigCheck |
From |
To |
|
Change Return Type Writer<Tuple2<K,V>> to SequenceFileWriter<K,V> in method public duplicate() : SequenceFileWriter<K,V> in class org.apache.flink.streaming.connectors.fs.SequenceFileWriter |
From |
To |
|
Change Return Type Writer<Tuple2<K,V>> to StreamWriterWithConfigCheck<K,V> in method public duplicate() : StreamWriterWithConfigCheck<K,V> in class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest.StreamWriterWithConfigCheck |
From |
To |
|
Change Return Type Writer<Tuple2<K,V>> to AvroKeyValueSinkWriter<K,V> in method public duplicate() : AvroKeyValueSinkWriter<K,V> in class org.apache.flink.streaming.connectors.fs.AvroKeyValueSinkWriter |
From |
To |
|
Change Return Type int to boolean in method public isSyncOnFlush() : boolean in class org.apache.flink.streaming.connectors.fs.StreamWriterBase |
From |
To |