in src/main/java/com/aliyun/emr/example/spark/SparkMaxComputeJavaDemo.java [61:67]
public List<Long> call(Record record, TableSchema schema) throws Exception {
List<Long> ret = new ArrayList<Long>();
for (int i = 0; i < schema.getColumns().size(); i++) {
ret.add(record.getBigint(i));
}
return ret;
}