@Override
    public boolean check() {
        Preconditions.checkNotNull(address, "elasticsearch7 type of address is required");
        Preconditions.checkNotNull(index, "elasticsearch7 type of index is required");

        if (index_definition != null && !Es7Util.isJson(index_definition)) {
            throw new IllegalArgumentException("elasticsearch7 type of index_definition must be json format!");
        }
        if (isAuthMesh()) {
            Preconditions.checkNotNull(userName, "elasticsearch7 type of userName is required");
            Preconditions.checkNotNull(password, "elasticsearch7 type of password is required");
        }

        return true;
    }
@description:
@program: flink.sql
@author: lany
@create: 2021/01/04 17:19
elasticsearch7/elasticsearch7-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/table/ElasticsearchTableInfo.java