我在Apache PIG中具有以下关系。
TSERIES: {ORDERED: {(timestamp: long,contentHost: chararray)},ts1: long}
我要执行以下操作:
F = foreach TSERIES {
ts = filter ORDERED by timestamp > TSERIES.ts1;
generate ts;
}
简而言之,我想让bag ORDERED的所有元素的时间戳映射都高于ts1,
但Pig不允许,特别是这部分
ts = filter ORDERED by timestamp > TSERIES.ts1;
。这可能吗?我正在使用
0.9.2-cdh4.0.1
版本(cloudera)。 最佳答案
您是否尝试过:
测试=筛选器tseries By(ordered.timestamp> ts1);