Package org.apache.beam.sdk.extensions.sql.meta.provider.kafka

Class PayloadSerializerKafkaTable

java.lang.Object

org.apache.beam.sdk.extensions.sql.meta.BaseBeamTable

org.apache.beam.sdk.extensions.sql.meta.SchemaBaseBeamTable

org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTable

org.apache.beam.sdk.extensions.sql.meta.provider.kafka.PayloadSerializerKafkaTable

All Implemented Interfaces:

java.io.Serializable, BeamSqlTable

public class PayloadSerializerKafkaTable
extends BeamKafkaTable

See Also:

Serialized Form

Field Summary

Fields inherited from class org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTable

numberOfRecordsForRate

Fields inherited from class org.apache.beam.sdk.extensions.sql.meta.SchemaBaseBeamTable

schema

Method Summary

Modifier and Type	Method	Description
protected org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.io.kafka.KafkaRecord<byte[],byte[]>>,org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row>>	getPTransformForInput()
protected org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row>,org.apache.beam.sdk.values.PCollection<org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]>>>	getPTransformForOutput()

Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.provider.kafka.BeamKafkaTable

buildIOReader, buildIOWriter, createKafkaRead, getBootstrapServers, getConfigUpdates, getTableStatistics, getTimestampPolicyFactory, getTopics, isBounded, updateConsumerProperties

Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.SchemaBaseBeamTable

getSchema

Methods inherited from class org.apache.beam.sdk.extensions.sql.meta.BaseBeamTable

buildIOReader, constructFilter, supportsProjects

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

getPTransformForInput

protected org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.io.kafka.KafkaRecord<byte[],byte[]>>,org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row>> getPTransformForInput()

Specified by:

getPTransformForInput in class BeamKafkaTable

getPTransformForOutput

protected org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<org.apache.beam.sdk.values.Row>,org.apache.beam.sdk.values.PCollection<org.apache.kafka.clients.producer.ProducerRecord<byte[],byte[]>>> getPTransformForOutput()

Specified by:

getPTransformForOutput in class BeamKafkaTable