@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 |
PTransforms 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.
|