code: public static CsvSchema convert(RowTypeInfo rowType) {
  		final Builder builder = new CsvSchema.Builder();
  		final String[] fields = rowType.getFieldNames();
  		final TypeInformation<?>[] types = rowType.getFieldTypes();
  		for (int i = 0; i < rowType.getArity(); i++) {
  			builder.addColumn(new Column(i, fields[i], convertType(fields[i], types[i])));
  		}
  		return builder.build();
  	}
docs: Convert {@link RowTypeInfo} to {@link CsvSchema}.