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