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