IGNITE-425: Implementation of ContinuousQueryWithTransformer
authorNikolay Izhikov <nizhikov@apache.org>
Thu, 8 Feb 2018 11:51:32 +0000 (14:51 +0300)
committerNikolay Izhikov <nizhikov@apache.org>
Thu, 8 Feb 2018 11:51:32 +0000 (14:51 +0300)
commita83f3038a9424a5eb826cf35da8d22496a551b50
treef2c61129c2e12609e4214b1eeadb460960770405
parentc917327b74b3dbcb65b961277f5d2c99a71b7a8a
IGNITE-425: Implementation of ContinuousQueryWithTransformer
17 files changed:
modules/core/src/main/java/org/apache/ignite/cache/query/AbstractContinuousQuery.java [new file with mode: 0644]
modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQuery.java
modules/core/src/main/java/org/apache/ignite/cache/query/ContinuousQueryWithTransformer.java [new file with mode: 0644]
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/IgniteCacheProxyImpl.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryEntry.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandler.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandlerV2.java
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryHandlerV3.java [new file with mode: 0644]
modules/core/src/main/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryManager.java
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousQueryRandomOperationsTest.java
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousWithTransformerClientSelfTest.java [new file with mode: 0644]
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousWithTransformerFailoverTest.java [new file with mode: 0644]
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousWithTransformerLocalSelfTest.java [new file with mode: 0644]
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousWithTransformerPartitionedSelfTest.java [new file with mode: 0644]
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousWithTransformerRandomOperationsTest.java [new file with mode: 0644]
modules/core/src/test/java/org/apache/ignite/internal/processors/cache/query/continuous/CacheContinuousWithTransformerReplicatedSelfTest.java [new file with mode: 0644]
modules/indexing/src/test/java/org/apache/ignite/testsuites/IgniteCacheQuerySelfTestSuite3.java