Struct aws_sdk_kinesisanalytics::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder
source · pub struct DiscoverInputSchemaFluentBuilder { /* private fields */ }
Expand description
Fluent builder constructing a request to DiscoverInputSchema
.
This documentation is for version 1 of the Amazon Kinesis Data Analytics API, which only supports SQL applications. Version 2 of the API supports SQL and Java applications. For more information about version 2, see Amazon Kinesis Data Analytics API V2 Documentation.
Infers a schema by evaluating sample records on the specified streaming source (Amazon Kinesis stream or Amazon Kinesis Firehose delivery stream) or S3 object. In the response, the operation returns the inferred schema and also the sample records that the operation used to infer the schema.
You can use the inferred schema when configuring a streaming source for your application. For conceptual information, see Configuring Application Input. Note that when you create an application using the Amazon Kinesis Analytics console, the console uses this operation to infer a schema and show it in the console user interface.
This operation requires permissions to perform the kinesisanalytics:DiscoverInputSchema
action.
Implementations§
source§impl DiscoverInputSchemaFluentBuilder
impl DiscoverInputSchemaFluentBuilder
sourcepub fn as_input(&self) -> &DiscoverInputSchemaInputBuilder
pub fn as_input(&self) -> &DiscoverInputSchemaInputBuilder
Access the DiscoverInputSchema as a reference.
sourcepub async fn send(
self
) -> Result<DiscoverInputSchemaOutput, SdkError<DiscoverInputSchemaError, HttpResponse>>
pub async fn send( self ) -> Result<DiscoverInputSchemaOutput, SdkError<DiscoverInputSchemaError, HttpResponse>>
Sends the request and returns the response.
If an error occurs, an SdkError
will be returned with additional details that
can be matched against.
By default, any retryable failures will be retried twice. Retry behavior is configurable with the RetryConfig, which can be set when configuring the client.
sourcepub fn customize(
self
) -> CustomizableOperation<DiscoverInputSchemaOutput, DiscoverInputSchemaError, Self>
pub fn customize( self ) -> CustomizableOperation<DiscoverInputSchemaOutput, DiscoverInputSchemaError, Self>
Consumes this builder, creating a customizable operation that can be modified before being sent.
sourcepub fn resource_arn(self, input: impl Into<String>) -> Self
pub fn resource_arn(self, input: impl Into<String>) -> Self
Amazon Resource Name (ARN) of the streaming source.
sourcepub fn set_resource_arn(self, input: Option<String>) -> Self
pub fn set_resource_arn(self, input: Option<String>) -> Self
Amazon Resource Name (ARN) of the streaming source.
sourcepub fn get_resource_arn(&self) -> &Option<String>
pub fn get_resource_arn(&self) -> &Option<String>
Amazon Resource Name (ARN) of the streaming source.
sourcepub fn role_arn(self, input: impl Into<String>) -> Self
pub fn role_arn(self, input: impl Into<String>) -> Self
ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf.
sourcepub fn set_role_arn(self, input: Option<String>) -> Self
pub fn set_role_arn(self, input: Option<String>) -> Self
ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf.
sourcepub fn get_role_arn(&self) -> &Option<String>
pub fn get_role_arn(&self) -> &Option<String>
ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf.
sourcepub fn input_starting_position_configuration(
self,
input: InputStartingPositionConfiguration
) -> Self
pub fn input_starting_position_configuration( self, input: InputStartingPositionConfiguration ) -> Self
Point at which you want Amazon Kinesis Analytics to start reading records from the specified streaming source discovery purposes.
sourcepub fn set_input_starting_position_configuration(
self,
input: Option<InputStartingPositionConfiguration>
) -> Self
pub fn set_input_starting_position_configuration( self, input: Option<InputStartingPositionConfiguration> ) -> Self
Point at which you want Amazon Kinesis Analytics to start reading records from the specified streaming source discovery purposes.
sourcepub fn get_input_starting_position_configuration(
&self
) -> &Option<InputStartingPositionConfiguration>
pub fn get_input_starting_position_configuration( &self ) -> &Option<InputStartingPositionConfiguration>
Point at which you want Amazon Kinesis Analytics to start reading records from the specified streaming source discovery purposes.
sourcepub fn s3_configuration(self, input: S3Configuration) -> Self
pub fn s3_configuration(self, input: S3Configuration) -> Self
Specify this parameter to discover a schema from data in an Amazon S3 object.
sourcepub fn set_s3_configuration(self, input: Option<S3Configuration>) -> Self
pub fn set_s3_configuration(self, input: Option<S3Configuration>) -> Self
Specify this parameter to discover a schema from data in an Amazon S3 object.
sourcepub fn get_s3_configuration(&self) -> &Option<S3Configuration>
pub fn get_s3_configuration(&self) -> &Option<S3Configuration>
Specify this parameter to discover a schema from data in an Amazon S3 object.
sourcepub fn input_processing_configuration(
self,
input: InputProcessingConfiguration
) -> Self
pub fn input_processing_configuration( self, input: InputProcessingConfiguration ) -> Self
The InputProcessingConfiguration to use to preprocess the records before discovering the schema of the records.
sourcepub fn set_input_processing_configuration(
self,
input: Option<InputProcessingConfiguration>
) -> Self
pub fn set_input_processing_configuration( self, input: Option<InputProcessingConfiguration> ) -> Self
The InputProcessingConfiguration to use to preprocess the records before discovering the schema of the records.
sourcepub fn get_input_processing_configuration(
&self
) -> &Option<InputProcessingConfiguration>
pub fn get_input_processing_configuration( &self ) -> &Option<InputProcessingConfiguration>
The InputProcessingConfiguration to use to preprocess the records before discovering the schema of the records.
Trait Implementations§
source§impl Clone for DiscoverInputSchemaFluentBuilder
impl Clone for DiscoverInputSchemaFluentBuilder
source§fn clone(&self) -> DiscoverInputSchemaFluentBuilder
fn clone(&self) -> DiscoverInputSchemaFluentBuilder
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source
. Read moreAuto Trait Implementations§
impl Freeze for DiscoverInputSchemaFluentBuilder
impl !RefUnwindSafe for DiscoverInputSchemaFluentBuilder
impl Send for DiscoverInputSchemaFluentBuilder
impl Sync for DiscoverInputSchemaFluentBuilder
impl Unpin for DiscoverInputSchemaFluentBuilder
impl !UnwindSafe for DiscoverInputSchemaFluentBuilder
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
source§impl<T> Instrument for T
impl<T> Instrument for T
source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
source§impl<T> IntoEither for T
impl<T> IntoEither for T
source§fn into_either(self, into_left: bool) -> Either<Self, Self>
fn into_either(self, into_left: bool) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left
is true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read moresource§fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
fn into_either_with<F>(self, into_left: F) -> Either<Self, Self>
self
into a Left
variant of Either<Self, Self>
if into_left(&self)
returns true
.
Converts self
into a Right
variant of Either<Self, Self>
otherwise. Read more