RecordReaderFactory
Implementations: CSVReader
JsonPathReader
AvroReader
CEFReader
Syslog5424Reader
JsonTreeReader
WindowsEventLogReader
XMLReader
SyslogReader
JASN1Reader
ReaderLookup
ParquetReader
GrokReader
ScriptedReader
YamlTreeReader
ExcelReader
Specifies the Controller Service to use for parsing incoming data and determining the data's schema | Redis Connection Pool | redis-connection-pool | | Controller Service API: RedisConnectionPool Implementation: RedisConnectionPoolService | No Description Provided. |
Hash Value Record Path | hash-value-record-path | | | Specifies a RecordPath to evaluate against each Record in order to determine the hash value associated with all the record fields/values (see 'hset' in Redis documentation for more details). The RecordPath must point at exactly one field or an error will occur. |
Data Record Path | data-record-path | / | | This property denotes a RecordPath that will be evaluated against each incoming Record and the Record that results from evaluating the RecordPath will be sent to Redis instead of sending the entire incoming Record. The property defaults to the root '/' which corresponds to a 'flat' record (all fields/values at the top level of the Record. |
Character Set | charset | UTF-8 | | Specifies the character set to use when storing record field values as strings. All fields will be converted to strings using this character set before being stored in Redis. Supports Expression Language: true (will be evaluated using flow file attributes and Environment variables) |
Relationships:
Name | Description |
---|
success | FlowFiles having all Records stored in Redis will be routed to this relationship |
failure | FlowFiles containing Records with processing errors will be routed to this relationship |
Reads Attributes:
None specified.Writes Attributes:
Name | Description |
---|
redis.success.record.count | Number of records written to Redis |
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.