@Override
    public void open(Configuration parameters) throws Exception {
        super.open(parameters);
        Elasticsearch7SideTableInfo tableInfo = (Elasticsearch7SideTableInfo) sideInfo.getSideTableInfo();
        rhlClient = Es7Util.getClient(tableInfo.getAddress(),
                tableInfo.isAuthMesh(),
                tableInfo.getUserName(),
                tableInfo.getPassword());
        searchRequest = Es7Util.setSearchRequest(sideInfo);
    }
@description:
@program: flink.sql
@author: lany
@create: 2021/01/11 11:21
elasticsearch7/elasticsearch7-side/elasticsearch7-async-side/src/main/java/com/dtstack/flink/sql/side/elasticsearch7/Elasticsearch7AsyncReqRow.java