Modifier and Type | Method and Description |
---|---|
void |
PrintSinkOutputWriter.write(IN element,
SinkWriter.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
SinkWriter.write(InputT element,
SinkWriter.Context context)
Adds an element to the writer.
|
Modifier and Type | Method and Description |
---|---|
RequestEntryT |
ElementConverter.apply(InputT element,
SinkWriter.Context context) |
void |
AsyncSinkWriter.write(InputT element,
SinkWriter.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
FileWriter.write(IN element,
SinkWriter.Context context) |
Modifier and Type | Method and Description |
---|---|
software.amazon.awssdk.services.firehose.model.Record |
KinesisFirehoseSinkElementConverter.apply(InputT element,
SinkWriter.Context context) |
Modifier and Type | Method and Description |
---|---|
software.amazon.awssdk.services.kinesis.model.PutRecordsRequestEntry |
KinesisStreamsSinkElementConverter.apply(InputT element,
SinkWriter.Context context) |
Modifier and Type | Method and Description |
---|---|
void |
PulsarWriter.write(IN element,
SinkWriter.Context context) |
Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.