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

Interface SqsIO.WriteBatches.EntryMapperFn.Builder<T>

All Superinterfaces:

BiConsumer<SendMessageBatchRequestEntry.Builder,T>, BiFunction<String,T,SendMessageBatchRequestEntry>, Serializable, SqsIO.WriteBatches.EntryMapperFn<T>

Enclosing interface:

SqsIO.WriteBatches.EntryMapperFn<T>

public static interface SqsIO.WriteBatches.EntryMapperFn.Builder<T>
extends 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	Description
default SendMessageBatchRequestEntry	apply(String entryId, T msg)

Methods inherited from interface java.util.function.BiConsumer

accept, andThen

Methods inherited from interface java.util.function.BiFunction

andThen

Method Details

apply

default SendMessageBatchRequestEntry apply(String entryId,
 T msg)

Specified by:

apply in interface BiFunction<String,T,SendMessageBatchRequestEntry>