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

x33g5p2x  于2022-01-18 转载在 其他  
字(5.3k)|赞(0)|评价(0)|浏览(152)

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

DataByteArray.toString介绍

[英]Convert the byte array to a string. UTF8 encoding will be assumed.
[中]将字节数组转换为字符串。将采用UTF8编码。

代码示例

代码示例来源:origin: com.twitter.elephantbird/elephant-bird-pig

@Override
protected Text toWritable(DataByteArray value) throws IOException {
 return toWritable(value.toString());
}

代码示例来源:origin: pl.edu.icm.coansys/commons

public static void main(String[] args){
    String s = "bla";
    DataByteArray dba = new DataByteArray();
    dba.set(s.getBytes());
    System.out.println(dba.toString());
  }
}

代码示例来源:origin: org.apache.pig/pig

/**
   * @param context the context the method is being executed in
   * @return        the string representation of the encapsulated DataByteArray
   */
  @JRubyMethod(name = {"to_s", "inspect"})
  public IRubyObject toString(ThreadContext context) {
    return RubyString.newString(context.getRuntime(), internalDBA.toString());
  }
}

代码示例来源:origin: org.apache.pig/pig

return new BigDecimal(((DataByteArray)o).toString());

代码示例来源:origin: org.apache.pig/pig

return Integer.valueOf(((DataByteArray)o).toString());

代码示例来源:origin: org.apache.pig/pig

return Double.valueOf(((DataByteArray)o).toString());

代码示例来源:origin: org.apache.pig/pig

return ((DataByteArray)o).toString();

代码示例来源:origin: org.apache.pig/pig

return new BigInteger(((DataByteArray)o).toString());

代码示例来源:origin: org.apache.pig/pig

return Long.valueOf(((DataByteArray)o).toString());

代码示例来源:origin: org.apache.pig/pig

return null;
case BYTEARRAY:
  return new DateTime(((DataByteArray) o).toString());
case CHARARRAY:

代码示例来源:origin: org.apache.pig/pig

static protected Double sum(Tuple input) throws ExecException, IOException {
  DataBag values = (DataBag)input.get(0);
  // if we were handed an empty bag, return NULL
  if(values == null || values.size() == 0) {
    return null;
  }
  double sum = 0;
  boolean sawNonNull = false;
  for (Iterator<Tuple> it = values.iterator(); it.hasNext();) {
    Tuple t = it.next();
    try{
      DataByteArray dba = (DataByteArray)t.get(0);
      Double d = dba != null ? Double.valueOf(dba.toString()) : null;
      if (d == null) continue;
      sawNonNull = true;
      sum += d;
    }catch(RuntimeException exp) {
      int errCode = 2103;
      String msg = "Problem while computing sum of doubles.";
      throw new ExecException(msg, errCode, PigException.BUG, exp);
    }
  }
  if(sawNonNull) {
    return new Double(sum);
  } else {
    return null;
  }
}

代码示例来源:origin: com.linkedin.datafu/datafu

static protected Double sum(Tuple input) throws ExecException, IOException {
  DataBag values = (DataBag)input.get(0);
  
  // if we were handed an empty bag, return NULL
  if(values.size() == 0) {
    return null;
  }
  double sum = 0;
  boolean sawNonNull = false;
  for (Iterator<Tuple> it = values.iterator(); it.hasNext();) {
    Tuple t = it.next();
    try{
      DataByteArray dba = (DataByteArray)t.get(0);
      Double d = dba != null ? Double.valueOf(dba.toString()) : null;
      if (d == null) continue;
      sawNonNull = true;
      sum += d;
    }catch(RuntimeException exp) {
      int errCode = 2103;
      String msg = "Problem while computing sum of values.";
      throw new ExecException(msg, errCode, PigException.BUG, exp);
    }
  }
  if(sawNonNull) {
    return new Double(sum);
  } else {
    return null;
  }
}

代码示例来源:origin: com.linkedin.datafu/datafu

static protected Double sumSquare(Tuple input) throws ExecException, IOException {
  DataBag values = (DataBag)input.get(0);
  
  // if we were handed an empty bag, return NULL
  if(values.size() == 0) {
    return null;
  }
  double sumSquare = 0;
  boolean sawNonNull = false;
  for (Iterator<Tuple> it = values.iterator(); it.hasNext();) {
    Tuple t = it.next();
    try{
      DataByteArray dba = (DataByteArray)t.get(0);
      Double d = dba != null ? Double.valueOf(dba.toString()) : null;
      if (d == null) continue;
      sawNonNull = true;
      sumSquare += d*d;
    }catch(RuntimeException exp) {
      int errCode = 2103;
      String msg = "Problem while computing sum of squared values.";
      throw new ExecException(msg, errCode, PigException.BUG, exp);
    }
  }
  if(sawNonNull) {
    return new Double(sumSquare);
  } else {
    return null;
  }
}

代码示例来源:origin: org.apache.pig/pig

return Float.valueOf(((DataByteArray)o).toString());

代码示例来源: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

@Override
  public Tuple exec(Tuple input) throws IOException {
    // Initial is called in the map.
    // we just send the tuple down
    try {
      // input is a bag with one tuple containing
      // the column we are trying to operate on
      DataBag bg = (DataBag) input.get(0);
      if (bg.iterator().hasNext()) {
        DataByteArray dba = (DataByteArray) bg.iterator().next().get(0);
        Double d = dba != null ? Double.valueOf(dba.toString()): null;
        return tfact.newTuple(d);
      } else {
        // make sure that we call the object constructor, not the list constructor
        return tfact.newTuple((Object) null);
      }
    } catch (ExecException e) {
      throw e;
    } catch (Exception e) {
      int errCode = 2106;
      throw new ExecException("Error executing an algebraic function", errCode, PigException.BUG, e);
    }
  }
}

代码示例来源:origin: org.apache.pig/pig

return (String) v + "0";
case DataType.BYTEARRAY:
  String str = ((DataByteArray) v).toString();
  str = str + "0";
  return new DataByteArray(str);

代码示例来源:origin: org.apache.pig/pig

dba = (DataByteArray)tp.get(0);
t.set(0, dba != null ? Double.valueOf(dba.toString()) : null);
if (dba == null)
  t.set(1, 0L);

代码示例来源:origin: com.linkedin.datafu/datafu

Double d = dba !=null ? Double.valueOf(dba.toString()) : null;
if (dba == null){
  t.set(0, null);

代码示例来源:origin: org.apache.pig/pig

case DataType.BYTEARRAY:
  DataByteArray dba = (DataByteArray)t.get(0);
  d = dba != null ? Double.valueOf(dba.toString()): null;
  break;
case DataType.DOUBLE:

相关文章

微信公众号

最新文章

更多