|
Change Parameter Type state : BucketState to state : BucketState<BucketID> in method package serializeV1(state BucketState<BucketID>, out DataOutputView) : void in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketStateSerializer |
From |
To |
|
Change Parameter Type writer : Encoder<Tuple2<String,Integer>> to partFileWriterFactory : PartFileWriter.PartFileFactory<Tuple2<String,Integer>,String> in method public getNewBucket(fsWriter RecoverableWriter, subtaskIndex int, bucketId String, bucketPath Path, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<Tuple2<String,Integer>,String>) : Bucket<Tuple2<String,Integer>,String> in class org.apache.flink.streaming.api.functions.sink.filesystem.LocalStreamingFileSinkTest.TestBucketFactory |
From |
To |
|
Change Parameter Type writer : Encoder<IN> to partFileWriterFactory : PartFileWriter.PartFileFactory<IN,BucketID> in method public getNewBucket(fsWriter RecoverableWriter, subtaskIndex int, bucketId BucketID, bucketPath Path, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<IN,BucketID>) : Bucket<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.DefaultBucketFactory |
From |
To |
|
Change Parameter Type context : Context to context : Bucketer.Context in method public getBucketId(element T, context Bucketer.Context) : String in class org.apache.flink.streaming.api.functions.sink.filesystem.bucketers.BasePathBucketer |
From |
To |
|
Change Parameter Type element : T to element : IN in method public getBucketId(element IN, context Bucketer.Context) : String in class org.apache.flink.streaming.api.functions.sink.filesystem.bucketers.DateTimeBucketer |
From |
To |
|
Change Parameter Type bucketId : String to bucketId : BucketID in method public getNewBucket(fsWriter RecoverableWriter, subtaskIndex int, bucketId BucketID, bucketPath Path, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<IN,BucketID>) : Bucket<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketFactory |
From |
To |
|
Change Parameter Type bucketId : String to bucketId : BucketID in method public getNewBucket(fsWriter RecoverableWriter, subtaskIndex int, bucketId BucketID, bucketPath Path, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<IN,BucketID>) : Bucket<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.DefaultBucketFactory |
From |
To |
|
Change Parameter Type writer : Encoder<Tuple2<String,Integer>> to partFileWriterFactory : PartFileWriter.PartFileFactory<Tuple2<String,Integer>,String> in method public restoreBucket(fsWriter RecoverableWriter, subtaskIndex int, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<Tuple2<String,Integer>,String>, bucketState BucketState<String>) : Bucket<Tuple2<String,Integer>,String> in class org.apache.flink.streaming.api.functions.sink.filesystem.LocalStreamingFileSinkTest.TestBucketFactory |
From |
To |
|
Change Parameter Type bucket : Bucket<IN> to bucket : Bucket<IN,BucketID> in method package merge(bucket Bucket<IN,BucketID>) : void in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Parameter Type writer : Encoder<IN> to partFileFactory : PartFileWriter.PartFileFactory<IN,BucketID> in method public Bucket(fsWriter RecoverableWriter, subtaskIndex int, bucketId BucketID, bucketPath Path, initialPartCounter long, partFileFactory PartFileWriter.PartFileFactory<IN,BucketID>) in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Parameter Type writer : Encoder<IN> to partFileFactory : PartFileWriter.PartFileFactory<IN,BucketID> in method public Bucket(fsWriter RecoverableWriter, subtaskIndex int, initialPartCounter long, partFileFactory PartFileWriter.PartFileFactory<IN,BucketID>, bucketState BucketState<BucketID>) in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Parameter Type bucketState : BucketState to bucketState : BucketState<String> in method public restoreBucket(fsWriter RecoverableWriter, subtaskIndex int, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<Tuple2<String,Integer>,String>, bucketState BucketState<String>) : Bucket<Tuple2<String,Integer>,String> in class org.apache.flink.streaming.api.functions.sink.filesystem.LocalStreamingFileSinkTest.TestBucketFactory |
From |
To |
|
Change Parameter Type bucketState : BucketState to bucketState : BucketState<BucketID> in method public restoreBucket(fsWriter RecoverableWriter, subtaskIndex int, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<IN,BucketID>, bucketState BucketState<BucketID>) : Bucket<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.DefaultBucketFactory |
From |
To |
|
Change Parameter Type bucketId : String to bucketId : BucketID in method public BucketState(bucketId BucketID, bucketPath Path, creationTime long, inProgress RecoverableWriter.ResumeRecoverable, pendingPerCheckpoint Map<Long,List<RecoverableWriter.CommitRecoverable>>) in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketState |
From |
To |
|
Change Parameter Type bucketId : String to bucketId : BucketID in method public Bucket(fsWriter RecoverableWriter, subtaskIndex int, bucketId BucketID, bucketPath Path, initialPartCounter long, partFileFactory PartFileWriter.PartFileFactory<IN,BucketID>) in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Parameter Type context : Context to context : Bucketer.Context in method public getBucketId(element IN, context Bucketer.Context) : String in class org.apache.flink.streaming.api.functions.sink.filesystem.bucketers.DateTimeBucketer |
From |
To |
|
Change Parameter Type state : BucketState to state : BucketState<BucketID> in method public serialize(state BucketState<BucketID>) : byte[] in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketStateSerializer |
From |
To |
|
Change Parameter Type writer : Encoder<IN> to partFileWriterFactory : PartFileWriter.PartFileFactory<IN,BucketID> in method public restoreBucket(fsWriter RecoverableWriter, subtaskIndex int, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<IN,BucketID>, bucketState BucketState<BucketID>) : Bucket<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.DefaultBucketFactory |
From |
To |
|
Change Parameter Type bucketstate : BucketState to bucketState : BucketState<BucketID> in method public Bucket(fsWriter RecoverableWriter, subtaskIndex int, initialPartCounter long, partFileFactory PartFileWriter.PartFileFactory<IN,BucketID>, bucketState BucketState<BucketID>) in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Move Method private checkLocalFs(outDir File, expectedInProgress int, expectedCompleted int) : void from class org.apache.flink.streaming.api.functions.sink.filesystem.LocalStreamingFileSinkTest to package checkLocalFs(outDir File, expectedInProgress int, expectedCompleted int) : void from class org.apache.flink.streaming.api.functions.sink.filesystem.TestUtils |
From |
To |
|
Move Method private createRescalingTestSink(outDir File, totalParallelism int, taskIdx int, inactivityInterval long, partMaxSize long) : OneInputStreamOperatorTestHarness<Tuple2<String,Integer>,Object> from class org.apache.flink.streaming.api.functions.sink.filesystem.LocalStreamingFileSinkTest to package createRescalingTestSink(outDir File, totalParallelism int, taskIdx int, inactivityInterval long, partMaxSize long) : OneInputStreamOperatorTestHarness<Tuple2<String,Integer>,Object> from class org.apache.flink.streaming.api.functions.sink.filesystem.TestUtils |
From |
To |
|
Move Method private getFileContentByPath(directory File) : Map<File,String> from class org.apache.flink.streaming.api.functions.sink.filesystem.LocalStreamingFileSinkTest to package getFileContentByPath(directory File) : Map<File,String> from class org.apache.flink.streaming.api.functions.sink.filesystem.TestUtils |
From |
To |
|
Move Method private createCustomRescalingTestSink(outDir File, totalParallelism int, taskIdx int, inactivityInterval long, partMaxSize long, factory BucketFactory<Tuple2<String,Integer>>, writer Encoder<Tuple2<String,Integer>>) : OneInputStreamOperatorTestHarness<Tuple2<String,Integer>,Object> from class org.apache.flink.streaming.api.functions.sink.filesystem.LocalStreamingFileSinkTest to package createCustomRescalingTestSink(outDir File, totalParallelism int, taskIdx int, bucketCheckInterval long, bucketer Bucketer<Tuple2<String,Integer>,String>, writer Encoder<Tuple2<String,Integer>>, rollingPolicy RollingPolicy<String>, bucketFactory BucketFactory<Tuple2<String,Integer>,String>) : OneInputStreamOperatorTestHarness<Tuple2<String,Integer>,Object> from class org.apache.flink.streaming.api.functions.sink.filesystem.TestUtils |
From |
To |
|
Move Method private updateMaxPartCounter(candidate long) : void from class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink to private updateMaxPartCounter(candidate long) : void from class org.apache.flink.streaming.api.functions.sink.filesystem.Buckets |
From |
To |
|
Change Return Type Bucket<IN> to Bucket<IN,BucketID> in method public restoreBucket(fsWriter RecoverableWriter, subtaskIndex int, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<IN,BucketID>, bucketState BucketState<BucketID>) : Bucket<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.DefaultBucketFactory |
From |
To |
|
Change Return Type String to BucketID in method public getBucketId() : BucketID in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Return Type String to BucketID in method public getBucketId() : BucketID in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketState |
From |
To |
|
Change Return Type BucketState to BucketState<BucketID> in method package deserializeV1(in DataInputView) : BucketState<BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketStateSerializer |
From |
To |
|
Change Return Type Bucket<IN> to Bucket<IN,BucketID> in method public getNewBucket(fsWriter RecoverableWriter, subtaskIndex int, bucketId BucketID, bucketPath Path, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<IN,BucketID>) : Bucket<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.DefaultBucketFactory |
From |
To |
|
Change Return Type BucketState to BucketState<BucketID> in method public deserialize(version int, serialized byte[]) : BucketState<BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketStateSerializer |
From |
To |
|
Change Return Type BucketState to BucketState<BucketID> in method public onCheckpoint(checkpointId long) : BucketState<BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Return Type PolicyBuilder to DefaultRollingPolicy.PolicyBuilder in method public withRolloverInterval(interval long) : DefaultRollingPolicy.PolicyBuilder in class org.apache.flink.streaming.api.functions.sink.filesystem.rolling.policies.DefaultRollingPolicy.PolicyBuilder |
From |
To |
|
Change Return Type PartFileInfo to PartFileInfo<BucketID> in method public getInProgressPartInfo() : PartFileInfo<BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Change Return Type String to BucketID in method public getBucketId() : BucketID in class org.apache.flink.streaming.api.functions.sink.filesystem.PartFileInfo |
From |
To |
|
Change Return Type Bucket<IN> to Bucket<IN,BucketID> in method public getNewBucket(fsWriter RecoverableWriter, subtaskIndex int, bucketId BucketID, bucketPath Path, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<IN,BucketID>) : Bucket<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketFactory |
From |
To |
|
Change Return Type Bucket<Tuple2<String,Integer>> to Bucket<Tuple2<String,Integer>,String> in method public getNewBucket(fsWriter RecoverableWriter, subtaskIndex int, bucketId String, bucketPath Path, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<Tuple2<String,Integer>,String>) : Bucket<Tuple2<String,Integer>,String> in class org.apache.flink.streaming.api.functions.sink.filesystem.LocalStreamingFileSinkTest.TestBucketFactory |
From |
To |
|
Change Return Type PolicyBuilder to DefaultRollingPolicy.PolicyBuilder in method public withMaxPartSize(size long) : DefaultRollingPolicy.PolicyBuilder in class org.apache.flink.streaming.api.functions.sink.filesystem.rolling.policies.DefaultRollingPolicy.PolicyBuilder |
From |
To |
|
Change Return Type Bucket<IN> to Bucket<IN,BucketID> in method public restoreBucket(fsWriter RecoverableWriter, subtaskIndex int, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<IN,BucketID>, bucketState BucketState<BucketID>) : Bucket<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketFactory |
From |
To |
|
Change Return Type PolicyBuilder to DefaultRollingPolicy.PolicyBuilder in method public withInactivityInterval(interval long) : DefaultRollingPolicy.PolicyBuilder in class org.apache.flink.streaming.api.functions.sink.filesystem.rolling.policies.DefaultRollingPolicy.PolicyBuilder |
From |
To |
|
Change Return Type Bucket<Tuple2<String,Integer>> to Bucket<Tuple2<String,Integer>,String> in method public restoreBucket(fsWriter RecoverableWriter, subtaskIndex int, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<Tuple2<String,Integer>,String>, bucketState BucketState<String>) : Bucket<Tuple2<String,Integer>,String> in class org.apache.flink.streaming.api.functions.sink.filesystem.LocalStreamingFileSinkTest.TestBucketFactory |
From |
To |
|
Move Attribute private encoder : Encoder<IN> from class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket to private encoder : Encoder<IN> from class org.apache.flink.streaming.api.functions.sink.filesystem.RowWisePartWriter |
From |
To |
|
Move Attribute private maxPartCounterUsed : long from class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink to private maxPartCounterUsed : long from class org.apache.flink.streaming.api.functions.sink.filesystem.Buckets |
From |
To |
|
Move Attribute private encoder : Encoder<IN> from class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket to private encoder : Encoder<IN> from class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.RowFormatBuilder |
From |
To |
|
Move Attribute private encoder : Encoder<IN> from class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket to private encoder : Encoder<IN> from class org.apache.flink.streaming.api.functions.sink.filesystem.RowWisePartWriter.Factory |
From |
To |
|
Move Attribute private basePath : Path from class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink to private basePath : Path from class org.apache.flink.streaming.api.functions.sink.filesystem.Buckets |
From |
To |
|
Move Attribute private initMaxPartCounter : long from class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink to private initMaxPartCounter : long from class org.apache.flink.streaming.api.functions.sink.filesystem.Buckets |
From |
To |
|
Move Attribute private LOG : Logger from class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink to private LOG : Logger from class org.apache.flink.streaming.api.functions.sink.filesystem.Buckets |
From |
To |
|
Move Attribute private encoder : Encoder<IN> from class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink to private encoder : Encoder<IN> from class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink.RowFormatBuilder |
From |
To |
|
Move Attribute private fileSystemWriter : RecoverableWriter from class org.apache.flink.streaming.api.functions.sink.filesystem.StreamingFileSink to private fileSystemWriter : RecoverableWriter from class org.apache.flink.streaming.api.functions.sink.filesystem.Buckets |
From |
To |
|
Change Variable Type recoveredState : BucketState to recoveredState : BucketState<String> in method public testSerializationFull() : void in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketStateSerializerTest |
From |
To |
|
Change Variable Type recoveredState : BucketState to recoveredState : BucketState<String> in method public testSerializationEmpty() : void in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketStateSerializerTest |
From |
To |
|
Change Variable Type resumables : List<CommitRecoverable> to resumables : List<RecoverableWriter.CommitRecoverable> in method package serializeV1(state BucketState<BucketID>, out DataOutputView) : void in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketStateSerializer |
From |
To |
|
Change Variable Type resumable : CommitRecoverable to resumable : RecoverableWriter.CommitRecoverable in method package serializeV1(state BucketState<BucketID>, out DataOutputView) : void in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketStateSerializer |
From |
To |
|
Change Variable Type resumablesForCheckpoint : Entry<Long,List<CommitRecoverable>> to resumablesForCheckpoint : Entry<Long,List<RecoverableWriter.CommitRecoverable>> in method package serializeV1(state BucketState<BucketID>, out DataOutputView) : void in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketStateSerializer |
From |
To |
|
Change Variable Type recoveredState : BucketState to recoveredState : BucketState<String> in method public testSerializationOnlyInProgress() : void in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketStateSerializerTest |
From |
To |
|
Change Variable Type resumables : ArrayList<RecoverableWriter.CommitRecoverable> to resumables : List<RecoverableWriter.CommitRecoverable> in method package deserializeV1(in DataInputView) : BucketState<BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketStateSerializer |
From |
To |
|
Change Variable Type recoveredState : BucketState to recoveredState : BucketState<String> in method public testSerializationNullInProgress() : void in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketStateSerializerTest |
From |
To |
|
Change Variable Type pendingCommitters : Map<Long,List<CommitRecoverable>> to pendingCommitters : Map<Long,List<RecoverableWriter.CommitRecoverable>> in method package serializeV1(state BucketState<BucketID>, out DataOutputView) : void in class org.apache.flink.streaming.api.functions.sink.filesystem.BucketStateSerializer |
From |
To |
|
Rename Parameter writer : Encoder<Tuple2<String,Integer>> to partFileWriterFactory : PartFileWriter.PartFileFactory<Tuple2<String,Integer>,String> in method public restoreBucket(fsWriter RecoverableWriter, subtaskIndex int, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<Tuple2<String,Integer>,String>, bucketState BucketState<String>) : Bucket<Tuple2<String,Integer>,String> in class org.apache.flink.streaming.api.functions.sink.filesystem.LocalStreamingFileSinkTest.TestBucketFactory |
From |
To |
|
Rename Parameter writer : Encoder<IN> to partFileWriterFactory : PartFileWriter.PartFileFactory<IN,BucketID> in method public restoreBucket(fsWriter RecoverableWriter, subtaskIndex int, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<IN,BucketID>, bucketState BucketState<BucketID>) : Bucket<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.DefaultBucketFactory |
From |
To |
|
Rename Parameter bucketstate : BucketState to bucketState : BucketState<BucketID> in method public Bucket(fsWriter RecoverableWriter, subtaskIndex int, initialPartCounter long, partFileFactory PartFileWriter.PartFileFactory<IN,BucketID>, bucketState BucketState<BucketID>) in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Rename Parameter writer : Encoder<Tuple2<String,Integer>> to partFileWriterFactory : PartFileWriter.PartFileFactory<Tuple2<String,Integer>,String> in method public getNewBucket(fsWriter RecoverableWriter, subtaskIndex int, bucketId String, bucketPath Path, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<Tuple2<String,Integer>,String>) : Bucket<Tuple2<String,Integer>,String> in class org.apache.flink.streaming.api.functions.sink.filesystem.LocalStreamingFileSinkTest.TestBucketFactory |
From |
To |
|
Rename Parameter writer : Encoder<IN> to partFileFactory : PartFileWriter.PartFileFactory<IN,BucketID> in method public Bucket(fsWriter RecoverableWriter, subtaskIndex int, bucketId BucketID, bucketPath Path, initialPartCounter long, partFileFactory PartFileWriter.PartFileFactory<IN,BucketID>) in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Rename Parameter inactivityInterval : long to bucketCheckInterval : long 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<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 |
|
Rename Parameter writer : Encoder<IN> to partFileWriterFactory : PartFileWriter.PartFileFactory<IN,BucketID> in method public getNewBucket(fsWriter RecoverableWriter, subtaskIndex int, bucketId BucketID, bucketPath Path, initialPartCounter long, partFileWriterFactory PartFileWriter.PartFileFactory<IN,BucketID>) : Bucket<IN,BucketID> in class org.apache.flink.streaming.api.functions.sink.filesystem.DefaultBucketFactory |
From |
To |
|
Rename Parameter writer : Encoder<IN> to partFileFactory : PartFileWriter.PartFileFactory<IN,BucketID> in method public Bucket(fsWriter RecoverableWriter, subtaskIndex int, initialPartCounter long, partFileFactory PartFileWriter.PartFileFactory<IN,BucketID>, bucketState BucketState<BucketID>) in class org.apache.flink.streaming.api.functions.sink.filesystem.Bucket |
From |
To |
|
Rename Parameter elementTimestamp : Long to element : Long in method package update(element Long, watermark long, processingTime long) : void in class org.apache.flink.streaming.api.functions.sink.filesystem.Buckets.BucketerContext |
From |
To |