More progress.

Signed-off-by: Jim Hughes <[email protected]>
locationtech · Mar 10, 2021 · 64c2fd0 · 64c2fd0
1 parent 4148a1c
commit 64c2fd0
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 2 deletions.
diff --git a/...udu-spark/src/main/scala/org/locationtech/geomesa/kudu/spark/GeoMesaKuduInputFormat.scala b/...udu-spark/src/main/scala/org/locationtech/geomesa/kudu/spark/GeoMesaKuduInputFormat.scala
@@ -71,7 +71,7 @@ class GeoMesaKuduInputFormat extends InputFormat[NullWritable, SimpleFeature] wi
       val sft = ds.getSchema(typeName)
       val query = new Query(typeName)
       filter.map(FastFilterFactory.toFilter(sft, _)).foreach(query.setFilter)
-      query.setPropertyNames(properties)
+      query.setPropertyNames(properties: _*)
 
       val plans = ds.getQueryPlan(query).filter(_.ranges.nonEmpty)
 

diff --git a/...da-datastore/src/main/scala/org/locationtech/geomesa/lambda/stream/kafka/KafkaStore.scala b/...da-datastore/src/main/scala/org/locationtech/geomesa/lambda/stream/kafka/KafkaStore.scala
@@ -111,7 +111,7 @@ class KafkaStore(ds: DataStore,
                     explain: Explainer = new ExplainLogging): CloseableIterator[SimpleFeature] = {
     val query = new Query()
     filter.foreach(query.setFilter)
-    transforms.foreach(query.setPropertyNames)
+    transforms.foreach(query.setPropertyNames(_: _*))
     hints.foreach(query.setHints) // note: we want to share the hints object
     queryRunner.runQuery(sft, query, explain)
   }