@Experimental(value=SOURCE_SINK)
See: Description
Interface | Description |
---|---|
SnsAsyncClientProvider |
Provides instances of Asynchronous SNS client.
|
SnsClientProvider |
Provides instances of SNS client.
|
Class | Description |
---|---|
PublishResponseCoder |
Custom Coder for handling publish result.
|
SnsCoderProviderRegistrar |
A
CoderProviderRegistrar for standard types used with SnsIO . |
SnsIO |
PTransform s for writing to SNS. |
SnsIO.RetryConfiguration |
A POJO encapsulating a configuration for retry behavior when issuing requests to SNS.
|
SnsIO.Write<T> |
Implementation of
SnsIO.write() . |
SnsIO.WriteAsync<T> |
Implementation of
SnsIO.writeAsync() . |
Exception | Description |
---|---|
SnsIO.SnsWriteException |
Exception class for SNS write exceptions.
|