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.