1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
// Code generated by software.amazon.smithy.rust.codegen.smithy-rs. DO NOT EDIT.
impl super::Client {
    /// Constructs a fluent builder for the [`DiscoverInputSchema`](crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder) operation.
    ///
    /// - The fluent builder is configurable:
    ///   - [`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>Amazon Resource Name (ARN) of the streaming source.</p><br>
    ///   - [`role_arn(impl Into<String>)`](crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder::role_arn) / [`set_role_arn(Option<String>)`](crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder::set_role_arn):<br>required: **false**<br><p>ARN of the IAM role that Amazon Kinesis Analytics can assume to access the stream on your behalf.</p><br>
    ///   - [`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>Point at which you want Amazon Kinesis Analytics to start reading records from the specified streaming source discovery purposes.</p><br>
    ///   - [`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>
    ///   - [`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 <a href="https://docs.aws.amazon.com/kinesisanalytics/latest/dev/API_InputProcessingConfiguration.html">InputProcessingConfiguration</a> to use to preprocess the records before discovering the schema of the records.</p><br>
    /// - On success, responds with [`DiscoverInputSchemaOutput`](crate::operation::discover_input_schema::DiscoverInputSchemaOutput) with field(s):
    ///   - [`input_schema(Option<SourceSchema>)`](crate::operation::discover_input_schema::DiscoverInputSchemaOutput::input_schema): <p>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>
    ///   - [`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>
    ///   - [`processed_input_records(Option<Vec::<String>>)`](crate::operation::discover_input_schema::DiscoverInputSchemaOutput::processed_input_records): <p>Stream data that was modified by the processor specified in the <code>InputProcessingConfiguration</code> parameter.</p>
    ///   - [`raw_input_records(Option<Vec::<String>>)`](crate::operation::discover_input_schema::DiscoverInputSchemaOutput::raw_input_records): <p>Raw stream data that was sampled to infer the schema.</p>
    /// - On failure, responds with [`SdkError<DiscoverInputSchemaError>`](crate::operation::discover_input_schema::DiscoverInputSchemaError)
    pub fn discover_input_schema(&self) -> crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder {
        crate::operation::discover_input_schema::builders::DiscoverInputSchemaFluentBuilder::new(self.handle.clone())
    }
}