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