RecordReaderFactory
Implementations: JsonPathReader
AvroReader
XMLReader
WindowsEventLogReader
ReaderLookup
Syslog5424Reader
GrokReader
ScriptedReader
CSVReader
SyslogReader
ParquetReader
JsonTreeReader
CEFReader
Specifies the Controller Service to use for reading incoming data | Record Writer | | Controller Service API: RecordSetWriterFactory Implementations: AvroRecordSetWriter ScriptedRecordSetWriter JsonRecordSetWriter ParquetRecordSetWriter RecordSetWriterLookup FreeFormTextRecordSetWriter XMLRecordSetWriter CSVRecordSetWriter | Specifies the Controller Service to use for writing out the records |
Lookup Service | | Controller Service API: LookupService Implementations: SimpleScriptedLookupService RestLookupService CouchbaseKeyValueLookupService HBase_2_RecordLookupService SimpleCsvFileLookupService CouchbaseRecordLookupService ElasticSearchStringLookupService PropertiesFileLookupService KuduLookupService IPLookupService ScriptedLookupService HBase_1_1_2_RecordLookupService XMLFileLookupService SimpleKeyValueLookupService DatabaseRecordLookupService CSVRecordLookupService SimpleDatabaseLookupService MongoDBLookupService DistributedMapCacheLookupService HBase_1_1_2_ListLookupService ElasticSearchLookupService | The Lookup Service to use in order to lookup a value in each Record |
Result RecordPath | | | A RecordPath that points to the field whose value should be updated with whatever value is returned from the Lookup Service. If not specified, the value that is returned from the Lookup Service will be ignored, except for determining whether the FlowFile should be routed to the 'matched' or 'unmatched' Relationship. Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
Routing Strategy | route-to-success | - Route to 'success'
- Route to 'matched' or 'unmatched'
| Specifies how to route records after a Lookup has completed |
Record Result Contents | insert-entire-record | - Insert Entire Record
- Insert Record Fields
| When a result is obtained that contains a Record, this property determines whether the Record itself is inserted at the configured path or if the contents of the Record (i.e., the sub-fields) will be inserted at the configured path. |
Record Update Strategy | use-property | - Replace Existing Values
- Use Property
| This property defines the strategy to use when updating the record with the value returned by the Lookup Service. |
Dynamic Properties:
Dynamic Properties allow the user to specify both the name and value of a property.
Name | Value | Description |
---|
Value To Lookup | Valid Record Path | A RecordPath that points to the field whose value will be looked up in the configured Lookup Service Supports Expression Language: true (will be evaluated using flow file attributes and variable registry) |
Relationships:
Name | Description |
---|
success | All records will be sent to this Relationship if configured to do so, unless a failure occurs |
failure | If a FlowFile cannot be enriched, the unchanged FlowFile will be routed to this relationship |
Reads Attributes:
None specified.Writes Attributes:
Name | Description |
---|
mime.type | Sets the mime.type attribute to the MIME Type specified by the Record Writer |
record.count | The number of records in the FlowFile |
State management:
This component does not store state.Restricted:
This component is not restricted.Input requirement:
This component requires an incoming relationship.System Resource Considerations:
None specified.See Also:
ConvertRecord, SplitRecord, SimpleKeyValueLookupService, IPLookupService, DatabaseRecordLookupService