Package org.apache.beam.sdk.io.aws2.kinesis

Class KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder

java.lang.Object

org.apache.beam.sdk.io.aws2.kinesis.KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder

Enclosing class:

KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration

public abstract static class KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder
extends Object

Constructor Summary

Constructors

Constructor	Description
Builder()

Method Summary

Modifier and Type	Method	Description
abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration	build()
abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder	setAggregationEnabled(Boolean aggregationEnabled)
abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder	setAggregationMaxBufferedTime(Long aggregationMaxBufferedTime)
abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder	setAggregationMaxBytes(Long aggregationMaxBytes)
abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder	setAggregationShardRefreshInterval(Long aggregationShardRefreshInterval)
abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder	setAwsAccessKey(String awsAccessKey)
abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder	setAwsSecretKey(String awsSecretKey)
abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder	setPartitionKey(String partitionKey)
abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder	setRegion(String region)
abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder	setServiceEndpoint(String serviceEndpoint)
abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder	setStreamName(String streamName)
abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder	setVerifyCertificate(Boolean verifyCertificate)

Methods inherited from class java.lang.Object

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

Constructor Details

Builder

public Builder()

Method Details

setStreamName

public abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder setStreamName(String streamName)

setAwsAccessKey

public abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder setAwsAccessKey(String awsAccessKey)

setAwsSecretKey

public abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder setAwsSecretKey(String awsSecretKey)

setRegion

public abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder setRegion(String region)

setPartitionKey

public abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder setPartitionKey(String partitionKey)

setServiceEndpoint

public abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder setServiceEndpoint(String serviceEndpoint)

setVerifyCertificate

public abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder setVerifyCertificate(Boolean verifyCertificate)

setAggregationEnabled

public abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder setAggregationEnabled(Boolean aggregationEnabled)

setAggregationMaxBytes

public abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder setAggregationMaxBytes(Long aggregationMaxBytes)

setAggregationMaxBufferedTime

public abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder setAggregationMaxBufferedTime(Long aggregationMaxBufferedTime)

setAggregationShardRefreshInterval

public abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration.Builder setAggregationShardRefreshInterval(Long aggregationShardRefreshInterval)

build

public abstract KinesisWriteSchemaTransformProvider.KinesisWriteSchemaTransformConfiguration build()