@Override
            public AbstractTableInfo getTableInfo(String tableName, String fieldsInfo, Map<String, Object> props) throws Exception {
                return null;
            }
Company: www.dtstack.com

@author zhufeng
@date 2020-06-22
elasticsearch6/elasticsearch6-sink/src/test/java/com/dtstack/flink/sql/sink/elasticsearch/table/ElasticsearchSinkParserTest.java