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

Interface SqsIO.WriteBatches.EntryMapperFn<T>

All Superinterfaces:

java.util.function.BiFunction<java.lang.String,T,SendMessageBatchRequestEntry>, java.io.Serializable

All Known Subinterfaces:

SqsIO.WriteBatches.EntryMapperFn.Builder<T>

Enclosing class:

SqsIO.WriteBatches<T>

public static interface SqsIO.WriteBatches.EntryMapperFn<T>
extends java.util.function.BiFunction<java.lang.String,T,SendMessageBatchRequestEntry>, java.io.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 and 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