Interface CatalogKafkaSource.Builder

All Superinterfaces:

Buildable, CopyableBuilder<CatalogKafkaSource.Builder,CatalogKafkaSource>, SdkBuilder<CatalogKafkaSource.Builder,CatalogKafkaSource>, SdkPojo

Enclosing class:

CatalogKafkaSource

public static interface CatalogKafkaSource.Builder
extends SdkPojo, CopyableBuilder<CatalogKafkaSource.Builder,CatalogKafkaSource>

Method Summary

Modifier and Type	Method	Description
CatalogKafkaSource.Builder	database(String database)	The name of the database to read from.
default CatalogKafkaSource.Builder	dataPreviewOptions(Consumer<StreamingDataPreviewOptions.Builder> dataPreviewOptions)	Specifies options related to data preview for viewing a sample of your data.
CatalogKafkaSource.Builder	dataPreviewOptions(StreamingDataPreviewOptions dataPreviewOptions)	Specifies options related to data preview for viewing a sample of your data.
CatalogKafkaSource.Builder	detectSchema(Boolean detectSchema)	Whether to automatically determine the schema from the incoming data.
CatalogKafkaSource.Builder	name(String name)	The name of the data store.
default CatalogKafkaSource.Builder	streamingOptions(Consumer<KafkaStreamingSourceOptions.Builder> streamingOptions)	Specifies the streaming options.
CatalogKafkaSource.Builder	streamingOptions(KafkaStreamingSourceOptions streamingOptions)	Specifies the streaming options.
CatalogKafkaSource.Builder	table(String table)	The name of the table in the database to read from.
CatalogKafkaSource.Builder	windowSize(Integer windowSize)	The amount of time to spend processing each micro batch.

Methods inherited from interface software.amazon.awssdk.utils.builder.CopyableBuilder

copy

Methods inherited from interface software.amazon.awssdk.utils.builder.SdkBuilder

applyMutation, build

Methods inherited from interface software.amazon.awssdk.core.SdkPojo

equalsBySdkFields, sdkFields

Method Details

name

CatalogKafkaSource.Builder name(String name)

The name of the data store.

Parameters:

name - The name of the data store.

Returns:

Returns a reference to this object so that method calls can be chained together.

windowSize

CatalogKafkaSource.Builder windowSize(Integer windowSize)

The amount of time to spend processing each micro batch.

Parameters:

windowSize - The amount of time to spend processing each micro batch.

Returns:

Returns a reference to this object so that method calls can be chained together.

detectSchema

CatalogKafkaSource.Builder detectSchema(Boolean detectSchema)

Whether to automatically determine the schema from the incoming data.

Parameters:

detectSchema - Whether to automatically determine the schema from the incoming data.

Returns:

Returns a reference to this object so that method calls can be chained together.

table

CatalogKafkaSource.Builder table(String table)

The name of the table in the database to read from.

Parameters:

table - The name of the table in the database to read from.

Returns:

Returns a reference to this object so that method calls can be chained together.

database

CatalogKafkaSource.Builder database(String database)

The name of the database to read from.

Parameters:

database - The name of the database to read from.

Returns:

Returns a reference to this object so that method calls can be chained together.

streamingOptions

CatalogKafkaSource.Builder streamingOptions(KafkaStreamingSourceOptions streamingOptions)

Specifies the streaming options.

Parameters:

streamingOptions - Specifies the streaming options.

Returns:

Returns a reference to this object so that method calls can be chained together.

streamingOptions

default CatalogKafkaSource.Builder streamingOptions(Consumer<KafkaStreamingSourceOptions.Builder> streamingOptions)

Specifies the streaming options.

This is a convenience method that creates an instance of the KafkaStreamingSourceOptions.Builder avoiding the need to create one manually via KafkaStreamingSourceOptions.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to streamingOptions(KafkaStreamingSourceOptions).

Parameters:

streamingOptions - a consumer that will call methods on KafkaStreamingSourceOptions.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• streamingOptions(KafkaStreamingSourceOptions)

dataPreviewOptions

CatalogKafkaSource.Builder dataPreviewOptions(StreamingDataPreviewOptions dataPreviewOptions)

Specifies options related to data preview for viewing a sample of your data.

Parameters:

dataPreviewOptions - Specifies options related to data preview for viewing a sample of your data.

Returns:

Returns a reference to this object so that method calls can be chained together.

dataPreviewOptions

default CatalogKafkaSource.Builder dataPreviewOptions(Consumer<StreamingDataPreviewOptions.Builder> dataPreviewOptions)

Specifies options related to data preview for viewing a sample of your data.

This is a convenience method that creates an instance of the StreamingDataPreviewOptions.Builder avoiding the need to create one manually via StreamingDataPreviewOptions.builder().

When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to dataPreviewOptions(StreamingDataPreviewOptions).

Parameters:

dataPreviewOptions - a consumer that will call methods on StreamingDataPreviewOptions.Builder

Returns:

Returns a reference to this object so that method calls can be chained together.

See Also:

• dataPreviewOptions(StreamingDataPreviewOptions)