support geo for reader (#11)

Nicole00 · web-flow · commit 2632f1d0e12a · 2021-10-29T15:43:40.000+08:00
diff --git a/nebula-spark-connector/src/main/scala/com/vesoft/nebula/connector/reader/NebulaPartitionReader.scala b/nebula-spark-connector/src/main/scala/com/vesoft/nebula/connector/reader/NebulaPartitionReader.scala
@@ -106,6 +106,9 @@ abstract class NebulaPartitionReader extends InputPartitionReader[InternalRow] {
       if (value.isDouble) {
         getters(i).apply(value.asDouble(), mutableRow, i)
       }
+      if (value.isGeography) {
+        getters(i).apply(value.asGeography(), mutableRow, i)
+      }
     }
     mutableRow
   }

Original file line number	Diff line number	Diff line change
`@@ -106,6 +106,9 @@ abstract class NebulaPartitionReader extends InputPartitionReader[InternalRow] {`
`106`	`106`	`if (value.isDouble) {`
`107`	`107`	`getters(i).apply(value.asDouble(), mutableRow, i)`
`108`	`108`	`}`
	`109`	`+ if (value.isGeography) {`
	`110`	`+ getters(i).apply(value.asGeography(), mutableRow, i)`
	`111`	`+ }`
`109`	`112`	`}`
`110`	`113`	`mutableRow`
`111`	`114`	`}`