public abstract static class SqsIO.Write extends PTransform<PCollection<SendMessageRequest>,PDone>
PTransform
to send messages to SQS. See SqsIO
for more information on usage
and configuration.name
Constructor and Description |
---|
Write() |
Modifier and Type | Method and Description |
---|---|
PDone |
expand(PCollection<SendMessageRequest> input)
Override this method to specify how this
PTransform should be expanded on the given
InputT . |
SqsIO.Write |
withSqsClientProvider(AwsCredentialsProvider credentialsProvider,
java.lang.String region)
Specify
AwsCredentialsProvider and region to
be used to write to SQS. |
SqsIO.Write |
withSqsClientProvider(AwsCredentialsProvider credentialsProvider,
java.lang.String region,
java.net.URI serviceEndpoint)
Specify
AwsCredentialsProvider and region to be used to write to SQS. |
SqsIO.Write |
withSqsClientProvider(SqsClientProvider awsClientsProvider)
Allows to specify custom
SqsClientProvider . |
compose, compose, getAdditionalInputs, getDefaultOutputCoder, getDefaultOutputCoder, getDefaultOutputCoder, getKindString, getName, populateDisplayData, toString, validate
public SqsIO.Write withSqsClientProvider(SqsClientProvider awsClientsProvider)
SqsClientProvider
. SqsClientProvider
creates new
SqsClient
which is later used for writing to a SqS queue.public SqsIO.Write withSqsClientProvider(AwsCredentialsProvider credentialsProvider, java.lang.String region)
AwsCredentialsProvider
and region to
be used to write to SQS. If you need more sophisticated credential protocol, then you should
look at withSqsClientProvider(SqsClientProvider)
.public SqsIO.Write withSqsClientProvider(AwsCredentialsProvider credentialsProvider, java.lang.String region, java.net.URI serviceEndpoint)
AwsCredentialsProvider
and region to be used to write to SQS. If you need
more sophisticated credential protocol, then you should look at withSqsClientProvider(SqsClientProvider)
.
The serviceEndpoint
sets an alternative service host. This is useful to execute
the tests with Kinesis service emulator.
public PDone expand(PCollection<SendMessageRequest> input)
PTransform
PTransform
should be expanded on the given
InputT
.
NOTE: This method should not be called directly. Instead apply the PTransform
should
be applied to the InputT
using the apply
method.
Composite transforms, which are defined in terms of other transforms, should return the output of one of the composed transforms. Non-composite transforms, which do not apply any transforms internally, should return a new unbound output and register evaluators (via backend-specific registration methods).
expand
in class PTransform<PCollection<SendMessageRequest>,PDone>