本文整理了Java中cascading.tuple.Tuple.append()
方法的一些代码示例,展示了Tuple.append()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Tuple.append()
方法的具体详情如下:
包路径:cascading.tuple.Tuple
类名称:Tuple
方法名:append
[英]Method append appends all the values of the given Tuple instances to a copy of this instance.
[中]方法append将给定元组实例的所有值追加到此实例的副本。
代码示例来源:origin: cwensel/cascading
@Override
public Tuple makeResult( Tuple input, Tuple output )
{
return input.get( incomingFields, remainderFields ).append( output );
}
};
代码示例来源:origin: LiveRamp/cascading_ext
private Tuple createResultTuple(Tuple key, T aggregate) {
return key.append(definition.getPartialAggregator().toPartialTuple(aggregate));
}
}
代码示例来源:origin: LiveRamp/cascading_ext
protected void emit(Tuple result) {
call.getOutputCollector().add(closure.getGrouping().append(result));
}
代码示例来源:origin: LiveRamp/cascading_ext
public Tuple getAggregateTuple() {
return key.getTuple().append(definition.getFinalAggregator().toFinalTuple(aggregate));
}
代码示例来源:origin: cwensel/cascading
/**
* Method appendNew appends the given TupleEntry instance to this instance.
*
* @param entry of type TupleEntry
* @return TupleEntry
*/
public TupleEntry appendNew( TupleEntry entry )
{
Fields appendedFields = fields.append( entry.fields.isUnknown() ? Fields.size( entry.tuple.size() ) : entry.fields );
Tuple appendedTuple = tuple.append( entry.tuple );
return new TupleEntry( appendedFields, appendedTuple );
}
代码示例来源:origin: cwensel/cascading
result = entry.getTuple();
else
result = result.append( entry.getTuple() );
内容来源于网络,如有侵权,请联系作者删除!