table.addRecord(createKafkaTestRecord(STR0 + i,ImmutableList.of(i,1,2d),1000L)); | table.addRecord(createKafkaTestRecord(STR0 + i,i,1000L)); | ImmutableList.of(i,1,2d) | i | beam | 56802e30d18a98cca37ee6d9bdb8a522c2022379 | org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTableTest | | | | - org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableList
| | Uses | True |
table.addRecord(createKafkaTestRecord(STR0,ImmutableList.of(i,1,2d),500L)); | table.addRecord(createKafkaTestRecord(STR0,i,500L)); | ImmutableList.of(i,1,2d) | i | beam | 56802e30d18a98cca37ee6d9bdb8a522c2022379 | org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTableTest | | | | - org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableList
| | Uses | True |
table.addRecord(createKafkaTestRecord(STR0,ImmutableList.of(i,1,2d),500L)); | table.addRecord(createKafkaTestRecord(STR0,i,500L)); | ImmutableList.of(i,1,2d) | i | beam | 56802e30d18a98cca37ee6d9bdb8a522c2022379 | org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTableTest | | | | - org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableList
| | Uses | True |
table.addRecord(createKafkaTestRecord(STR0,ImmutableList.of(i,1,2d),500L * i)); | table.addRecord(createKafkaTestRecord(STR0,i,500L * i)); | ImmutableList.of(i,1,2d) | i | beam | 56802e30d18a98cca37ee6d9bdb8a522c2022379 | org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTableTest | | | | - org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableList
| | Uses | True |
table.addRecord(createKafkaTestRecord(STR0,ImmutableList.of(i,1,2d),1000L * i)); | table.addRecord(createKafkaTestRecord(STR0,i,1000L * i)); | ImmutableList.of(i,1,2d) | i | beam | 56802e30d18a98cca37ee6d9bdb8a522c2022379 | org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTableTest | | | | - org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableList
| | Uses | True |
table.addRecord(createKafkaTestRecord(STR0 + i,ImmutableList.of(i,1,2d),500L * i)); | table.addRecord(createKafkaTestRecord(STR0 + i,i,500L * i)); | ImmutableList.of(i,1,2d) | i | beam | 56802e30d18a98cca37ee6d9bdb8a522c2022379 | org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTableTest | | | | - org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableList
| | Uses | True |
table.addRecord(createKafkaTestRecord(STR0 + i,ImmutableList.of(i,1,2d),500L * i)); | table.addRecord(createKafkaTestRecord(STR0 + i,i,500L * i)); | ImmutableList.of(i,1,2d) | i | beam | 56802e30d18a98cca37ee6d9bdb8a522c2022379 | org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTableTest | | | | - org.apache.beam.vendor.guava.v26_0_jre.com.google.common.collect.ImmutableList
| | Uses | True |