OriginalCompleteBefore

OriginalCompleteAfter

Before

After

Project

Commit

CompilationUnit

LineNos

Names

TemplateVariableToCodeBefore

RelevantImports

TemplateVariableToCodeAfter

isRelevant

isSafe

kafkaParams = ImmutableMap.of(STR0,EMBEDDED_KAFKA_CLUSTER.getBrokerList(),STR1,STR2)

consumerProps = ImmutableMap.<String,Object>of(STR1,STR3)

ImmutableMap.of(STR0,EMBEDDED_KAFKA_CLUSTER.getBrokerList(),STR1,STR2)

ImmutableMap.<String,Object>of(STR1,STR3)

beam

b72e7e34f70527e4ee575aaf0bc8c4c31ed31b0a

org.apache.beam.runners.spark.translation.streaming.ResumeFromCheckpointStreamingTest

_1	144
_2	145

_1	kafkaParams
_2	consumerProps

v0	STR1

v0	STR1

AssignedTo

False

Map<String,String> kafkaParams=ImmutableMap.of(STR0,EMBEDDED_KAFKA_CLUSTER.getBrokerList(),STR1,STR2);

Map<String,Object> consumerProps=ImmutableMap.<String,Object>of(STR1,STR3);