Package com.pulumi.aws.kinesis.outputs

Class AnalyticsApplicationInputs

java.lang.Object

com.pulumi.aws.kinesis.outputs.AnalyticsApplicationInputs

public final class AnalyticsApplicationInputs
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AnalyticsApplicationInputs.Builder

Method Summary

Modifier and Type	Method	Description
static AnalyticsApplicationInputs.Builder	builder()
static AnalyticsApplicationInputs.Builder	builder(AnalyticsApplicationInputs defaults)
java.util.Optional<java.lang.String>	id()
java.util.Optional<AnalyticsApplicationInputsKinesisFirehose>	kinesisFirehose()
java.util.Optional<AnalyticsApplicationInputsKinesisStream>	kinesisStream()
java.lang.String	namePrefix()
java.util.Optional<AnalyticsApplicationInputsParallelism>	parallelism()
java.util.Optional<AnalyticsApplicationInputsProcessingConfiguration>	processingConfiguration()
AnalyticsApplicationInputsSchema	schema()
java.util.List<AnalyticsApplicationInputsStartingPositionConfiguration>	startingPositionConfigurations()
java.util.List<java.lang.String>	streamNames()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Detail

id

public java.util.Optional<java.lang.String> id()

Returns:

ARN of the Kinesis Analytics Application.

kinesisFirehose

public java.util.Optional<AnalyticsApplicationInputsKinesisFirehose> kinesisFirehose()

Returns:

Kinesis Firehose configuration for the streaming source. Conflicts with `kinesisStream`. See `inputs.kinesis_firehose` Block below for details.

kinesisStream

public java.util.Optional<AnalyticsApplicationInputsKinesisStream> kinesisStream()

Returns:

Kinesis Stream configuration for the streaming source. Conflicts with `kinesisFirehose`. See `inputs.kinesis_stream` Block below for details.

namePrefix

public java.lang.String namePrefix()

Returns:

Name Prefix to use when creating an in-application stream.

parallelism

public java.util.Optional<AnalyticsApplicationInputsParallelism> parallelism()

Returns:

Number of Parallel in-application streams to create. See `inputs.parallelism` Block below for details.

processingConfiguration

public java.util.Optional<AnalyticsApplicationInputsProcessingConfiguration> processingConfiguration()

Returns:

Processing Configuration to transform records as they are received from the stream. See `inputs.processing_configuration` Block below for details.

schema

public AnalyticsApplicationInputsSchema schema()

Returns:

Schema format of the data in the streaming source. See `inputs.schema` Block below for details.

startingPositionConfigurations

public java.util.List<AnalyticsApplicationInputsStartingPositionConfiguration> startingPositionConfigurations()

Returns:

Point at which the application starts processing records from the streaming source. See `inputs.starting_position_configuration` Block below for details.

streamNames

public java.util.List<java.lang.String> streamNames()

Returns:

Names of the in-application streams created for the input.

builder

public static AnalyticsApplicationInputs.Builder builder()

builder

public static AnalyticsApplicationInputs.Builder builder(AnalyticsApplicationInputs defaults)