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) | beam | d1217994ff3cf23eaed87ef157d23a1b7abd309b | org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTableTest | | | TCIVar | i |
---|
v0 | STR0 |
---|
v2 | timestamp |
---|
v3 | key |
---|
| | TCIVar | i |
---|
v0 | STR0 |
---|
v2 | timestamp |
---|
v3 | key |
---|
| Uses | True |