org.apache.spark.sql.Row.getJavaMap()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(1.9k)|赞(0)|评价(0)|浏览(246)

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

Row.getJavaMap介绍

暂无

代码示例

代码示例来源:origin: cloudera-labs/envelope

@Override
public <K, V> Map<K, V> getJavaMap(int arg0) {
 return internalRow.getJavaMap(arg0);
}

代码示例来源:origin: org.apache.spark/spark-sql_2.11

Seq<Integer> outputBuffer = (Seq<Integer>) first.getJavaMap(2).get("hello");
Assert.assertArrayEquals(
 bean.getC().get("hello"),

代码示例来源:origin: org.apache.spark/spark-sql_2.10

Seq<Integer> outputBuffer = (Seq<Integer>) first.getJavaMap(2).get("hello");
Assert.assertArrayEquals(
 bean.getC().get("hello"),

代码示例来源:origin: org.apache.spark/spark-sql

Seq<Integer> outputBuffer = (Seq<Integer>) first.getJavaMap(2).get("hello");
Assert.assertArrayEquals(
 bean.getC().get("hello"),

代码示例来源:origin: Netflix/iceberg

break;
case MAP:
 record.put(i, convert(field.schema(), row.getJavaMap(i)));
 break;
default:

代码示例来源:origin: cdapio/cdap

builder.set(field.getName(), fromRowValue(row.getList(idx), fieldSchema, fieldPath));
} else if (fieldSchema.getType() == Schema.Type.MAP) {
 builder.set(field.getName(), fromRowValue(row.getJavaMap(idx), fieldSchema, fieldPath));
} else {
 Object fieldValue = row.get(idx);

代码示例来源:origin: cdapio/cdap

builder.set(field.getName(), fromRowValue(row.getList(idx), fieldSchema, fieldPath));
} else if (fieldSchema.getType() == Schema.Type.MAP) {
 builder.set(field.getName(), fromRowValue(row.getJavaMap(idx), fieldSchema, fieldPath));
} else {
 Object fieldValue = row.get(idx);

代码示例来源:origin: co.cask.cdap/cdap-api-spark2

builder.set(field.getName(), fromRowValue(row.getList(idx), fieldSchema, fieldPath));
} else if (fieldSchema.getType() == Schema.Type.MAP) {
 builder.set(field.getName(), fromRowValue(row.getJavaMap(idx), fieldSchema, fieldPath));
} else {
 Object fieldValue = row.get(idx);

相关文章