@Override
    public TypeInformation<Row> getRecordType() {
        return new RowTypeInfo(fieldTypes, fieldNames);
    }
table output elastic5plugin
Date: 2018/7/13
Company: www.dtstack.com
@author huyifan_zju@163.com
elasticsearch5/elasticsearch5-sink/src/main/java/com/dtstack/flink/sql/sink/elasticsearch/ElasticsearchSink.java