com.mozilla.secops

Class SqsIO.Write

java.lang.Object

org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<String>,org.apache.beam.sdk.values.PDone>

com.mozilla.secops.SqsIO.Write

All Implemented Interfaces:

Serializable, org.apache.beam.sdk.transforms.display.HasDisplayData

Enclosing class:

SqsIO

public static class SqsIO.Write
extends org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<String>,org.apache.beam.sdk.values.PDone>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
Write(String queueUrl, String key, String secret, String region) Create new SqsIO write transfrom

Method Summary

Modifier and Type	Method and Description
org.apache.beam.sdk.values.PDone	expand(org.apache.beam.sdk.values.PCollection<String> input)

Methods inherited from class org.apache.beam.sdk.transforms.PTransform

compose, compose, getAdditionalInputs, getDefaultOutputCoder, getName, getResourceHints, populateDisplayData, setResourceHints, toString, validate

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

Write

public Write(String queueUrl,
             String key,
             String secret,
             String region)

Create new SqsIO write transfrom

Parameters:

queueUrl - SQS queue URL

key - AWS access key

secret - AWS secret

region - Region identifier

Method Detail

expand

public org.apache.beam.sdk.values.PDone expand(org.apache.beam.sdk.values.PCollection<String> input)

Specified by:

expand in class org.apache.beam.sdk.transforms.PTransform<org.apache.beam.sdk.values.PCollection<String>,org.apache.beam.sdk.values.PDone>