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