import geotrellis.spark._
import geotrellis.spark.io._
import geotrellis.spark.io.geomesa._
val instance: GeoMesaInstance(
tableName = ...,
instanceName = ...,
zookeepers = ...,
users = ...,
password = ...,
useMock = ...
)
val reader = new GeoMesaFeatureReader(instance)
val writer = new GeoMesaFeatureWriter(instance)
val id: LayerId = ...
val query: Query = ... /* GeoMesa query type */
val spatialFeatureType: SimpleFeatureType = ... /* from geomesa - see their docs */
/* for some generic D, following GeoTrellis `Feature[G, D]` */
val res: RDD[SimpleFeature] = reader.read[Point, D](
id,
spatialFeatureType,
query
)
-
Notifications
You must be signed in to change notification settings - Fork 0
License
geotrellis/geotrellis-geomesa
Folders and files
Name | Name | Last commit message | Last commit date | |
---|---|---|---|---|
Repository files navigation
About
No description, website, or topics provided.
Resources
License
Stars
Watchers
Forks
Releases
No releases published
Packages 0
No packages published