GridGain Module Documentation Reference

Name

String

The name for this configuration. Connectors reference the configuration with this name.

Connection

The connection types that can be provided to this configuration.

Send Correlation Id

Whether to specify a correlationId when publishing messages. This applies both for custom correlation ids specifies at the operation level and for default correlation Ids taken from the current event

AUTO

Expiration Policy

Configures the minimum amount of time that a dynamic configuration instance can remain idle before the runtime considers it eligible for expiration. This does not mean that the platform will expire the instance at the exact moment that it becomes eligible. The runtime will actually purge the instances when it sees it fit.

Configuration

String

The name of the configuration to use.

Atomic Long

Atomic object's name

Value to add

Value to add

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Long

Atomic object's name

Expected value

Expected value

New value if current value == expected value

New value if current value == expected value

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Long

Atomic object's name

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Long

Atomic object's name

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Long

Atomic object's name

Value to add

Value to add

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Long

Atomic object's name

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Long

Atomic object's name

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Long

Atomic object's name

Value to set

Value to set

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Long

Atomic object's name

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Reference

Atomic object's name

Expected value

New value if current value == expected value

Serialize before compare

Flag to specify if the value must be serialized before being set

false

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Reference

Atomic object's name

Deserialize after get

Flag to specify if the value must be deserialized after being read

false

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Reference

Atomic object's name

Value

#[payload]

Serialize before set

Flag to specify if the value must be serialized before being set

false

Reconnection Strategy

A retry strategy in case of connectivity errors

Configuration

String

The name of the configuration to use.

Atomic Sequence

Atomic object's name

Value to add

Value to add

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Sequence

Atomic object's name

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Sequence

Atomic object's name

Value to add

Value to add

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Sequence

Atomic object's name

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Sequence

Atomic object's name

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Stamped

Atomic object's name

Expected value

New value if current value == expected value

#[payload]

Expected stamp

New stamp if current stamp == expected stamp

Serialize before compare and set

Flag to specify if value and stamp must be serialized before being set

false

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Stamped

Atomic object's name

Deserialize after get

Flag to specify if the stamp must be deserialized after being read

false

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Stamped

Atomic object's name

Deserialize after get

Flag to specify if the value must be deserialized after being read

false

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Atomic Stamped

Atomic object's name

Value

#[payload]

Stamp

Serialize before set

Flag to specify if value and stamp must be serialized before being set

false

Reconnection Strategy

A retry strategy in case of connectivity errors

Configuration

String

The name of the configuration to use.

Cache

the cache's name

Reconnection Strategy

A retry strategy in case of connectivity errors

Configuration

String

The name of the configuration to use.

Cache

the cache's name

Cache entry key

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Cache

the cache's name

Cache entry key

Deserialize after get

flag to specify it the value must be serialized after being get from the cache

false

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Cache

the target cache into store data

Data provider

External reference to a com.hawkore.ignite.extensions.api.ingestion.ICacheDataProvider implementation

Number of ingesters

The amount of concurrent ingesters to be placed on the dataProvider. Be careful, dataProvider must be thread-safe if this number is > 1. As the number of ingesters increases, so does the speed on which ingestion process pushes messages into the cache

1

Async

If true does not wait for ingestion to finish

false

Allow Overwrite

if true and cache key exists then data will be overwritten

false

Batch size

Increase ingestion performance in batch mode by setting a batch size

1000

Auto-flush frequency (ms)

If this value is equals or less than 0, autoflush will be disabled and flush will be performed after the ingestion of every batch package

0

Serialize before put

if data must be serialized before store it

false

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Cache

the cache's name

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Cache

the cache's name

Cache entry key

Cache entry value

#[payload]

Expiry Policy

expiry Policy

ACCESSED_EXPIRY_POLICY

Entry TTL (⇐0 never expires)

entry TTL %lt;=0 never expires

0

Entry TTL unit

entry TTL unit

SECONDS

Serialize before put

flag to specify it the value must be serialized before being put into the cache

false

Async

execute operation asynchronously

false

Reconnection Strategy

A retry strategy in case of connectivity errors

Configuration

String

The name of the configuration to use.

Cache

the cache's name

Cache entry key

Async

execute operation asynchronously

false

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Cache

the cache's name

Cache entry key

Cache entry value expected

Cache entry value

Serialize before replace

flag to specify it the value must be serialized before being put into the cache

false

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Cache

the cache's name

Cache entry key

Cache entry value

#[payload]

Serialize before replace

flag to specify it the value must be serialized before being put into the cache

false

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Countdown latch

The name of the countdown latch

Timeout

Max time to wait: timeout < 0 wait forever, timeout = 0 do not wait, timeout > 0 wait the specified time.

60

Timeout unit

the timeout unit

SECONDS

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Countdown latch

The name of the countdown latch

Amount to decrease

Amount to decrease. -1 all, >0 amount to decrease

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Lock

The name of the Lock

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Query entity

