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

Class KinesisTransformRegistrar.WriteBuilder.Configuration

java.lang.Object

org.apache.beam.sdk.io.aws2.kinesis.KinesisTransformRegistrar.WriteBuilder.Configuration

Enclosing class:

KinesisTransformRegistrar.WriteBuilder

public static class KinesisTransformRegistrar.WriteBuilder.Configuration
extends Object

Constructor Summary

Constructors

Constructor	Description
Configuration()

Method Summary

Modifier and Type	Method	Description
void	setAggregationEnabled(@Nullable Boolean aggregationEnabled)
void	setAggregationMaxBufferedTime(Long aggregationMaxBufferedTime)
void	setAggregationMaxBytes(Long aggregationMaxBytes)
void	setAggregationShardRefreshInterval(Long aggregationShardRefreshInterval)
void	setAwsAccessKey(String awsAccessKey)
void	setAwsSecretKey(String awsSecretKey)
void	setPartitionKey(String partitionKey)
void	setRegion(String region)
void	setServiceEndpoint(@Nullable String serviceEndpoint)
void	setStreamName(String streamName)
void	setVerifyCertificate(@Nullable Boolean verifyCertificate)

Methods inherited from class java.lang.Object

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

Constructor Details

Configuration

public Configuration()

Method Details

setPartitionKey

public void setPartitionKey(String partitionKey)

setStreamName

public void setStreamName(String streamName)

setAwsAccessKey

public void setAwsAccessKey(String awsAccessKey)

setAwsSecretKey

public void setAwsSecretKey(String awsSecretKey)

setRegion

public void setRegion(String region)

setServiceEndpoint

public void setServiceEndpoint(@Nullable String serviceEndpoint)

setVerifyCertificate

public void setVerifyCertificate(@Nullable Boolean verifyCertificate)

setAggregationEnabled

public void setAggregationEnabled(@Nullable Boolean aggregationEnabled)

setAggregationMaxBytes

public void setAggregationMaxBytes(Long aggregationMaxBytes)

setAggregationMaxBufferedTime

public void setAggregationMaxBufferedTime(Long aggregationMaxBufferedTime)

setAggregationShardRefreshInterval

public void setAggregationShardRefreshInterval(Long aggregationShardRefreshInterval)