| 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 |