Table to query, on ignite or SQL format (examples: mycache_myqueryentity, "MyCache".MyQueryEntity

Max results

Maximun entry count at result list

1024

Query on local node only

If this query should be executed on local node only. Useful if local node is an affinity node (server node)

false

Text query

Query to execute in lucene format (for example: name: Eva). If not present, results will not be filtered.

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Query

The sql statement. Ignite DML and DDL subset commands are fully supported. Example: select * from "MyCache".MyQueryEntity T where T.oneNumber = ? and T.someText = ? and T.oneDate < ?

Query parameters

List of ordered parameters (?) to replace on sql statement

Filters

List of filters that will be applied with AND restriction to select statement query after, if any, defined statement filters (List of com.hawkore.ignite.extensions.api.query.pagination.Filter)

Sorts

Order by for select statement, will be applied to select statement after, if any, defined order by items (List of com.hawkore.ignite.extensions.api.query.pagination.Sort)

Page

Page for select statement (com.hawkore.ignite.extensions.api.query.pagination.Page)

Distributed joins allowed

Specify if distributed joins are enabled for this query

false

Query is over replicated tables only

The query contains only replicated tables. This is a hint for potentially more effective execution

false

Query is collocated

Collocation flag is used for optimization purposes of queries with GROUP BY statements, when data is collocated and you group by collocated key (primary or affinity key)

false

Lazy data retrieval

By default (lazy=false) Ignite attempts to fetch the whole query result set to memory and send it to the client. For small and medium result sets this to false provides optimal performance and minimize duration of internal database locks, thus increasing concurrency. If resulset is big, use this flag as a hint for Ignite to fetch result set lazily from an iterable collection wrapping an ignite QueryCursor (note that this 'lazy' collection's size will have real size only when underline cursor was fully fetched, so initial size is 0), thus minimizing memory consumption at the cost of moderate performance hit

false

Query on local node only

If this query should be executed on local node only. Useful if local node is an affinity node (server node)

false

Enforce join order

Sets flag to enforce join order of tables in the query. If set to true query optimizer will not reorder tables in join. Leave it to false unless you are a SQL expert

false

Timeout

Zero value disables timeout. Query will be automatically cancelled if the execution timeout is exceeded

0

Timeout unit

timeout unit

SECONDS

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Queue

the queue configuration

Timeout

Max time to wait: timeout < 0 wait forever, timeout = 0 do not wait, timeout > 0 wait the specified time.

60

Timeout unit

timeout unit

SECONDS

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Attributes Type

Configuration

String

The name of the configuration to use.

Queue

the target queue into store data

Data provider

External reference to a com.hawkore.ignite.extensions.api.ingestion.IQueueDataProvider implementation

Number of ingesters

The amount of concurrent ingesters to be placed on the dataProvider. Be careful, dataProvider must be thread-safe if this number is > 1. As the number of ingesters increases, so does the speed on which ingestion process pushes messages into the queue

1

Async

If true does not wait for ingestion to finish

false

Batch size

Increase ingestion performance in batch mode by setting a batch size

1000

Send Correlation Id

outbound Correlation Strategy

Correlation id

Custom correlation Id

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Queue

The queue's name

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Queue

the queue configuration

Item to publish

Timeout

Max time to wait: timeout < 0 wait forever, timeout = 0 do not wait, timeout > 0 wait the specified time.

60

Timeout unit

timeout unit

SECONDS

Send Correlation Id

options on whether to include an outbound correlation id or not

Correlation id

allows to set a custom correlation id

Reconnection Strategy

A retry strategy in case of connectivity errors

Configuration

String

The name of the configuration to use.

Queue

the queue configuration

Item to publish

Timeout

Max time to wait: timeout < 0 wait forever, timeout = 0 do not wait, timeout > 0 wait the specified time.

60

Timeout unit

timeout unit

SECONDS

Send Correlation Id

options on whether to include an outbound correlation id or not

Correlation id

allows to set a custom correlation id

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Attributes Type

Configuration

String

The name of the configuration to use.

Scheduler task id

task identifier (a.k.a. uuid from scheduler id)

Enabled on start

if scheduler is enabled on flow start. If false, manual activation will be required throught 'Scheduler - start' operation

true

Allow concurrent execution

if enabled, same flow will be run on all cluster nodes at scheduled time

false

Scheduler strategy

scheduler strategy

Reconnection Strategy

A retry strategy in case of connectivity errors

Configuration

String

The name of the configuration to use.

Scheduler task id

task identifier (a.k.a. uuid from scheduler id)

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Scheduler task id

task identifier (a.k.a. uuid from scheduler id)

Reconnection Strategy

A retry strategy in case of connectivity errors

Configuration

String

The name of the configuration to use.

Scheduler task id

task identifier (a.k.a. uuid from scheduler id)

Reconnection Strategy

A retry strategy in case of connectivity errors

Configuration

String

The name of the configuration to use.

Scheduler task id

task identifier (a.k.a. uuid from scheduler id)

Reconnection Strategy

A retry strategy in case of connectivity errors

Configuration

String

The name of the configuration to use.

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Semaphore

semaphore's name

Permits to acquire

permits to acquire, must be greater than zero

Timeout

Max time to wait: timeout < 0 wait forever, timeout = 0 do not wait, timeout > 0 wait the specified time.

60

Timeout unit

timeout unit

SECONDS

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type

Configuration

String

The name of the configuration to use.

Semaphore

semaphore's name

Target Variable

The name of a variable on which the operation's output will be placed

Target Value

An expression that will be evaluated against the operation's output and the outcome of that expression will be stored in the target variable

#[payload]

Reconnection Strategy

A retry strategy in case of connectivity errors

Type