本文整理汇总了Java中org.apache.pig.data.InternalSortedBag类的典型用法代码示例。如果您正苦于以下问题:Java InternalSortedBag类的具体用法?Java InternalSortedBag怎么用?Java InternalSortedBag使用的例子?那么恭喜您, 这里精选的类代码示例或许可以为您提供帮助。
InternalSortedBag类属于org.apache.pig.data包,在下文中一共展示了InternalSortedBag类的1个代码示例,这些例子默认根据受欢迎程度排序。您可以为喜欢或者感觉有用的代码点赞,您的评价将有助于我们的系统推荐出更棒的Java代码示例。
示例1: getNextTuple
import org.apache.pig.data.InternalSortedBag; //导入依赖的package包/类
@Override
public Result getNextTuple() throws ExecException {
Result res = new Result();
if (!inputsAccumulated) {
res = processInput();
if (!initialized) {
initialized = true;
if (PigMapReduce.sJobConfInternal.get() != null) {
String bagType = PigMapReduce.sJobConfInternal.get().get(PigConfiguration.PIG_CACHEDBAG_SORT_TYPE);
if (bagType != null && bagType.equalsIgnoreCase("default")) {
useDefaultBag = true;
}
}
}
// by default, we create InternalSortedBag, unless user configures
// explicitly to use old bag
sortedBag = useDefaultBag ? BagFactory.getInstance().newSortedBag(mComparator)
: new InternalSortedBag(3, mComparator);
while (res.returnStatus != POStatus.STATUS_EOP) {
if (res.returnStatus == POStatus.STATUS_ERR) {
log.error("Error in reading from the inputs");
return res;
} else if (res.returnStatus == POStatus.STATUS_NULL) {
// Ignore and read the next tuple.
res = processInput();
continue;
}
sortedBag.add((Tuple) res.result);
res = processInput();
}
inputsAccumulated = true;
}
if (it == null) {
it = sortedBag.iterator();
}
if (it.hasNext()) {
res.result = it.next();
illustratorMarkup(res.result, res.result, 0);
res.returnStatus = POStatus.STATUS_OK;
} else {
res.returnStatus = POStatus.STATUS_EOP;
reset();
}
return res;
}
开发者ID:sigmoidanalytics,项目名称:spork,代码行数:50,代码来源:POSort.java
注:本文中的org.apache.pig.data.InternalSortedBag类示例整理自Github/MSDocs等源码及文档管理平台,相关代码片段筛选自各路编程大神贡献的开源项目,源码版权归原作者所有,传播和使用请参考对应项目的License;未经允许,请勿转载。 |
请发表评论