本文整理了Java中org.apache.pig.data.Tuple.append()
方法的一些代码示例,展示了Tuple.append()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Tuple.append()
方法的具体详情如下:
包路径:org.apache.pig.data.Tuple
类名称:Tuple
方法名:append
[英]Append a field to a tuple. This method is not efficient as it may force copying of existing data in order to grow the data structure. Whenever possible you should construct your Tuple with TupleFactory#newTuple(int) and then fill in the values with #set(int,Object), rather than construct it with TupleFactory#newTuple() and append values.
[中]将字段附加到元组。这种方法效率不高,因为它可能会强制复制现有数据以增加数据结构。只要有可能,就应该用TupleFactory#newTuple(int)构造元组,然后用#set(int,Object)填充值,而不是用TupleFactory#newTuple()构造元组并附加值。
代码示例来源:origin: apache/phoenix
Tuple t = tupleFactory.newTuple();
t.append(1);
t.append(dt);
t.append(dt);
t.append(dt);
代码示例来源:origin: apache/phoenix
for (int i = 1; i <= rows; i++) {
Tuple t = tupleFactory.newTuple();
t.append(i);
t.append(new DataByteArray(Bytes.toBytes(i * 5)));
t.append(new DataByteArray(Bytes.toBytes(i * 10.0F)));
t.append(new DataByteArray(Bytes.toBytes(i * 15.0D)));
t.append(new DataByteArray(Bytes.toBytes(i)));
t.append(new DataByteArray(Bytes.toBytes( i % 2 == 0)));
t.append(new DataByteArray(Bytes.toBytes(i)));
list.add(t);
代码示例来源:origin: org.apache.pig/pig
@Override
public void append(Object val) {
t.append(val);
}
代码示例来源:origin: org.apache.pig/pig
@Override
public void append(Object val) {
t.append(val);
}
代码示例来源:origin: com.twitter.elephantbird/elephant-bird-pig
@Override
public void append(Object obj) {
realTuple.append(obj);
}
代码示例来源:origin: apache/phoenix
for (int i = 0; i < rows; i++) {
Tuple t = tupleFactory.newTuple();
t.append(i);
t.append("a" + i);
list.add(t);
代码示例来源:origin: apache/phoenix
for (int i = 0; i < rows; i++) {
Tuple t = tupleFactory.newTuple();
t.append(i);
t.append("a" + i);
t.append(i * 2);
list.add(t);
代码示例来源:origin: ShifuML/shifu
private void appendFirstHiddenOutputScore(Tuple tuple, SortedMap<String, Double> hiddenLayerScores, boolean b) {
for(Entry<String, Double> entry: hiddenLayerScores.entrySet()) {
tuple.append(entry.getValue());
}
}
代码示例来源:origin: org.apache.pig/pig
@Override
public Tuple call(Tuple v1, Tuple v2) {
Tuple res = tf.newTuple();
res.append(v1);
res.append(v2);
LOG.info("MergeFunction out:"+res);
return res;
}
}
代码示例来源:origin: org.apache.pig/pig
@Override
public void append(Object val) {
if (appendedFields == null) {
appendedFields = mTupleFactory.newTuple();
}
appendedFields.append(val);
}
代码示例来源:origin: pl.edu.icm.coansys/commons
@Override
public Tuple getNext() throws IOException {
Tuple myTuple = super.getNext();
if (myTuple != null) {
myTuple.append(path.toString());
}
return myTuple;
}
}
代码示例来源:origin: org.apache.pig/pig
@Override
public void addColsToTuple(DataInput in, Tuple t) throws IOException {
byte type = in.readByte();
int sz = getTupleSize(in, type);
for (int i = 0; i < sz; i++) {
t.append(readDatum(in));
}
}
代码示例来源:origin: ShifuML/shifu
/**
* Append model scores into tuple
*
* @param tuple
* - Tuple to append
* @param cs
* - CaseScoreResult
*/
private void appendSimpleScore(Tuple tuple, CaseScoreResult cs) {
for(int i = 0; i < cs.getScores().size(); i++) {
tuple.append(cs.getScores().get(i));
}
}
代码示例来源:origin: pl.edu.icm.coansys/coansys-io-output
@Override
public Tuple exec(Tuple tuple) throws IOException {
if (tuple == null) {
throw new IOException("" + this.getClass().getName() +": null tuple has been passed to UDF!");
}
Tuple ret = tupleFactory.newTuple();
for(int i=1;i<(tuple.size()-1);i++){
ret.append(tuple.get(i));
}
ret.append(tuple.get(0));
return ret;
}
}
代码示例来源:origin: com.linkedin.datafu/datafu
private Tuple extractKey(Tuple tuple) throws ExecException {
Tuple key = tupleFactory.newTuple();
for (String field : fieldNames) {
key.append(getObject(tuple, field));
}
return key;
}
代码示例来源:origin: mozilla-metrics/akela
@Override
public Tuple getNext() throws IOException {
Tuple t = null;
while (reader.nextKeyValue()) {
Text val = reader.getCurrentValue();
if (val != null) {
String line = val.toString();
t = TupleFactory.getInstance().newTuple();
t.append(line);
}
}
return t;
}
代码示例来源:origin: pl.edu.icm.coansys/commons
@Override
public Tuple exec(Tuple input) throws IOException {
Tuple t = TupleFactory.getInstance().newTuple();
t.append(((DataByteArray) input.get(0)).toString());
return t;
}
代码示例来源:origin: org.apache.pig/pig
private Tuple createTuple(Tuple[] data) throws ExecException {
Tuple out = TupleFactory.getInstance().newTuple();
for (int i = 0; i < data.length; ++i) {
Tuple t = data[i];
int size = t.size();
for (int j = 0; j < size; ++j) {
out.append(t.get(j));
}
}
return illustratorMarkup(out, out, 0);
}
代码示例来源:origin: nielsbasjes/yauaa
@Override
public Tuple exec(Tuple tuple) throws IOException {
initialize();
String userAgentString = (String) tuple.get(0);
UserAgent agent = analyzer.parse(userAgentString);
Tuple result = TUPLE_FACTORY.newTuple();
for (String fieldName: requestedFields) {
result.append(agent.getValue(fieldName));
}
return result;
}
代码示例来源:origin: pl.edu.icm.coansys/coansys-io-output
@Override
public Tuple exec(Tuple tuple) throws IOException {
checkCorrectness(tuple);
String rowId = (String) tuple.get(0);
DataByteArray origDocDBA = (DataByteArray) tuple.get(1);
DocumentWrapper.Builder dwb = DocumentWrapper.newBuilder(DocumentWrapper.parseFrom(origDocDBA.get()));
dwb = merger.execute(tuple, 3, dwb);
DataByteArray resultDocDBA = new DataByteArray(dwb.build().toByteArray());
Tuple result = TupleFactory.getInstance().newTuple();
result.append(rowId);
result.append(resultDocDBA);
return result;
}
内容来源于网络,如有侵权,请联系作者删除!