* When you configure the application input, you specify the streaming source, the in-application stream name that is * created, and the mapping between the two. For more information, see Configuring Application * Input. *
* * @see AWS API * Documentation */ @Generated("com.amazonaws:aws-java-sdk-code-generator") public class Input implements Serializable, Cloneable, StructuredPojo { /** *
* Name prefix to use when creating an in-application stream. Suppose that you specify a prefix
* "MyInApplicationStream." Amazon Kinesis Analytics then creates one or more (as per the
* InputParallelism count you specified) in-application streams with names "MyInApplicationStream_001,"
* "MyInApplicationStream_002," and so on.
*
* The * InputProcessingConfiguration for the input. An input processor transforms records as they are received from * the stream, before the application's SQL code executes. Currently, the only input processing configuration * available is * InputLambdaProcessor. *
*/ private InputProcessingConfiguration inputProcessingConfiguration; /** ** If the streaming source is an Amazon Kinesis stream, identifies the stream's Amazon Resource Name (ARN) and an * IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf. *
*
* Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.
*
* If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the delivery stream's ARN and * an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf. *
*
* Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.
*
* Describes the number of in-application streams to create. *
** Data from your source is routed to these in-application input streams. *
** (see Configuring * Application Input. *
*/ private InputParallelism inputParallelism; /** ** Describes the format of the data in the streaming source, and how each data element maps to corresponding columns * in the in-application stream that is being created. *
** Also used to describe the format of the reference data source. *
*/ private SourceSchema inputSchema; /** *
* Name prefix to use when creating an in-application stream. Suppose that you specify a prefix
* "MyInApplicationStream." Amazon Kinesis Analytics then creates one or more (as per the
* InputParallelism count you specified) in-application streams with names "MyInApplicationStream_001,"
* "MyInApplicationStream_002," and so on.
*
InputParallelism count you specified) in-application streams with names
* "MyInApplicationStream_001," "MyInApplicationStream_002," and so on.
*/
public void setNamePrefix(String namePrefix) {
this.namePrefix = namePrefix;
}
/**
*
* Name prefix to use when creating an in-application stream. Suppose that you specify a prefix
* "MyInApplicationStream." Amazon Kinesis Analytics then creates one or more (as per the
* InputParallelism count you specified) in-application streams with names "MyInApplicationStream_001,"
* "MyInApplicationStream_002," and so on.
*
InputParallelism count you specified) in-application streams with names
* "MyInApplicationStream_001," "MyInApplicationStream_002," and so on.
*/
public String getNamePrefix() {
return this.namePrefix;
}
/**
*
* Name prefix to use when creating an in-application stream. Suppose that you specify a prefix
* "MyInApplicationStream." Amazon Kinesis Analytics then creates one or more (as per the
* InputParallelism count you specified) in-application streams with names "MyInApplicationStream_001,"
* "MyInApplicationStream_002," and so on.
*
InputParallelism count you specified) in-application streams with names
* "MyInApplicationStream_001," "MyInApplicationStream_002," and so on.
* @return Returns a reference to this object so that method calls can be chained together.
*/
public Input withNamePrefix(String namePrefix) {
setNamePrefix(namePrefix);
return this;
}
/**
* * The * InputProcessingConfiguration for the input. An input processor transforms records as they are received from * the stream, before the application's SQL code executes. Currently, the only input processing configuration * available is * InputLambdaProcessor. *
* * @param inputProcessingConfiguration * The InputProcessingConfiguration for the input. An input processor transforms records as they are * received from the stream, before the application's SQL code executes. Currently, the only input processing * configuration available is InputLambdaProcessor. */ public void setInputProcessingConfiguration(InputProcessingConfiguration inputProcessingConfiguration) { this.inputProcessingConfiguration = inputProcessingConfiguration; } /** ** The * InputProcessingConfiguration for the input. An input processor transforms records as they are received from * the stream, before the application's SQL code executes. Currently, the only input processing configuration * available is * InputLambdaProcessor. *
* * @return The InputProcessingConfiguration for the input. An input processor transforms records as they are * received from the stream, before the application's SQL code executes. Currently, the only input * processing configuration available is InputLambdaProcessor. */ public InputProcessingConfiguration getInputProcessingConfiguration() { return this.inputProcessingConfiguration; } /** ** The * InputProcessingConfiguration for the input. An input processor transforms records as they are received from * the stream, before the application's SQL code executes. Currently, the only input processing configuration * available is * InputLambdaProcessor. *
* * @param inputProcessingConfiguration * The InputProcessingConfiguration for the input. An input processor transforms records as they are * received from the stream, before the application's SQL code executes. Currently, the only input processing * configuration available is InputLambdaProcessor. * @return Returns a reference to this object so that method calls can be chained together. */ public Input withInputProcessingConfiguration(InputProcessingConfiguration inputProcessingConfiguration) { setInputProcessingConfiguration(inputProcessingConfiguration); return this; } /** ** If the streaming source is an Amazon Kinesis stream, identifies the stream's Amazon Resource Name (ARN) and an * IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf. *
*
* Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.
*
* Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.
*/
public void setKinesisStreamsInput(KinesisStreamsInput kinesisStreamsInput) {
this.kinesisStreamsInput = kinesisStreamsInput;
}
/**
*
* If the streaming source is an Amazon Kinesis stream, identifies the stream's Amazon Resource Name (ARN) and an * IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf. *
*
* Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.
*
* Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.
*/
public KinesisStreamsInput getKinesisStreamsInput() {
return this.kinesisStreamsInput;
}
/**
*
* If the streaming source is an Amazon Kinesis stream, identifies the stream's Amazon Resource Name (ARN) and an * IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf. *
*
* Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.
*
* Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.
* @return Returns a reference to this object so that method calls can be chained together.
*/
public Input withKinesisStreamsInput(KinesisStreamsInput kinesisStreamsInput) {
setKinesisStreamsInput(kinesisStreamsInput);
return this;
}
/**
*
* If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the delivery stream's ARN and * an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf. *
*
* Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.
*
* Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.
*/
public void setKinesisFirehoseInput(KinesisFirehoseInput kinesisFirehoseInput) {
this.kinesisFirehoseInput = kinesisFirehoseInput;
}
/**
*
* If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the delivery stream's ARN and * an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf. *
*
* Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.
*
* Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.
*/
public KinesisFirehoseInput getKinesisFirehoseInput() {
return this.kinesisFirehoseInput;
}
/**
*
* If the streaming source is an Amazon Kinesis Firehose delivery stream, identifies the delivery stream's ARN and * an IAM role that enables Amazon Kinesis Analytics to access the stream on your behalf. *
*
* Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.
*
* Note: Either KinesisStreamsInput or KinesisFirehoseInput is required.
* @return Returns a reference to this object so that method calls can be chained together.
*/
public Input withKinesisFirehoseInput(KinesisFirehoseInput kinesisFirehoseInput) {
setKinesisFirehoseInput(kinesisFirehoseInput);
return this;
}
/**
*
* Describes the number of in-application streams to create. *
** Data from your source is routed to these in-application input streams. *
** (see Configuring * Application Input. *
* * @param inputParallelism * Describes the number of in-application streams to create. ** Data from your source is routed to these in-application input streams. *
** (see Configuring * Application Input. */ public void setInputParallelism(InputParallelism inputParallelism) { this.inputParallelism = inputParallelism; } /** *
* Describes the number of in-application streams to create. *
** Data from your source is routed to these in-application input streams. *
** (see Configuring * Application Input. *
* * @return Describes the number of in-application streams to create. ** Data from your source is routed to these in-application input streams. *
** (see Configuring * Application Input. */ public InputParallelism getInputParallelism() { return this.inputParallelism; } /** *
* Describes the number of in-application streams to create. *
** Data from your source is routed to these in-application input streams. *
** (see Configuring * Application Input. *
* * @param inputParallelism * Describes the number of in-application streams to create. ** Data from your source is routed to these in-application input streams. *
** (see Configuring * Application Input. * @return Returns a reference to this object so that method calls can be chained together. */ public Input withInputParallelism(InputParallelism inputParallelism) { setInputParallelism(inputParallelism); return this; } /** *
* Describes the format of the data in the streaming source, and how each data element maps to corresponding columns * in the in-application stream that is being created. *
** Also used to describe the format of the reference data source. *
* * @param inputSchema * Describes the format of the data in the streaming source, and how each data element maps to corresponding * columns in the in-application stream that is being created. ** Also used to describe the format of the reference data source. */ public void setInputSchema(SourceSchema inputSchema) { this.inputSchema = inputSchema; } /** *
* Describes the format of the data in the streaming source, and how each data element maps to corresponding columns * in the in-application stream that is being created. *
** Also used to describe the format of the reference data source. *
* * @return Describes the format of the data in the streaming source, and how each data element maps to corresponding * columns in the in-application stream that is being created. ** Also used to describe the format of the reference data source. */ public SourceSchema getInputSchema() { return this.inputSchema; } /** *
* Describes the format of the data in the streaming source, and how each data element maps to corresponding columns * in the in-application stream that is being created. *
** Also used to describe the format of the reference data source. *
* * @param inputSchema * Describes the format of the data in the streaming source, and how each data element maps to corresponding * columns in the in-application stream that is being created. ** Also used to describe the format of the reference data source. * @return Returns a reference to this object so that method calls can be chained together. */ public Input withInputSchema(SourceSchema inputSchema) { setInputSchema(inputSchema); return this; } /** * Returns a string representation of this object. This is useful for testing and debugging. Sensitive data will be * redacted from this string using a placeholder value. * * @return A string representation of this object. * * @see java.lang.Object#toString() */ @Override public String toString() { StringBuilder sb = new StringBuilder(); sb.append("{"); if (getNamePrefix() != null) sb.append("NamePrefix: ").append(getNamePrefix()).append(","); if (getInputProcessingConfiguration() != null) sb.append("InputProcessingConfiguration: ").append(getInputProcessingConfiguration()).append(","); if (getKinesisStreamsInput() != null) sb.append("KinesisStreamsInput: ").append(getKinesisStreamsInput()).append(","); if (getKinesisFirehoseInput() != null) sb.append("KinesisFirehoseInput: ").append(getKinesisFirehoseInput()).append(","); if (getInputParallelism() != null) sb.append("InputParallelism: ").append(getInputParallelism()).append(","); if (getInputSchema() != null) sb.append("InputSchema: ").append(getInputSchema()); sb.append("}"); return sb.toString(); } @Override public boolean equals(Object obj) { if (this == obj) return true; if (obj == null) return false; if (obj instanceof Input == false) return false; Input other = (Input) obj; if (other.getNamePrefix() == null ^ this.getNamePrefix() == null) return false; if (other.getNamePrefix() != null && other.getNamePrefix().equals(this.getNamePrefix()) == false) return false; if (other.getInputProcessingConfiguration() == null ^ this.getInputProcessingConfiguration() == null) return false; if (other.getInputProcessingConfiguration() != null && other.getInputProcessingConfiguration().equals(this.getInputProcessingConfiguration()) == false) return false; if (other.getKinesisStreamsInput() == null ^ this.getKinesisStreamsInput() == null) return false; if (other.getKinesisStreamsInput() != null && other.getKinesisStreamsInput().equals(this.getKinesisStreamsInput()) == false) return false; if (other.getKinesisFirehoseInput() == null ^ this.getKinesisFirehoseInput() == null) return false; if (other.getKinesisFirehoseInput() != null && other.getKinesisFirehoseInput().equals(this.getKinesisFirehoseInput()) == false) return false; if (other.getInputParallelism() == null ^ this.getInputParallelism() == null) return false; if (other.getInputParallelism() != null && other.getInputParallelism().equals(this.getInputParallelism()) == false) return false; if (other.getInputSchema() == null ^ this.getInputSchema() == null) return false; if (other.getInputSchema() != null && other.getInputSchema().equals(this.getInputSchema()) == false) return false; return true; } @Override public int hashCode() { final int prime = 31; int hashCode = 1; hashCode = prime * hashCode + ((getNamePrefix() == null) ? 0 : getNamePrefix().hashCode()); hashCode = prime * hashCode + ((getInputProcessingConfiguration() == null) ? 0 : getInputProcessingConfiguration().hashCode()); hashCode = prime * hashCode + ((getKinesisStreamsInput() == null) ? 0 : getKinesisStreamsInput().hashCode()); hashCode = prime * hashCode + ((getKinesisFirehoseInput() == null) ? 0 : getKinesisFirehoseInput().hashCode()); hashCode = prime * hashCode + ((getInputParallelism() == null) ? 0 : getInputParallelism().hashCode()); hashCode = prime * hashCode + ((getInputSchema() == null) ? 0 : getInputSchema().hashCode()); return hashCode; } @Override public Input clone() { try { return (Input) super.clone(); } catch (CloneNotSupportedException e) { throw new IllegalStateException("Got a CloneNotSupportedException from Object.clone() " + "even though we're Cloneable!", e); } } @com.amazonaws.annotation.SdkInternalApi @Override public void marshall(ProtocolMarshaller protocolMarshaller) { com.amazonaws.services.kinesisanalytics.model.transform.InputMarshaller.getInstance().marshall(this, protocolMarshaller); } }