@Override
    public void open(Configuration parameters) throws Exception {
        super.open(parameters);
        this.customerSinkFunc.setRhlClient(extendEs7ApiCallBridge.getRhlClient());
        this.customerSinkFunc.getIndexGenerator().open();
        this.customerSinkFunc.getDynamicIndexCache();
        initMetric();
    }
@description:
@program: flink.sql
@author: lany
@create: 2021/01/04 17:20
elasticsearch7/elasticsearch7-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/MetricElasticsearch7Sink.java