Struct aws_sdk_glue::model::catalog_kafka_source::Builder
source · pub struct Builder { /* private fields */ }Expand description
A builder for CatalogKafkaSource.
Implementations§
source§impl Builder
impl Builder
sourcepub fn window_size(self, input: i32) -> Self
pub fn window_size(self, input: i32) -> Self
The amount of time to spend processing each micro batch.
sourcepub fn set_window_size(self, input: Option<i32>) -> Self
pub fn set_window_size(self, input: Option<i32>) -> Self
The amount of time to spend processing each micro batch.
sourcepub fn detect_schema(self, input: bool) -> Self
pub fn detect_schema(self, input: bool) -> Self
Whether to automatically determine the schema from the incoming data.
sourcepub fn set_detect_schema(self, input: Option<bool>) -> Self
pub fn set_detect_schema(self, input: Option<bool>) -> Self
Whether to automatically determine the schema from the incoming data.
sourcepub fn table(self, input: impl Into<String>) -> Self
pub fn table(self, input: impl Into<String>) -> Self
The name of the table in the database to read from.
sourcepub fn set_table(self, input: Option<String>) -> Self
pub fn set_table(self, input: Option<String>) -> Self
The name of the table in the database to read from.
sourcepub fn set_database(self, input: Option<String>) -> Self
pub fn set_database(self, input: Option<String>) -> Self
The name of the database to read from.
sourcepub fn streaming_options(self, input: KafkaStreamingSourceOptions) -> Self
pub fn streaming_options(self, input: KafkaStreamingSourceOptions) -> Self
Specifies the streaming options.
sourcepub fn set_streaming_options(
self,
input: Option<KafkaStreamingSourceOptions>
) -> Self
pub fn set_streaming_options(
self,
input: Option<KafkaStreamingSourceOptions>
) -> Self
Specifies the streaming options.
sourcepub fn data_preview_options(self, input: StreamingDataPreviewOptions) -> Self
pub fn data_preview_options(self, input: StreamingDataPreviewOptions) -> Self
Specifies options related to data preview for viewing a sample of your data.
sourcepub fn set_data_preview_options(
self,
input: Option<StreamingDataPreviewOptions>
) -> Self
pub fn set_data_preview_options(
self,
input: Option<StreamingDataPreviewOptions>
) -> Self
Specifies options related to data preview for viewing a sample of your data.
sourcepub fn build(self) -> CatalogKafkaSource
pub fn build(self) -> CatalogKafkaSource
Consumes the builder and constructs a CatalogKafkaSource.