org.apache.pig.data.Tuple.append()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(5.1k)|赞(0)|评价(0)|浏览(64)

本文整理了Java中org.apache.pig.data.Tuple.append()方法的一些代码示例,展示了Tuple.append()的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Tuple.append()方法的具体详情如下:
包路径:org.apache.pig.data.Tuple
类名称:Tuple
方法名:append

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;
}

相关文章