Interface DirectKinesisSource.Builder

All Superinterfaces:

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

Enclosing class:

DirectKinesisSource

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

Method Summary

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

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

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

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

streamingOptions

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

DirectKinesisSource.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 DirectKinesisSource.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)