pyflink.datastream.connectors.elasticsearch.ElasticsearchEmitter#
- class ElasticsearchEmitter(j_emitter)[source]#
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.