Description:
Stream the contents of a FlowFile to Ignite Cache using DataStreamer. The processor uses the value of FlowFile attribute (Ignite cache entry key) as the cache key and the byte array of the FlowFile as the value of the cache entry value. Both the string key and a non-empty byte array value are required otherwise the FlowFile is transferred to the failure relation. Note - The Ignite Kernel periodically outputs node performance statistics to the logs. This message can be turned off by setting the log level for logger ‘org.apache.ignite’ to WARN in the logback.xml configuration file.
Tags:
Ignite, insert, update, stream, write, put, cache, key
Properties:
In the list below, the names of required properties appear in bold. Any other properties (not in bold) are considered optional. The table also indicates any default values, whether a property supports the Expression Language Guide.
Name | Default Value | Allowable Values | Description | ||||||||||||||||||||||||||||||||||||||||||||||||||
Ignite Spring Properties Xml File |
Ignite spring configuration file,
Ignite Cache Name
|
|
|
The name of the ignite cache
|
Batch Size For Entries
|
250
|
|
Batch size for entries (1-500).
|
Ignite Cache Entry Identifier
|
|
|
A FlowFile attribute, or attribute expression used for determining Ignite cache key for the Flow File content |
Supports Expression Language: true
Data Streamer Per Node Parallel Operations
|
|
|
Data streamer per node parallelism
|
Data Streamer Per Node Buffer Size
|
250
|
|
Data streamer per node buffer size (1-500).
|
Data Streamer Auto Flush Frequency in millis
|
10
|
|
Data streamer flush interval in millis seconds
|
Data Streamer Allow Override
|
false
|
*true
*false
|
Whether to override values already in the cache
|
|