Interface CatalogKinesisSource.Builder

All Superinterfaces:

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

Enclosing class:

CatalogKinesisSource

@Mutable
@NotThreadSafe
public static interface CatalogKinesisSource.Builder
extends SdkPojo, CopyableBuilder<CatalogKinesisSource.Builder,CatalogKinesisSource>

Method Summary

Modifier and Type	Method	Description
CatalogKinesisSource.Builder	database(String database)	The name of the database to read from.
default CatalogKinesisSource.Builder	dataPreviewOptions(Consumer<StreamingDataPreviewOptions.Builder> dataPreviewOptions)	Additional options for data preview.
CatalogKinesisSource.Builder	dataPreviewOptions(StreamingDataPreviewOptions dataPreviewOptions)	Additional options for data preview.
CatalogKinesisSource.Builder	detectSchema(Boolean detectSchema)	Whether to automatically determine the schema from the incoming data.
CatalogKinesisSource.Builder	name(String name)	The name of the data source.
default CatalogKinesisSource.Builder	streamingOptions(Consumer<KinesisStreamingSourceOptions.Builder> streamingOptions)	Additional options for the Kinesis streaming data source.
CatalogKinesisSource.Builder	streamingOptions(KinesisStreamingSourceOptions streamingOptions)	Additional options for the Kinesis streaming data source.
CatalogKinesisSource.Builder	table(String table)	The name of the table in the database to read from.
CatalogKinesisSource.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, sdkFieldNameToField, sdkFields

Method Details

name

CatalogKinesisSource.Builder name(String name)

The name of the data source.

Parameters:

name - The name of the data source.

Returns:

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

windowSize

CatalogKinesisSource.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

CatalogKinesisSource.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

CatalogKinesisSource.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

CatalogKinesisSource.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

CatalogKinesisSource.Builder streamingOptions(KinesisStreamingSourceOptions streamingOptions)

Additional options for the Kinesis streaming data source.

Parameters:

streamingOptions - Additional options for the Kinesis streaming data source.

Returns:

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

streamingOptions

default CatalogKinesisSource.Builder streamingOptions(Consumer<KinesisStreamingSourceOptions.Builder> streamingOptions)

Additional options for the Kinesis streaming data source.

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

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

Parameters:

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

Returns:

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

See Also:

• streamingOptions(KinesisStreamingSourceOptions)

dataPreviewOptions

CatalogKinesisSource.Builder dataPreviewOptions(StreamingDataPreviewOptions dataPreviewOptions)

Additional options for data preview.

Parameters:

dataPreviewOptions - Additional options for data preview.

Returns:

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

dataPreviewOptions

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

Additional options for data preview.

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)