12.4. Record Processors

Record-based processors (PutGeoMesa*Record) accept the following configuration parameters for specifying the input source. Each datastore-specific processor also has additional parameters for connecting to the datastore, detailed in the following sections.

Property Description
Record reader The Record Reader to use for deserializing the incoming data
Feature type name Name to use for the simple feature type schema. If not specified, will use the name from the record schema
Feature ID column Column that will be used as the feature ID. If not specified, a random ID will be used
Geometry columns Column(s) that will be deserialized as geometries, and their type, as a SimpleFeatureType specification string (e.g. the_geom:Point). A ‘*’ can be used to indicate the default geometry column, otherwise it will be the first geometry in the schema
Geometry serialization format The format to use for serializing/deserializing geometries, either WKT or WKB
JSON columns Column(s) that contain valid JSON documents, comma-separated (must be STRING type columns)
Default date column Column to use as the default date attribute (must be a DATE or TIMESTAMP type column)
Visibilities column Column to use for feature visibilities (see Data Security)
Schema user data User data used to configure the GeoMesa SimpleFeatureType, in the form ‘key1=value1,key2=value2’

12.4.1. GeoAvroRecordSetWriterFactory

GeoMesa also provides a record writer that can be used to produce GeoAvro files from any NiFi processor that supports record-based output. The writer factory uses the same properties detailed above.