/* * Copyright 2018-2023 Amazon.com, Inc. or its affiliates. All Rights Reserved. * * Licensed under the Apache License, Version 2.0 (the "License"). You may not use this file except in compliance with * the License. A copy of the License is located at * * http://aws.amazon.com/apache2.0 * * or in the "license" file accompanying this file. This file is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR * CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions * and limitations under the License. */ package com.amazonaws.services.kinesisanalytics.model; import java.io.Serializable; import javax.annotation.Generated; /** *
* * @see AWS API Documentation */ @Generated("com.amazonaws:aws-java-sdk-code-generator") public class DiscoverInputSchemaResult extends com.amazonaws.AmazonWebServiceResult* 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. *
*/ private SourceSchema inputSchema; /** ** An array of elements, where each element corresponds to a row in a stream record (a stream record can have more * than one row). *
*/ private java.util.List
* Stream data that was modified by the processor specified in the InputProcessingConfiguration
* parameter.
*
* Raw stream data that was sampled to infer the schema. *
*/ private java.util.List* 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. *
* * @param inputSchema * 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. */ public void setInputSchema(SourceSchema inputSchema) { this.inputSchema = inputSchema; } /** ** 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. *
* * @return 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. */ public SourceSchema getInputSchema() { return this.inputSchema; } /** ** 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. *
* * @param inputSchema * 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. * @return Returns a reference to this object so that method calls can be chained together. */ public DiscoverInputSchemaResult withInputSchema(SourceSchema inputSchema) { setInputSchema(inputSchema); return this; } /** ** An array of elements, where each element corresponds to a row in a stream record (a stream record can have more * than one row). *
* * @return An array of elements, where each element corresponds to a row in a stream record (a stream record can * have more than one row). */ public java.util.List* An array of elements, where each element corresponds to a row in a stream record (a stream record can have more * than one row). *
* * @param parsedInputRecords * An array of elements, where each element corresponds to a row in a stream record (a stream record can have * more than one row). */ public void setParsedInputRecords(java.util.Collection* An array of elements, where each element corresponds to a row in a stream record (a stream record can have more * than one row). *
** NOTE: This method appends the values to the existing list (if any). Use * {@link #setParsedInputRecords(java.util.Collection)} or {@link #withParsedInputRecords(java.util.Collection)} if * you want to override the existing values. *
* * @param parsedInputRecords * An array of elements, where each element corresponds to a row in a stream record (a stream record can have * more than one row). * @return Returns a reference to this object so that method calls can be chained together. */ public DiscoverInputSchemaResult withParsedInputRecords(java.util.List* An array of elements, where each element corresponds to a row in a stream record (a stream record can have more * than one row). *
* * @param parsedInputRecords * An array of elements, where each element corresponds to a row in a stream record (a stream record can have * more than one row). * @return Returns a reference to this object so that method calls can be chained together. */ public DiscoverInputSchemaResult withParsedInputRecords(java.util.Collection
* Stream data that was modified by the processor specified in the InputProcessingConfiguration
* parameter.
*
InputProcessingConfiguration
* parameter.
*/
public java.util.List
* Stream data that was modified by the processor specified in the InputProcessingConfiguration
* parameter.
*
InputProcessingConfiguration
* parameter.
*/
public void setProcessedInputRecords(java.util.Collection
* Stream data that was modified by the processor specified in the InputProcessingConfiguration
* parameter.
*
* NOTE: This method appends the values to the existing list (if any). Use * {@link #setProcessedInputRecords(java.util.Collection)} or * {@link #withProcessedInputRecords(java.util.Collection)} if you want to override the existing values. *
* * @param processedInputRecords * Stream data that was modified by the processor specified in theInputProcessingConfiguration
* parameter.
* @return Returns a reference to this object so that method calls can be chained together.
*/
public DiscoverInputSchemaResult withProcessedInputRecords(String... processedInputRecords) {
if (this.processedInputRecords == null) {
setProcessedInputRecords(new java.util.ArrayList
* Stream data that was modified by the processor specified in the InputProcessingConfiguration
* parameter.
*
InputProcessingConfiguration
* parameter.
* @return Returns a reference to this object so that method calls can be chained together.
*/
public DiscoverInputSchemaResult withProcessedInputRecords(java.util.Collection* Raw stream data that was sampled to infer the schema. *
* * @return Raw stream data that was sampled to infer the schema. */ public java.util.List* Raw stream data that was sampled to infer the schema. *
* * @param rawInputRecords * Raw stream data that was sampled to infer the schema. */ public void setRawInputRecords(java.util.Collection* Raw stream data that was sampled to infer the schema. *
** NOTE: This method appends the values to the existing list (if any). Use * {@link #setRawInputRecords(java.util.Collection)} or {@link #withRawInputRecords(java.util.Collection)} if you * want to override the existing values. *
* * @param rawInputRecords * Raw stream data that was sampled to infer the schema. * @return Returns a reference to this object so that method calls can be chained together. */ public DiscoverInputSchemaResult withRawInputRecords(String... rawInputRecords) { if (this.rawInputRecords == null) { setRawInputRecords(new java.util.ArrayList* Raw stream data that was sampled to infer the schema. *
* * @param rawInputRecords * Raw stream data that was sampled to infer the schema. * @return Returns a reference to this object so that method calls can be chained together. */ public DiscoverInputSchemaResult withRawInputRecords(java.util.Collection