HiveTableSchemas.putForName(conf, dbName, tableName, tableSchema);
HiveTableSchemas.putForProfile(conf, profileId, tableSchema);
Function<String, Integer> columnNameToId = new Function<String, Integer>() {
@Override public Integer apply(String input) {
return tableSchema.positionOf(input);
}
};
List<Integer> columnIds = transform(inputDesc.getColumns(), columnNameToId);
InputInfo inputInfo = new InputInfo(tableSchema, columnIds);