- 使用 Spring Initializr 创建 Spring Boot 应用程序
- 在Spring Boot中配置Cassandra
- 在 Spring Boot 上配置 Tomcat 连接池
- 将Camel消息路由到嵌入WildFly的Artemis上
本文整理了Java中org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableStringObjectInspector.getPrimitiveJavaObject()
方法的一些代码示例,展示了WritableStringObjectInspector.getPrimitiveJavaObject()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。WritableStringObjectInspector.getPrimitiveJavaObject()
方法的具体详情如下:
包路径:org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableStringObjectInspector
类名称:WritableStringObjectInspector
方法名:getPrimitiveJavaObject
暂无
代码示例来源:origin: apache/hive
private static SampleRec deserializeInner(Object row, StructObjectInspector inspector) {
List<? extends StructField> fields = inspector.getAllStructFieldRefs();
WritableStringObjectInspector f0ins = (WritableStringObjectInspector) fields.get(0).getFieldObjectInspector();
WritableIntObjectInspector f1ins = (WritableIntObjectInspector) fields.get(1).getFieldObjectInspector();
WritableStringObjectInspector f2ins = (WritableStringObjectInspector) fields.get(2).getFieldObjectInspector();
String f0 = f0ins.getPrimitiveJavaObject(inspector.getStructFieldData(row, fields.get(0)));
int f1 = f1ins.get(inspector.getStructFieldData(row, fields.get(1)));
String f2 = f2ins.getPrimitiveJavaObject(inspector.getStructFieldData(row, fields.get(2)));
return new SampleRec(f0, f1, f2);
}
代码示例来源:origin: apache/hive
private static SampleRec deserializeInner(Object row, StructObjectInspector inspector) {
List<? extends StructField> fields = inspector.getAllStructFieldRefs();
WritableStringObjectInspector f0ins = (WritableStringObjectInspector) fields.get(0).getFieldObjectInspector();
WritableIntObjectInspector f1ins = (WritableIntObjectInspector) fields.get(1).getFieldObjectInspector();
WritableStringObjectInspector f2ins = (WritableStringObjectInspector) fields.get(2).getFieldObjectInspector();
String f0 = f0ins.getPrimitiveJavaObject(inspector.getStructFieldData(row, fields.get(0)));
int f1 = f1ins.get(inspector.getStructFieldData(row, fields.get(1)));
String f2 = f2ins.getPrimitiveJavaObject(inspector.getStructFieldData(row, fields.get(2)));
return new SampleRec(f0, f1, f2);
}
代码示例来源:origin: apache/hive
return object;
} else {
return ((WritableStringObjectInspector) objectInspector).getPrimitiveJavaObject(object);
代码示例来源:origin: Quetzal-RDF/quetzal
postMethod.setParameter(inputColumns.get(i),
PrimitiveObjectInspectorFactory.writableStringObjectInspector
.getPrimitiveJavaObject(arg0[i]));
代码示例来源:origin: org.apache.hivemall/hivemall-core
@Override
public void merge(@SuppressWarnings("deprecation") AggregationBuffer agg, Object partial)
throws HiveException {
if (partial == null) {
return;
}
Object tpObj = internalMergeOI.getStructFieldData(partial, tpField);
Object totalActualObj = internalMergeOI.getStructFieldData(partial, totalActualField);
Object totalPredictedObj =
internalMergeOI.getStructFieldData(partial, totalPredictedField);
Object betaObj = internalMergeOI.getStructFieldData(partial, betaOptionField);
Object averageObj = internalMergeOI.getStructFieldData(partial, averageOptionFiled);
long tp = PrimitiveObjectInspectorFactory.writableLongObjectInspector.get(tpObj);
long totalActual =
PrimitiveObjectInspectorFactory.writableLongObjectInspector.get(totalActualObj);
long totalPredicted = PrimitiveObjectInspectorFactory.writableLongObjectInspector.get(
totalPredictedObj);
double beta =
PrimitiveObjectInspectorFactory.writableDoubleObjectInspector.get(betaObj);
String average =
PrimitiveObjectInspectorFactory.writableStringObjectInspector.getPrimitiveJavaObject(
averageObj);
FMeasureAggregationBuffer myAggr = (FMeasureAggregationBuffer) agg;
myAggr.merge(tp, totalActual, totalPredicted, beta, average);
}
我正在编写一个自定义 Hive UDF,以根据属性文件中定义的值解析 Map 中的键/值对。格式为 validate(Map, String)。目的是让第一个参数是要评估的 Map,第二个参数包含属性
我正在尝试为复杂对象类型编写自定义可写类型 - 以控制序列化和反序列化。 我想为此创建一个 ObjectInspector,我试图找到一个相同的示例。但是没有合适的例子。 最佳答案 我认为您不需要为此
这两个包有什么区别: org.apache.hadoop.hive.serde2.objectinspector org.apache.hadoop.hive.serde2.typeinfo 有一个是
本文整理了Java中org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableStringObjectInspector类的一些代
本文整理了Java中org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableConstantIntObjectInspector
本文整理了Java中org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableByteObjectInspector类的一些代码示
我收到这些组件 TreeView、ObjectInspector、ConnectedTreeNode 的 PropTypes 验证器直接不受支持 警告>、ObjectRootLabel、ObjectP
本文整理了Java中org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableStringObjectInspector.crea
本文整理了Java中org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableStringObjectInspector.getP
本文整理了Java中org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableStringObjectInspector.getP
本文整理了Java中org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableConstantIntObjectInspector
本文整理了Java中org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableConstantIntObjectInspector
本文整理了Java中org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableByteObjectInspector.get()方
本文整理了Java中org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableByteObjectInspector.create
本文整理了Java中org.apache.hadoop.hive.serde2.objectinspector.primitive.WritableByteObjectInspector.precis
我是一名优秀的程序员,十分优秀!