private String buildPartitionCondition(ImpalaSideTableInfo impalaSideTableInfo) {
        String partitionCondtion = " ";
        String[] partitionfields = impalaSideTableInfo.getPartitionfields();
        String[] partitionFieldTypes = impalaSideTableInfo.getPartitionFieldTypes();
        Map<String, List> partitionVaules = impalaSideTableInfo.getPartitionValues();

        int fieldsSize = partitionfields.length;
        for (int i = 0; i < fieldsSize; i++) {
            String fieldName = partitionfields[i];
            String fieldType = partitionFieldTypes[i];
            List values = partitionVaules.get(fieldName);
            String partitionVaule = getPartitionVaule(fieldType, values);
            partitionCondtion += String.format("AND %s IN (%s) ", fieldName, partitionVaule);
        }
        return partitionCondtion;
    }
Date: 2019/11/12
Company: www.dtstack.com

@author xiuzhu
impala/impala-side/impala-async-side/src/main/java/com/dtstack/flink/sql/side/impala/ImpalaAsyncSideInfo.java