@Override
    public DataStreamSink<?> consumeDataStream(DataStream<Tuple2<Boolean, Row>> dataStream) {
        DataStreamSink dataStreamSink = dataStream.addSink(new OutputFormatSinkFunction(getOutputFormat()))
                .setParallelism(parallelism)
                .name(registerTabName);
        return dataStreamSink;
    }
Reason:
Date: 2018/11/27
Company: www.dtstack.com

@author maqi
rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/AbstractRdbSink.java