table.addRecord(createKafkaTestRecord(STR0,true,i,500,true)); | table.addRecord(createKafkaTestRecord(STR0,ImmutableList.of(i,1,2d),500L)); | table.addRecord(createKafkaTestRecord(STR0,true,i,500,true)) | table.addRecord(createKafkaTestRecord(STR0,ImmutableList.of(i,1,2d),500L)) | beam | 986c21e2f680cdce60235af0be8df96ce99be1c2 | org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTableTest | | | | | | Uses | False |
table.addRecord(createKafkaTestRecord(STR0,true,i,500,true)); | table.addRecord(createKafkaTestRecord(STR0,ImmutableList.of(i,1,2d),500L)); | table.addRecord(createKafkaTestRecord(STR0,true,i,500,true)) | table.addRecord(createKafkaTestRecord(STR0,ImmutableList.of(i,1,2d),500L)) | beam | 986c21e2f680cdce60235af0be8df96ce99be1c2 | org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTableTest | | | | | | Uses | False |