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","."]
docstr: Creates an emitter with static index which is invoked on every record to convert it to
  Elasticsearch actions.
code: def static_index(
      index: str, key_field: str = None, doc_type: str = None
  ) -> "ElasticsearchEmitter":
      """
      Creates an emitter with static index which is invoked on every record to convert it to
      Elasticsearch actions.
      """
      JMapElasticsearchEmitter = (
          get_gateway().jvm.org.apache.flink.connector.elasticsearch.sink.MapElasticsearchEmitter
      )
      j_emitter = JMapElasticsearchEmitter(
          index, doc_type, key_field, False
      )
      return ElasticsearchEmitter(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 2 for calling the ElasticsearchEmitter obj's underlying member method code with example usage: obj.static_index(index, key_field, doc_type) and returns: ElasticsearchEmitter