I think I have already done that in my custom sink.
@Override
public String[] getFieldNames() {
return this.fieldNames;
}
@Override
public TypeInformation<?>[] getFieldTypes() {
return this.fieldTypes;
}
@Override
public TableSink<Row> configure(String[] fieldNames, TypeInformation<?>[]
fieldTypes) {
this.fieldNames = fieldNames;
this.fieldTypes = fieldTypes;
return this;
}
--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/
