pyflink.datastream.connectors.elasticsearch.ElasticsearchEmitter

class ElasticsearchEmitter(j_emitter)

Emitter which is used by sinks to prepare elements for sending them to Elasticsearch.

Methods

dynamic_index(index_field[, key_field, doc_type])	Creates an emitter with dynamic index which is invoked on every record to convert it to Elasticsearch actions.
static_index(index[, key_field, doc_type])	Creates an emitter with static index which is invoked on every record to convert it to Elasticsearch actions.