本文整理了Java中org.apache.pig.data.DataByteArray.toString()
方法的一些代码示例,展示了DataByteArray.toString()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。DataByteArray.toString()
方法的具体详情如下:
包路径:org.apache.pig.data.DataByteArray
类名称: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:
内容来源于网络,如有侵权,请联系作者删除!