class_docstr: Builder to construct an Elasticsearch 6 compatible ElasticsearchSink.
  
  The following example shows the minimal setup to create a ElasticsearchSink that submits
  actions on checkpoint or the default number of actions was buffered (1000).
  
  Example:
  ::
  
      >>> sink = Elasticsearch6SinkBuilder() \
      ...     .set_hosts('localhost:9200') \
      ...     .set_emitter(ElasticsearchEmitter.static_index("user", "key_col")) \
      ...     .build()
class_docstr_tok: ["Builder","to","construct","an","Elasticsearch","6","compatible","ElasticsearchSink",".","The","following","example","shows","the","minimal","setup","to","create","a","ElasticsearchSink","that","submits","actions","on","checkpoint","or","the","default","number","of","actions","was","buffered","(","1000",")",".","Example",":",":",":",">",">",">","sink","=","Elasticsearch6SinkBuilder","(",")","\\","...",".set_hosts","(","'localhost:9200","'",")","\\","...",".set_emitter","(","ElasticsearchEmitter.static_index","(","``","user","''",",","``","key_col","''",")",")","\\","...",".build","(",")"]
code: def __init__(self):
      self._j_elasticsearch_sink_builder = (
          get_gateway().jvm.org.apache.flink.connector.elasticsearch.sink.Elasticsearch6SinkBuilder()
      )
  
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 Elasticsearch6SinkBuilder object from inherited base classes: ElasticsearchSinkBuilderBase with example: obj = Elasticsearch6SinkBuilder()