12.4. 唱片处理机

基于记录的处理器 (PutGeoMesaRecord )接受以下配置参数以指定输入源:

属性

描述

Record reader

用于反序列化传入数据的记录读取器

Feature type name

用于简单要素类型架构的名称。如果未指定,将使用记录架构中的名称

Feature ID column

将用作要素ID的列。如果未指定,将使用随机ID

Geometry columns

列(S),该列将被反序列化为几何,并将其类型反序列化为SimpleFeatureType规范字符串(例如 the_geom:Point )。可使用‘*’表示默认几何列,否则它将是方案中的第一个几何

Geometry serialization format

用于序列化/反序列化几何的格式,可以是 WKTWKB

JSON columns

包含有效JSON文档的列(S),用逗号分隔(必须是字符串类型的列)

Default date column

用作默认日期属性的列(必须是日期或时间戳类型的列)

Visibilities column

用于要素可见性的列(请参见 数据安全 )

Schema user data

用于配置GeoMesa SimpleFeatureType的用户数据,格式为‘key1=value1,key2=value2’

12.4.1. GeoAvroRecordSetWriterFactory

GeoMesa还提供了一个记录写入器,可用于从任何支持基于记录的输出的NiFi处理器生成GeoAvro文件。编写器工厂使用上面详细说明的相同属性。