aws_sdk_kinesisanalyticsv2/client/
discover_input_schema.rs

1// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
2impl super::Client {
3    /// Constructs a fluent builder for the [`DiscoverInputSchema`](crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder) operation.
4    ///
5    /// - The fluent builder is configurable:
6    ///   - [`resource_arn(impl Into<String>)`](crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder::resource_arn) / [`set_resource_arn(Option<String>)`](crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder::set_resource_arn):<br>required: **false**<br><p>The Amazon Resource Name (ARN) of the streaming source.</p><br>
7    ///   - [`service_execution_role(impl Into<String>)`](crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder::service_execution_role) / [`set_service_execution_role(Option<String>)`](crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder::set_service_execution_role):<br>required: **true**<br><p>The ARN of the role that is used to access the streaming source.</p><br>
8    ///   - [`input_starting_position_configuration(InputStartingPositionConfiguration)`](crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder::input_starting_position_configuration) / [`set_input_starting_position_configuration(Option<InputStartingPositionConfiguration>)`](crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder::set_input_starting_position_configuration):<br>required: **false**<br><p>The point at which you want Kinesis Data Analytics to start reading records from the specified streaming source for discovery purposes.</p><br>
9    ///   - [`s3_configuration(S3Configuration)`](crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder::s3_configuration) / [`set_s3_configuration(Option<S3Configuration>)`](crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder::set_s3_configuration):<br>required: **false**<br><p>Specify this parameter to discover a schema from data in an Amazon S3 object.</p><br>
10    ///   - [`input_processing_configuration(InputProcessingConfiguration)`](crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder::input_processing_configuration) / [`set_input_processing_configuration(Option<InputProcessingConfiguration>)`](crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder::set_input_processing_configuration):<br>required: **false**<br><p>The <code>InputProcessingConfiguration</code> to use to preprocess the records before discovering the schema of the records.</p><br>
11    /// - On success, responds with [`DiscoverInputSchemaOutput`](crate::operation::discover_input_schema::DiscoverInputSchemaOutput) with field(s):
12    ///   - [`input_schema(Option<SourceSchema>)`](crate::operation::discover_input_schema::DiscoverInputSchemaOutput::input_schema): <p>The schema inferred from the streaming source. It identifies the format of the data in the streaming source and how each data element maps to corresponding columns in the in-application stream that you can create.</p>
13    ///   - [`parsed_input_records(Option<Vec::<Vec::<String>>>)`](crate::operation::discover_input_schema::DiscoverInputSchemaOutput::parsed_input_records): <p>An array of elements, where each element corresponds to a row in a stream record (a stream record can have more than one row).</p>
14    ///   - [`processed_input_records(Option<Vec::<String>>)`](crate::operation::discover_input_schema::DiscoverInputSchemaOutput::processed_input_records): <p>The stream data that was modified by the processor specified in the <code>InputProcessingConfiguration</code> parameter.</p>
15    ///   - [`raw_input_records(Option<Vec::<String>>)`](crate::operation::discover_input_schema::DiscoverInputSchemaOutput::raw_input_records): <p>The raw stream data that was sampled to infer the schema.</p>
16    /// - On failure, responds with [`SdkError<DiscoverInputSchemaError>`](crate::operation::discover_input_schema::DiscoverInputSchemaError)
17    pub fn discover_input_schema(&self) -> crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder {
18        crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder::new(self.handle.clone())
19    }
20}
aws_sdk_kinesisanalyticsv2/client/discover_input_schema.rs

aws_sdk_kinesisanalyticsv2/client/
discover_input_schema.rs
