public class ElasticsearchTestEmitter extends Object implements ElasticsearchEmitter<KeyValue<Integer,String>>
Constructor and Description |
---|
ElasticsearchTestEmitter(UpdateRequestFactory factory)
Instantiates a new Elasticsearch test emitter.
|
Modifier and Type | Method and Description |
---|---|
void |
emit(KeyValue<Integer,String> element,
SinkWriter.Context context,
RequestIndexer indexer)
Process the incoming element to produce multiple
ActionRequests . |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
close, open
public ElasticsearchTestEmitter(UpdateRequestFactory factory)
factory
- The factory for creating UpdateRequest
s.public void emit(KeyValue<Integer,String> element, SinkWriter.Context context, RequestIndexer indexer)
ElasticsearchEmitter
ActionRequests
. The
produced requests should be added to the provided RequestIndexer
.emit
in interface ElasticsearchEmitter<KeyValue<Integer,String>>
element
- incoming element to processcontext
- to access additional information about the recordindexer
- request indexer that ActionRequest
should be added toCopyright © 2014–2023 The Apache Software Foundation. All rights reserved.