class_docstr: Emitter which is used by sinks to prepare elements for sending them to Elasticsearch.
class_docstr_tok: ["Emitter","which","is","used","by","sinks","to","prepare","elements","for","sending","them","to","Elasticsearch","."]
code: def __init__(self, j_emitter):
      self._j_emitter = j_emitter
  
imports: import abc
  from enum import Enum
  from typing import List, Union
  from pyflink.datastream.connectors import Sink, DeliveryGuarantee
  from pyflink.java_gateway import get_gateway
  from pyflink.util.java_utils import to_jarray
label_desc: Use image node_id 1 to create a new ElasticsearchEmitter object from inherited base classes: object with example: obj = ElasticsearchEmitter(j_emitter)