|
Move And Rename Method private checkFs(outDir File, inprogress int, pending int, completed int, valid int) : void from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkMigrationTest to public checkLocalFs(outDir File, inprogress int, pending int, completed int, valid int) : void from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTestUtils |
From |
To |
|
Move And Rename Method private checkFs(outDir File, inprogress int, pending int, completed int, valid int) : void from class org.apache.flink.streaming.connectors.fs.RollingSinkITCase to public checkLocalFs(outDir File, inprogress int, pending int, completed int, valid int) : void from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTestUtils |
From |
To |
|
Move And Rename Method private checkFs(outDir File, inprogress int, pending int, completed int, valid int) : void from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest to public checkLocalFs(outDir File, inprogress int, pending int, completed int, valid int) : void from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTestUtils |
From |
To |
|
Move Attribute private PENDING_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest to public PENDING_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTestUtils |
From |
To |
|
Move Attribute private IN_PROGRESS_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkMigrationTest to public IN_PROGRESS_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTestUtils |
From |
To |
|
Move Attribute private IN_PROGRESS_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkFaultToleranceITCase to public IN_PROGRESS_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTestUtils |
From |
To |
|
Move Attribute private IN_PROGRESS_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.RollingSinkFaultToleranceITCase to public IN_PROGRESS_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTestUtils |
From |
To |
|
Move Attribute private PART_PREFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkMigrationTest to public PART_PREFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTestUtils |
From |
To |
|
Move Attribute private PENDING_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkMigrationTest to public PENDING_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTestUtils |
From |
To |
|
Move Attribute private VALID_LENGTH_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkMigrationTest to public VALID_LENGTH_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTestUtils |
From |
To |
|
Move Attribute private PART_PREFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest to public PART_PREFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTestUtils |
From |
To |
|
Move Attribute private PENDING_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkFaultToleranceITCase to public PENDING_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTestUtils |
From |
To |
|
Move Attribute private IN_PROGRESS_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest to public IN_PROGRESS_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTestUtils |
From |
To |
|
Move Attribute private VALID_LENGTH_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTest to public VALID_LENGTH_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTestUtils |
From |
To |
|
Move Attribute private PENDING_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.RollingSinkFaultToleranceITCase to public PENDING_SUFFIX : String from class org.apache.flink.streaming.connectors.fs.bucketing.BucketingSinkTestUtils |
From |
To |