如果架构中的所有字段都有相同的前缀集（例如group1:：id、group1:：amount等），则在引用特定字段时可以忽略前缀（仅将它们引用为id、amount等）
或者，如果您仍然希望去掉一个前缀级别的模式，您可以使用如下自定义项：

public class RemoveGroupFromTupleSchema extends EvalFunc<Tuple> {
@Override
public Tuple exec(Tuple input) throws IOException {
    Tuple result = input;
    return result;
}
@Override
public Schema outputSchema(Schema input) throws FrontendException {
    if(input.size() != 1) {
        throw new RuntimeException("Expected input (tuple) but input does not have 1 field");
    }
    List<Schema.FieldSchema> inputSchema = input.getFields();
    List<Schema.FieldSchema> outputSchema = new ArrayList<Schema.FieldSchema>(inputSchema);
    for(int i = 0; i < inputSchema.size(); i++) {
        Schema.FieldSchema thisInputFieldSchema = inputSchema.get(i);
        String inputFieldName = thisInputFieldSchema.alias;
        Byte dataType = thisInputFieldSchema.type;
        String outputFieldName;
        int findLoc = inputFieldName.indexOf("::");
        if(findLoc == -1) {
            outputFieldName = inputFieldName;
        }
        else {
            outputFieldName = inputFieldName.substring(findLoc+2);
        }
        Schema.FieldSchema thisOutputFieldSchema = new Schema.FieldSchema(outputFieldName, dataType);
        outputSchema.set(i, thisOutputFieldSchema);
    }
    return new Schema(outputSchema);
}
}

您可以将'as'语句与'foreach'放在同一行。
即

my_data_grouped = group my_data by some_column;
my_data_grouped = filter my_data_grouped by <some expression>;
my_data = FOREACH my_data_grouped FLATTEN(my_data) AS (c1, c2, c3);

但是，这与在两行上执行相同，并不能缓解“具有可变列的数据集”的问题。