org.apache.beam.sdk.io.kinesis

Interface AWSClientsProvider

All Superinterfaces:

java.io.Serializable

public interface AWSClientsProvider
extends java.io.Serializable

Provides instances of AWS clients.

Please note, that any instance of AWSClientsProvider must be Serializable to ensure it can be sent to worker machines.

Method Summary

Modifier and Type	Method and Description
com.amazonaws.services.kinesis.producer.IKinesisProducer	createKinesisProducer(com.amazonaws.services.kinesis.producer.KinesisProducerConfiguration config)
com.amazonaws.services.cloudwatch.AmazonCloudWatch	getCloudWatchClient()
com.amazonaws.services.kinesis.AmazonKinesis	getKinesisClient()

Method Detail

getKinesisClient

com.amazonaws.services.kinesis.AmazonKinesis getKinesisClient()

getCloudWatchClient

com.amazonaws.services.cloudwatch.AmazonCloudWatch getCloudWatchClient()

createKinesisProducer

com.amazonaws.services.kinesis.producer.IKinesisProducer createKinesisProducer(com.amazonaws.services.kinesis.producer.KinesisProducerConfiguration config)