@Internal public class KinesisStreamsSinkElementConverter<InputT> extends Object implements ElementConverter<InputT,software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>
ElementConverter
that uses the AWS Kinesis SDK v2. The user only
needs to provide a SerializationSchema
of the InputT
and a PartitionKeyGenerator
lambda to transform the input element into a String.Modifier and Type | Class and Description |
---|---|
static class |
KinesisStreamsSinkElementConverter.Builder<InputT>
A builder for the KinesisStreamsSinkElementConverter.
|
Modifier and Type | Method and Description |
---|---|
software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry |
apply(InputT element,
SinkWriter.Context context) |
static <InputT> KinesisStreamsSinkElementConverter.Builder<InputT> |
builder() |
public software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry apply(InputT element, SinkWriter.Context context)
apply
in interface ElementConverter<InputT,software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry>
public static <InputT> KinesisStreamsSinkElementConverter.Builder<InputT> builder()
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.