org.apache.beam.sdk.io.kafka

Class KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration.Builder

java.lang.Object

org.apache.beam.sdk.io.kafka.KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration.Builder

Enclosing class:

KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration

public abstract static class KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration.Builder
extends java.lang.Object

Builder for the KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration.

Constructor Summary

Constructors

Constructor and Description
Builder()

Method Summary

Modifier and Type	Method and Description
abstract KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration	build() Builds a KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration instance.
abstract KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration.Builder	setPartition(java.lang.Integer value) The number of the topic partition.
abstract KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration.Builder	setTopic(java.lang.String value) The name of the topic defining the partition.

Methods inherited from class java.lang.Object

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

Constructor Detail

Builder

public Builder()

Method Detail

setTopic

public abstract KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration.Builder setTopic(java.lang.String value)

The name of the topic defining the partition.

setPartition

public abstract KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration.Builder setPartition(java.lang.Integer value)

The number of the topic partition.

build

public abstract KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration build()

Builds a KafkaSchemaTransformReadConfiguration.TopicPartitionConfiguration instance.