PutIgniteCache

Deprecation notice:

Apache Ignite 1 is no longer supported

Please consider using one the following alternatives: No alternative components suggested.

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, and whether a property supports the NiFi Expression Language.

Display Name	API Name	Default Value	Allowable Values	Description
Ignite Spring Properties Xml File	ignite-spring-properties-xml-file			Ignite spring configuration file, <path>/<ignite-configuration>.xml. If the configuration file is not provided, default Ignite configuration configuration is used which binds to 127.0.0.1:47500..47509
Ignite Cache Name	ignite-cache-name			The name of the ignite cache
Batch Size For Entries	batch-size-for-entries	250		Batch size for entries (1-500).
Ignite Cache Entry Identifier	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 (will be evaluated using flow file attributes and variable registry)
Data Streamer Per Node Parallel Operations	data-streamer-per-node-parallel-operations	5		Data streamer per node parallelism
Data Streamer Per Node Buffer Size	data-streamer-per-node-buffer-size	250		Data streamer per node buffer size (1-500).
Data Streamer Auto Flush Frequency in millis	data-streamer-auto-flush-frequency-in-millis	10		Data streamer flush interval in millis seconds
Data Streamer Allow Override	data-streamer-allow-override	false	true false	Whether to override values already in the cache

Relationships:

Name	Description
success	All FlowFiles that are written to Ignite cache are routed to this relationship
failure	All FlowFiles that cannot be written to Ignite cache are routed to this relationship

Reads Attributes:

None specified.

Writes Attributes:

Name	Description
ignite.cache.batch.flow.file.total.count	The total number of FlowFile in the batch
ignite.cache.batch.flow.file.item.number	The item number of FlowFile in the batch
ignite.cache.batch.flow.file.successful.number	The successful FlowFile item number
ignite.cache.batch.flow.file.successful.count	The number of successful FlowFiles
ignite.cache.batch.flow.file.failed.number	The failed FlowFile item number
ignite.cache.batch.flow.file.failed.count	The total number of failed FlowFiles in the batch
ignite.cache.batch.flow.file.failed.reason	The failed reason attribute key

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:

Resource	Description
MEMORY	An instance of this component can cause high usage of this system resource. Multiple instances or high concurrency settings may result a degradation of performance.