|
Change Return Type List<FileStatus> to Map<Path,FileStatus> in method private listEligibleFiles(fileSystem FileSystem) : Map<Path,FileStatus> in class org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction |
From |
To |
|
Change Return Type Tuple3<List<FileInputSplit>,FileInputSplit,S> to List<TimestampedFileInputSplit> in method private getReaderState() : List<TimestampedFileInputSplit> in class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator.SplitReader |
From |
To |
|
Change Return Type void to Tuple2<org.apache.hadoop.fs.Path,String> in method private fillWithData(base String, fileName String, fileIdx int, sampleLine String) : Tuple2<org.apache.hadoop.fs.Path,String> in class org.apache.flink.hdfstests.ContinuousFileProcessingITCase |
From |
To |
|
Rename Attribute collectedContent : Map<Integer,Set<String>> to actualContent : Map<Integer,Set<String>> in class org.apache.flink.test.checkpointing.ContinuousFileProcessingCheckpointITCase.TestingSinkFunction |
From |
To |
|
Rename Attribute readerState : Tuple3<List<FileInputSplit>,FileInputSplit,S> to restoredReaderState : List<TimestampedFileInputSplit> in class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator |
From |
To |
|
Rename Attribute collectedContent : Map<Integer,List<String>> to actualContent : Map<Integer,Set<String>> in class org.apache.flink.hdfstests.ContinuousFileProcessingITCase.TestingSinkFunction |
From |
To |
|
Rename Attribute finalCollectedContent : Map<Integer,List<String>> to actualCollectedContent : Map<Integer,Set<String>> in class org.apache.flink.test.checkpointing.ContinuousFileProcessingCheckpointITCase |
From |
To |
|
Rename Attribute fs : FileSystem to localFs : FileSystem in class org.apache.flink.test.checkpointing.ContinuousFileProcessingCheckpointITCase |
From |
To |
|
Change Variable Type splits : DataStream<FileInputSplit> to splits : DataStream<TimestampedFileInputSplit> in method protected testProgram() : void in class org.apache.flink.hdfstests.ContinuousFileProcessingITCase |
From |
To |
|
Change Variable Type collected : Map<Integer,List<String>> to collected : Map<Integer,Set<String>> in method public postSubmit() : void in class org.apache.flink.test.checkpointing.ContinuousFileProcessingCheckpointITCase |
From |
To |
|
Change Variable Type pendingSplits : List<FileInputSplit> to pendingSplits : List<TimestampedFileInputSplit> in method public restoreState(is FSDataInputStream) : void in class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator |
From |
To |
|
Change Variable Type tester : OneInputStreamOperatorTestHarness<FileInputSplit,String> to tester : OneInputStreamOperatorTestHarness<TimestampedFileInputSplit,String> in method public testFileReadingOperatorWithIngestionTime() : void in class org.apache.flink.hdfstests.ContinuousFileProcessingTest |
From |
To |
|
Change Variable Type reader : ContinuousFileReaderOperator<String,?> to reader : ContinuousFileReaderOperator<String> in method protected testProgram() : void in class org.apache.flink.hdfstests.ContinuousFileProcessingITCase |
From |
To |
|
Change Variable Type snapshot : List<FileInputSplit> to snapshot : List<TimestampedFileInputSplit> in method private getReaderState() : List<TimestampedFileInputSplit> in class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator.SplitReader |
From |
To |
|
Change Variable Type files : List<FileStatus> to files : Map<Path,FileStatus> in method private listEligibleFiles(fileSystem FileSystem) : Map<Path,FileStatus> in class org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction |
From |
To |
|
Change Variable Type reader : ContinuousFileReaderOperator<OUT,?> to reader : ContinuousFileReaderOperator<OUT> in method private createFileInput(inputFormat FileInputFormat<OUT>, typeInfo TypeInformation<OUT>, sourceName String, monitoringMode FileProcessingMode, interval long) : DataStreamSource<OUT> in class org.apache.flink.streaming.api.environment.StreamExecutionEnvironment |
From |
To |
|
Change Variable Type reader : ContinuousFileReaderOperator<String,?> to reader : ContinuousFileReaderOperator<String> in method public testFileReadingOperatorWithEventTime() : void in class org.apache.flink.hdfstests.ContinuousFileProcessingTest |
From |
To |
|
Change Variable Type content : List<String> to content : Set<String> in method public invoke(value String) : void in class org.apache.flink.hdfstests.ContinuousFileProcessingITCase.TestingSinkFunction |
From |
To |
|
Change Variable Type readerState : Tuple3<List<FileInputSplit>,FileInputSplit,S> to readerState : List<TimestampedFileInputSplit> in method public snapshotState(os FSDataOutputStream, checkpointId long, timestamp long) : void in class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator |
From |
To |
|
Change Variable Type tester : OneInputStreamOperatorTestHarness<FileInputSplit,String> to tester : OneInputStreamOperatorTestHarness<TimestampedFileInputSplit,String> in method public testFileReadingOperatorWithEventTime() : void in class org.apache.flink.hdfstests.ContinuousFileProcessingTest |
From |
To |
|
Change Variable Type split : FileInputSplit to split : TimestampedFileInputSplit in method public snapshotState(os FSDataOutputStream, checkpointId long, timestamp long) : void in class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator |
From |
To |
|
Change Variable Type reader : ContinuousFileReaderOperator<String,?> to reader : ContinuousFileReaderOperator<String> in method public testFileReadingOperatorWithIngestionTime() : void in class org.apache.flink.hdfstests.ContinuousFileProcessingTest |
From |
To |
|
Change Attribute Type reader : SplitReader<S,OUT> to reader : SplitReader<OUT> in class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator |
From |
To |
|
Change Attribute Type currentSplit : FileInputSplit to currentSplit : TimestampedFileInputSplit in class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator.SplitReader |
From |
To |
|
Change Attribute Type readerState : Tuple3<List<FileInputSplit>,FileInputSplit,S> to restoredReaderState : List<TimestampedFileInputSplit> in class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator |
From |
To |
|
Change Attribute Type pendingSplits : Queue<FileInputSplit> to pendingSplits : Queue<TimestampedFileInputSplit> in class org.apache.flink.streaming.api.functions.source.ContinuousFileReaderOperator.SplitReader |
From |
To |
|
Change Attribute Type finalCollectedContent : Map<Integer,List<String>> to actualCollectedContent : Map<Integer,Set<String>> in class org.apache.flink.test.checkpointing.ContinuousFileProcessingCheckpointITCase |
From |
To |
|
Change Attribute Type globalModificationTime : Long to globalModificationTime : long in class org.apache.flink.streaming.api.functions.source.ContinuousFileMonitoringFunction |
From |
To |
|
Change Attribute Type collectedContent : Map<Integer,List<String>> to actualContent : Map<Integer,Set<String>> in class org.apache.flink.hdfstests.ContinuousFileProcessingITCase.TestingSinkFunction |
From |
To |