@Override
    public BulkProcessor.Builder createBulkProcessorBuilder(TransportClient client, BulkProcessor.Listener listener) {
        return BulkProcessor.builder(client, listener);
    }
@date 2019/11/16
@author xiuzhu
@Company: www.dtstack.com
elasticsearch5-xh/elasticsearch5-xh-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/ExtendES5ApiCallBridge.java