Package org.apache.beam.sdk.io.aws2.sqs

Interface SqsIO.WriteBatches.EntryMapperFn<T>

All Superinterfaces:

BiFunction<String,T,SendMessageBatchRequestEntry>, Serializable

All Known Subinterfaces:

SqsIO.WriteBatches.EntryMapperFn.Builder<T>

Enclosing class:

SqsIO.WriteBatches<T>

public static interface SqsIO.WriteBatches.EntryMapperFn<T>
extends BiFunction<String,T,SendMessageBatchRequestEntry>, Serializable

Mapper to create a SendMessageBatchRequestEntry from a unique batch entry id and the input T.

Nested Class Summary

Nested Classes

Modifier and Type	Interface	Description
static interface	SqsIO.WriteBatches.EntryMapperFn.Builder<T>	A more convenient SqsIO.WriteBatches.EntryMapperFn variant that already sets the entry id.

Method Summary

Methods inherited from interface java.util.function.BiFunction

andThen, apply