@Override
    public DataStreamSink<?> consumeDataStream(DataStream<Tuple2<Boolean, Row>> dataStream) {
        ImpalaOutputFormat outputFormat = buildImpalaOutputFormat();
        RichSinkFunction richSinkFunction = new OutputFormatSinkFunction(outputFormat);
        DataStreamSink dataStreamSink = dataStream.addSink(richSinkFunction)
                .setParallelism(parallelism)
                .name(tableName);
        return dataStreamSink;
    }
build Impala Jdbc Url according to authMech

@param impalaTableInfo impala table info
@return jdbc url with auth mech info
impala/impala-sink/src/main/java/com/dtstack/flink/sql/sink/impala/ImpalaSink.java