|
Change Parameter Type policy : RollingPolicy<BucketID> to policy : RollingPolicy<IN,BucketID> in method public withRollingPolicy(policy RollingPolicy<IN,BucketID>) : StreamingFileSink.RowFormatBuilder<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.RowFormatBuilder |
From |
To |
|
Change Parameter Type rollingPolicy : RollingPolicy<String> to rollingPolicy : RollingPolicy<Tuple2<String,Integer>,String> in method package createCustomRescalingTestSink(outDir File, totalParallelism int, taskIdx int, bucketCheckInterval long, bucketer Bucketer<Tuple2<String,Integer>,String>, writer Encoder<Tuple2<String,Integer>>, rollingPolicy RollingPolicy<Tuple2<String,Integer>,String>, bucketFactory BucketFactory<Tuple2<String,Integer>,String>) : OneInputStreamOperatorTestHarness<Tuple2<String,Integer>,Object> in class org.apache.flink.streaming.api.functions.sink.filesystem.TestUtils |
From |
To |
|
Change Parameter Type rollingPolicy : RollingPolicy<BucketID> to rollingPolicy : RollingPolicy<IN,BucketID> in method package Buckets(basePath Path, bucketer Bucketer<IN,BucketID>, bucketFactory BucketFactory<IN,BucketID>, partFileWriterFactory PartFileWriter.PartFileFactory<IN,BucketID>, rollingPolicy RollingPolicy<IN,BucketID>, subtaskIndex int) in class org.apache.flink.streaming.api.functions.sink.filesystem.Buckets |
From |
To |
|
Change Parameter Type policy : RollingPolicy<ID> to policy : RollingPolicy<IN,ID> in method public withBucketerAndPolicy(bucketer Bucketer<IN,ID>, policy RollingPolicy<IN,ID>) : StreamingFileSink.RowFormatBuilder<IN,ID> in class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.RowFormatBuilder |
From |
To |
|
Change Variable Type rollingPolicy : RollingPolicy<String> to rollingPolicy : RollingPolicy<Tuple2<String,Integer>,String> in method package createRescalingTestSink(outDir File, totalParallelism int, taskIdx int, inactivityInterval long, partMaxSize long) : OneInputStreamOperatorTestHarness<Tuple2<String,Integer>,Object> in class org.apache.flink.streaming.api.functions.sink.filesystem.TestUtils |
From |
To |
|
Change Variable Type rollingPolicy : RollingPolicy<String> to rollingPolicy : RollingPolicy<Tuple2<String,Integer>,String> in method public testDefaultRollingPolicy() : void in class org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicyTest |
From |
To |
|
Change Variable Type rollingPolicy : RollingPolicy<String> to rollingPolicy : RollingPolicy<Tuple2<String,Integer>,String> in method public testCustomRollingPolicy() : void in class org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicyTest |
From |
To |
|
Change Variable Type rollingPolicy : RollingPolicy<String> to rollingPolicy : RollingPolicy<Tuple2<String,Integer>,String> in method public testMaxCounterUponRecovery() : void in class org.apache.flink.streaming.api.functions.sink.filesystem.LocalStreamingFileSinkTest |
From |
To |
|
Change Variable Type rollingPolicy : RollingPolicy<String> to rollingPolicy : RollingPolicy<Tuple2<String,Integer>,String> in method public testRollOnCheckpointPolicy() : void in class org.apache.flink.streaming.api.functions.sink.filesystem.RollingPolicyTest |
From |
To |