* 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. *
*/ 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
* The stream data that was modified by the processor specified in the InputProcessingConfiguration
* parameter.
*
* The raw stream data that was sampled to infer the schema. *
*/ private java.util.List* 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. *
* * @param inputSchema * 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. */ public void setInputSchema(SourceSchema inputSchema) { this.inputSchema = inputSchema; } /** ** 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. *
* * @return 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. */ public SourceSchema getInputSchema() { return this.inputSchema; } /** ** 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. *
* * @param inputSchema * 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. * @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
* The stream data that was modified by the processor specified in the InputProcessingConfiguration
* parameter.
*
InputProcessingConfiguration
parameter.
*/
public java.util.List
* The stream data that was modified by the processor specified in the InputProcessingConfiguration
* parameter.
*
InputProcessingConfiguration
parameter.
*/
public void setProcessedInputRecords(java.util.Collection
* The 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 * The stream data that was modified by the processor specified in the *InputProcessingConfiguration
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
* The 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* The raw stream data that was sampled to infer the schema. *
* * @return The raw stream data that was sampled to infer the schema. */ public java.util.List* The raw stream data that was sampled to infer the schema. *
* * @param rawInputRecords * The raw stream data that was sampled to infer the schema. */ public void setRawInputRecords(java.util.Collection* The 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 * The 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* The raw stream data that was sampled to infer the schema. *
* * @param rawInputRecords * The 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