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