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

Interface SqsIO.WriteBatches.EntryMapperFn.Builder<T>

All Superinterfaces:

java.util.function.BiConsumer<SendMessageBatchRequestEntry.Builder,T>, java.util.function.BiFunction<java.lang.String,T,SendMessageBatchRequestEntry>, java.io.Serializable, SqsIO.WriteBatches.EntryMapperFn<T>

Enclosing interface:

SqsIO.WriteBatches.EntryMapperFn<T>

public static interface SqsIO.WriteBatches.EntryMapperFn.Builder<T>
extends java.util.function.BiConsumer<SendMessageBatchRequestEntry.Builder,T>, SqsIO.WriteBatches.EntryMapperFn<T>

A more convenient SqsIO.WriteBatches.EntryMapperFn variant that already sets the entry id.

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.beam.sdk.io.aws2.sqs.SqsIO.WriteBatches.EntryMapperFn

SqsIO.WriteBatches.EntryMapperFn.Builder<T>

Method Summary

Modifier and Type	Method and Description
default SendMessageBatchRequestEntry	apply(java.lang.String entryId, T msg)

Methods inherited from interface java.util.function.BiConsumer

accept, andThen

Methods inherited from interface java.util.function.BiFunction

andThen

Method Detail

apply

default SendMessageBatchRequestEntry apply(java.lang.String entryId,
                                           T msg)

Specified by:

apply in interface java.util.function.BiFunction<java.lang.String,T,SendMessageBatchRequestEntry>