OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
originalPartitions = Arrays.asList(new KafkaTopicPartition(testTopic,7),new KafkaTopicPartition(testTopic,13),new KafkaTopicPartition(testTopic,21))originalPartitions = new HashMap<>()Arrays.asList(new KafkaTopicPartition(testTopic,7),new KafkaTopicPartition(testTopic,13),new KafkaTopicPartition(testTopic,21))new HashMap<>()flinked68fedbe90db03823d75a020510ad3c344fa73eorg.apache.flink.streaming.connectors.kafka.internals.AbstractFetcherTimestampsTest
_1122
_2121
_1originalPartitions
_2originalPartitions
xyzArrays.asList(new KafkaTopicPartition(testTopic,7),new KafkaTopicPartition(testTopic,13),new KafkaTopicPartition(testTopic,21))
  • java.util.HashMap
  • java.util.Arrays
xyznew HashMap<>()
AssignedToFalse
originalPartitions = Arrays.asList(new KafkaTopicPartition(testTopic,7),new KafkaTopicPartition(testTopic,13),new KafkaTopicPartition(testTopic,21))originalPartitions = new HashMap<>()Arrays.asList(new KafkaTopicPartition(testTopic,7),new KafkaTopicPartition(testTopic,13),new KafkaTopicPartition(testTopic,21))new HashMap<>()flinked68fedbe90db03823d75a020510ad3c344fa73eorg.apache.flink.streaming.connectors.kafka.internals.AbstractFetcherTimestampsTest
_147
_247
_1originalPartitions
_2originalPartitions
xyzArrays.asList(new KafkaTopicPartition(testTopic,7),new KafkaTopicPartition(testTopic,13),new KafkaTopicPartition(testTopic,21))
  • java.util.HashMap
  • java.util.Arrays
xyznew HashMap<>()
AssignedToFalse