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 |
MapElasticsearchEmitter.emit(Map<String,Object> doc,
SinkWriter.Context context,
RequestIndexer indexer) |
void |
ElasticsearchEmitter.emit(T element,
SinkWriter.Context context,
RequestIndexer indexer)
Process the incoming element to produce multiple
ActionRequests . |
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) |
Modifier and Type | Method and Description |
---|---|
void |
ElasticsearchTestEmitter.emit(KeyValue<Integer,String> element,
SinkWriter.Context context,
RequestIndexer indexer) |
Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.