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.