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/

Reply via email to