OriginalCompleteBeforeOriginalCompleteAfterBeforeAfterProjectCommitCompilationUnitLineNosNamesTemplateVariableToCodeBeforeRelevantImportsTemplateVariableToCodeAfterisRelevantisSafe
return KafkaTestRecord.create(key,generateEncodedPayload(i),STR0,timestamp);return KafkaTestRecord.create(key,i.toString().getBytes(UTF_8),STR0,timestamp);KafkaTestRecord.create(key,generateEncodedPayload(i),STR0,timestamp)KafkaTestRecord.create(key,i.toString().getBytes(UTF_8),STR0,timestamp)beamd1217994ff3cf23eaed87ef157d23a1b7abd309borg.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTableTest
_1167
_2117
_1i
_2i
TCIVari
v0STR0
v2timestamp
v3key
TCIVari
v0STR0
v2timestamp
v3key
UsesTrue