This is an automated email from the ASF dual-hosted git repository. av pushed a commit to branch ignite-ducktape in repository https://gitbox.apache.org/repos/asf/ignite.git
commit 3d955e15c9f261b2a7a5551ec2baa1facc649163 Merge: 281458e 08475e2 Author: Anton Vinogradov <a...@apache.org> AuthorDate: Tue Oct 20 10:54:22 2020 +0300 Merge remote-tracking branch 'origin/master' into ignite-ducktape CONTRIBUTING.md | 2 +- README.txt | 14 +- assembly/dependencies-apache-ignite-slim.xml | 1 - assembly/libs/README.txt | 1 - bin/control.bat | 50 +- bin/control.sh | 41 +- bin/ignite.bat | 9 +- config/apache-ignite-slim/default-config.xml | 29 + config/visor-cmd/node_startup_by_ssh.sample.ini | 2 +- docs/.gitignore | 5 + docs/Gemfile | 14 + docs/README.adoc | 212 ++ docs/_config.yml | 46 + docs/_data/toc.yaml | 559 ++++ docs/_docs/SQL/JDBC/error-codes.adoc | 81 + docs/_docs/SQL/JDBC/jdbc-client-driver.adoc | 297 ++ docs/_docs/SQL/JDBC/jdbc-driver.adoc | 649 +++++ docs/_docs/SQL/ODBC/connection-string-dsn.adoc | 255 ++ docs/_docs/SQL/ODBC/data-types.adoc | 38 + docs/_docs/SQL/ODBC/error-codes.adoc | 155 + docs/_docs/SQL/ODBC/odbc-driver.adoc | 343 +++ docs/_docs/SQL/ODBC/querying-modifying-data.adoc | 491 ++++ docs/_docs/SQL/ODBC/specification.adoc | 1090 ++++++++ docs/_docs/SQL/custom-sql-func.adoc | 49 + docs/_docs/SQL/distributed-joins.adoc | 110 + docs/_docs/SQL/indexes.adoc | 357 +++ docs/_docs/SQL/schemas.adoc | 94 + docs/_docs/SQL/sql-api.adoc | 352 +++ docs/_docs/SQL/sql-introduction.adoc | 53 + docs/_docs/SQL/sql-transactions.adoc | 87 + docs/_docs/SQL/sql-tuning.adoc | 471 ++++ .../binary-client-protocol.adoc | 286 ++ .../binary-type-metadata.adoc | 421 +++ .../cache-configuration.adoc | 714 +++++ docs/_docs/binary-client-protocol/data-format.adoc | 1072 +++++++ .../binary-client-protocol/key-value-queries.adoc | 1416 ++++++++++ .../sql-and-scan-queries.adoc | 634 +++++ docs/_docs/clustering/baseline-topology.adoc | 159 ++ docs/_docs/clustering/clustering.adoc | 51 + docs/_docs/clustering/connect-client-nodes.adoc | 106 + docs/_docs/clustering/discovery-in-the-cloud.adoc | 270 ++ docs/_docs/clustering/network-configuration.adoc | 185 ++ .../running-client-nodes-behind-nat.adoc | 47 + docs/_docs/clustering/tcp-ip-discovery.adoc | 426 +++ docs/_docs/clustering/zookeeper-discovery.adoc | 193 ++ .../_docs/code-deployment/deploying-user-code.adoc | 96 + docs/_docs/code-deployment/peer-class-loading.adoc | 166 ++ docs/_docs/code-snippets/cpp/src/affinity_run.cpp | 148 + .../cpp/src/cache_asynchronous_execution.cpp | 128 + .../cpp/src/cache_atomic_operations.cpp | 54 + .../cpp/src/cache_creating_dynamically.cpp | 37 + docs/_docs/code-snippets/cpp/src/cache_get_put.cpp | 58 + .../cpp/src/cache_getting_instance.cpp | 38 + docs/_docs/code-snippets/cpp/src/city.h | 69 + docs/_docs/code-snippets/cpp/src/city_key.h | 76 + .../cpp/src/compute_acessing_data.cpp | 134 + .../code-snippets/cpp/src/compute_broadcast.cpp | 136 + docs/_docs/code-snippets/cpp/src/compute_call.cpp | 151 + .../code-snippets/cpp/src/compute_call_async.cpp | 165 ++ docs/_docs/code-snippets/cpp/src/compute_get.cpp | 38 + docs/_docs/code-snippets/cpp/src/compute_run.cpp | 147 + .../code-snippets/cpp/src/concurrent_updates.cpp | 60 + .../code-snippets/cpp/src/continuous_query.cpp | 87 + .../cpp/src/continuous_query_filter.cpp | 167 ++ .../cpp/src/continuous_query_listener.cpp | 76 + docs/_docs/code-snippets/cpp/src/country.h | 74 + docs/_docs/code-snippets/cpp/src/invoke.cpp | 156 ++ .../cpp/src/key_value_execute_sql.cpp | 55 + .../code-snippets/cpp/src/key_value_object_key.cpp | 52 + docs/_docs/code-snippets/cpp/src/person.h | 94 + docs/_docs/code-snippets/cpp/src/scan_query.cpp | 53 + .../cpp/src/setting_work_directory.cpp | 32 + docs/_docs/code-snippets/cpp/src/sql.cpp | 56 + docs/_docs/code-snippets/cpp/src/sql_create.cpp | 40 + .../_docs/code-snippets/cpp/src/sql_join_order.cpp | 33 + .../code-snippets/cpp/src/start_stop_nodes.cpp | 45 + .../code-snippets/cpp/src/thin_authentication.cpp | 44 + .../code-snippets/cpp/src/thin_client_cache.cpp | 46 + .../code-snippets/cpp/src/thin_client_ssl.cpp | 39 + .../cpp/src/thin_creating_client_instance.cpp | 42 + .../cpp/src/thin_partition_awareness.cpp | 46 + docs/_docs/code-snippets/cpp/src/transactions.cpp | 78 + .../cpp/src/transactions_pessimistic.cpp | 52 + .../code-snippets/dotnet/AffinityCollocation.cs | 141 + .../_docs/code-snippets/dotnet/BaselineTopology.cs | 49 + .../code-snippets/dotnet/BasicCacheOperations.cs | 93 + docs/_docs/code-snippets/dotnet/ClusterGroups.cs | 89 + .../code-snippets/dotnet/ClusteringOverview.cs | 58 + .../dotnet/ClusteringTcpIpDiscovery.cs | 132 + .../dotnet/CollocationgComputationsWithData.cs | 161 ++ .../code-snippets/dotnet/ConfiguringMetrics.cs | 86 + .../code-snippets/dotnet/ContiniuosQueries.cs | 116 + .../dotnet/DataModellingConfiguringCaches.cs | 103 + .../dotnet/DataModellingDataPartitioning.cs | 53 + docs/_docs/code-snippets/dotnet/DataRebalancing.cs | 67 + docs/_docs/code-snippets/dotnet/DataStreaming.cs | 224 ++ docs/_docs/code-snippets/dotnet/DefiningIndexes.cs | 187 ++ .../dotnet/DistributedComputingApi.cs | 284 ++ .../_docs/code-snippets/dotnet/EvictionPolicies.cs | 114 + docs/_docs/code-snippets/dotnet/ExpiryPolicies.cs | 60 + docs/_docs/code-snippets/dotnet/IgniteLifecycle.cs | 53 + docs/_docs/code-snippets/dotnet/MapReduceApi.cs | 158 ++ .../code-snippets/dotnet/MemoryArchitecture.cs | 79 + docs/_docs/code-snippets/dotnet/NearCaches.cs | 118 + docs/_docs/code-snippets/dotnet/OnHeapCaching.cs | 35 + .../_docs/code-snippets/dotnet/PeerClassLoading.cs | 52 + .../code-snippets/dotnet/PerformingTransactions.cs | 152 + .../dotnet/PersistenceIgnitePersistence.cs | 82 + .../code-snippets/dotnet/PersistenceTuning.cs | 95 + docs/_docs/code-snippets/dotnet/PlatformCache.cs | 120 + docs/_docs/code-snippets/dotnet/SqlJoinOrder.cs | 38 + docs/_docs/code-snippets/dotnet/SqlTransactions.cs | 102 + docs/_docs/code-snippets/dotnet/ThinClient.cs | 351 +++ .../dotnet/UnderstandingConfiguration.cs | 51 + .../code-snippets/dotnet/UnderstandingSchemas.cs | 38 + .../_docs/code-snippets/dotnet/UsingScanQueries.cs | 82 + docs/_docs/code-snippets/dotnet/UsingSqlApi.cs | 211 ++ .../dotnet/WorkingWithBinaryObjects.cs | 142 + .../code-snippets/dotnet/WorkingWithEvents.cs | 183 ++ docs/_docs/code-snippets/dotnet/dotnet.csproj | 11 + docs/_docs/code-snippets/java/pom.xml | 146 + .../snippets/AffinityCollocationExample.java | 150 + .../org/apache/ignite/snippets/BackupFilter.java | 39 + .../ignite/snippets/BasicCacheOperations.java | 139 + .../ignite/snippets/CacheJdbcPersonStore.java | 121 + .../org/apache/ignite/snippets/ClientNodes.java | 81 + .../org/apache/ignite/snippets/ClusterAPI.java | 118 + .../apache/ignite/snippets/ClusteringOverview.java | 80 + .../ignite/snippets/CollocatedComputations.java | 184 ++ .../apache/ignite/snippets/ComputeTaskExample.java | 81 + .../apache/ignite/snippets/ConfiguringCaches.java | 104 + .../apache/ignite/snippets/ConfiguringMetrics.java | 169 ++ .../apache/ignite/snippets/CustomThreadPool.java | 69 + .../apache/ignite/snippets/DataPartitioning.java | 67 + .../snippets/DataRegionConfigurationExample.java | 71 + .../org/apache/ignite/snippets/DataStreaming.java | 179 ++ .../org/apache/ignite/snippets/DataStructures.java | 222 ++ .../java/org/apache/ignite/snippets/Discovery.java | 42 + .../ignite/snippets/DiscoveryInTheCloud.java | 151 + .../apache/ignite/snippets/DiskCompression.java | 57 + .../ignite/snippets/DistributedComputing.java | 197 ++ .../java/org/apache/ignite/snippets/Events.java | 188 ++ .../apache/ignite/snippets/EvictionPolicies.java | 164 ++ .../org/apache/ignite/snippets/ExpiryPolicies.java | 68 + .../apache/ignite/snippets/ExternalStorage.java | 169 ++ .../org/apache/ignite/snippets/FailureHandler.java | 55 + .../org/apache/ignite/snippets/FaultTolerance.java | 65 + .../ignite/snippets/IgniteExecutorService.java | 56 + .../apache/ignite/snippets/IgniteLifecycle.java | 76 + .../apache/ignite/snippets/IgnitePersistence.java | 113 + .../java/org/apache/ignite/snippets/Indexes.java | 159 ++ .../org/apache/ignite/snippets/Indexes_groups.java | 37 + .../apache/ignite/snippets/JDBCClientDriver.java | 80 + .../org/apache/ignite/snippets/JDBCThinDriver.java | 237 ++ .../org/apache/ignite/snippets/JavaThinClient.java | 427 +++ .../org/apache/ignite/snippets/JobScheduling.java | 122 + .../org/apache/ignite/snippets/LoadBalancing.java | 119 + .../java/org/apache/ignite/snippets/Logging.java | 94 + .../java/org/apache/ignite/snippets/MapReduce.java | 170 ++ .../apache/ignite/snippets/MyLifecycleBean.java | 39 + .../org/apache/ignite/snippets/MyNodeFilter.java | 40 + .../java/org/apache/ignite/snippets/NearCache.java | 69 + .../ignite/snippets/NetworkConfiguration.java | 52 + .../org/apache/ignite/snippets/NodeFilter.java | 75 + .../main/java/org/apache/ignite/snippets/ODBC.java | 38 + .../org/apache/ignite/snippets/OnHeapCaching.java | 31 + .../snippets/PartitionLossPolicyExample.java | 113 + .../apache/ignite/snippets/PeerClassLoading.java | 42 + .../ignite/snippets/PerformingTransactions.java | 178 ++ .../apache/ignite/snippets/PersistenceTuning.java | 109 + .../java/org/apache/ignite/snippets/Person.java | 75 + .../QueryEntitiesExampleWithAnnotation.java | 58 + .../apache/ignite/snippets/QueryEntityExample.java | 58 + .../apache/ignite/snippets/RESTConfiguration.java | 31 + .../ignite/snippets/RebalancingConfiguration.java | 62 + .../java/org/apache/ignite/snippets/Schemas.java | 37 + .../java/org/apache/ignite/snippets/Security.java | 94 + .../java/org/apache/ignite/snippets/Snapshots.java | 54 + .../java/org/apache/ignite/snippets/SqlAPI.java | 195 ++ .../apache/ignite/snippets/SqlTransactions.java | 33 + .../main/java/org/apache/ignite/snippets/Swap.java | 55 + .../main/java/org/apache/ignite/snippets/TDE.java | 63 + .../org/apache/ignite/snippets/TcpIpDiscovery.java | 335 +++ .../java/org/apache/ignite/snippets/Tracing.java | 110 + .../snippets/UnderstandingConfiguration.java | 42 + .../apache/ignite/snippets/UserCodeDeployment.java | 66 + .../ignite/snippets/UsingContinuousQueries.java | 158 ++ .../apache/ignite/snippets/UsingScanQueries.java | 87 + .../main/java/org/apache/ignite/snippets/WAL.java | 46 + .../ignite/snippets/WorkingWithBinaryObjects.java | 183 ++ .../apache/ignite/snippets/ZookeeperDiscovery.java | 46 + .../java/org/apache/ignite/snippets/k8s/K8s.java | 40 + .../apache/ignite/snippets/plugin/MyPlugin.java | 84 + .../ignite/snippets/plugin/MyPluginProvider.java | 142 + .../ignite/snippets/plugin/PluginExample.java | 66 + .../ignite/snippets/services/MyCounterService.java | 32 + .../snippets/services/MyCounterServiceImpl.java | 99 + .../ignite/snippets/services/ServiceExample.java | 177 ++ .../java/src/main/resources/config/ignite-jdbc.xml | 39 + .../java/src/main/resources/keystore/node.jks | Bin 0 -> 3230 bytes .../java/src/main/resources/keystore/trust.jks | Bin 0 -> 2432 bytes docs/_docs/code-snippets/k8s/cluster-role.yaml | 45 + docs/_docs/code-snippets/k8s/service-account.yaml | 22 + docs/_docs/code-snippets/k8s/service.yaml | 43 + docs/_docs/code-snippets/k8s/setup.sh | 96 + .../k8s/stateful/node-configuration.xml | 55 + .../k8s/stateful/statefulset-template.yaml | 96 + .../k8s/stateless/deployment-template.yaml | 60 + .../k8s/stateless/node-configuration.xml | 39 + docs/_docs/code-snippets/nodejs/authentication.js | 53 + docs/_docs/code-snippets/nodejs/binary-types.js | 80 + docs/_docs/code-snippets/nodejs/conf1.js | 36 + docs/_docs/code-snippets/nodejs/conf2.js | 39 + .../code-snippets/nodejs/configuring-cache-1.js | 43 + .../code-snippets/nodejs/configuring-cache-2.js | 40 + docs/_docs/code-snippets/nodejs/connecting.js | 50 + docs/_docs/code-snippets/nodejs/enabling-debug.js | 22 + .../code-snippets/nodejs/get-existing-cache.js | 37 + docs/_docs/code-snippets/nodejs/initialize.js | 33 + docs/_docs/code-snippets/nodejs/key-value.js | 51 + docs/_docs/code-snippets/nodejs/scan-query.js | 55 + docs/_docs/code-snippets/nodejs/scanquery.js | 62 + .../_docs/code-snippets/nodejs/sql-fields-query.js | 60 + docs/_docs/code-snippets/nodejs/sql.js | 75 + docs/_docs/code-snippets/nodejs/tls.js | 128 + .../nodejs/types-mapping-configuration.js | 45 + .../code-snippets/php/ConnectingToCluster.php | 39 + docs/_docs/code-snippets/php/Security.php | 45 + docs/_docs/code-snippets/php/UsingKeyValueApi.php | 134 + docs/_docs/code-snippets/python/auth.py | 33 + .../_docs/code-snippets/python/basic_operations.py | 42 + .../_docs/code-snippets/python/client_reconnect.py | 50 + docs/_docs/code-snippets/python/client_ssl.py | 29 + docs/_docs/code-snippets/python/connect.py | 22 + docs/_docs/code-snippets/python/create_cache.py | 25 + .../python/create_cache_with_properties.py | 52 + docs/_docs/code-snippets/python/scan.py | 59 + docs/_docs/code-snippets/python/sql.py | 66 + docs/_docs/code-snippets/python/type_hints.py | 48 + .../code-snippets/xml/affinity-backup-filter.xml | 65 + .../code-snippets/xml/attribute-node-filter.xml | 58 + docs/_docs/code-snippets/xml/binary-objects.xml | 54 + .../code-snippets/xml/cache-configuration.xml | 49 + docs/_docs/code-snippets/xml/cache-groups.xml | 56 + .../code-snippets/xml/cache-jdbc-pojo-store.xml | 114 + docs/_docs/code-snippets/xml/cache-template.xml | 49 + docs/_docs/code-snippets/xml/client-behind-nat.xml | 44 + docs/_docs/code-snippets/xml/client-node.xml | 50 + docs/_docs/code-snippets/xml/configure-backups.xml | 54 + .../code-snippets/xml/configuring-metrics.xml | 89 + docs/_docs/code-snippets/xml/custom-keys.xml | 70 + .../xml/data-regions-configuration.xml | 90 + docs/_docs/code-snippets/xml/deployment.xml | 55 + .../code-snippets/xml/discovery-multicast.xml | 36 + .../xml/discovery-static-and-multicast.xml | 45 + docs/_docs/code-snippets/xml/discovery-static.xml | 48 + docs/_docs/code-snippets/xml/disk-compression.xml | 59 + docs/_docs/code-snippets/xml/events.xml | 54 + docs/_docs/code-snippets/xml/eviction.xml | 58 + docs/_docs/code-snippets/xml/expiry.xml | 56 + docs/_docs/code-snippets/xml/failover-always.xml | 45 + docs/_docs/code-snippets/xml/failover-never.xml | 43 + .../_docs/code-snippets/xml/http-configuration.xml | 50 + .../code-snippets/xml/ignite-authentication.xml | 58 + docs/_docs/code-snippets/xml/jcl.xml | 57 + docs/_docs/code-snippets/xml/jetty.xml | 69 + .../code-snippets/xml/job-scheduling-fifo.xml | 46 + .../code-snippets/xml/job-scheduling-priority.xml | 47 + docs/_docs/code-snippets/xml/job-stealing.xml | 66 + docs/_docs/code-snippets/xml/lifecycle.xml | 43 + docs/_docs/code-snippets/xml/log4j-config.xml | 107 + docs/_docs/code-snippets/xml/log4j.xml | 59 + docs/_docs/code-snippets/xml/log4j2-config.xml | 79 + docs/_docs/code-snippets/xml/log4j2.xml | 59 + docs/_docs/code-snippets/xml/metrics.xml | 56 + docs/_docs/code-snippets/xml/mvcc.xml | 46 + docs/_docs/code-snippets/xml/near-cache-config.xml | 52 + .../code-snippets/xml/network-configuration.xml | 46 + docs/_docs/code-snippets/xml/odbc-cache-config.xml | 95 + docs/_docs/code-snippets/xml/odbc.xml | 52 + docs/_docs/code-snippets/xml/on-heap-cache.xml | 44 + .../code-snippets/xml/partition-loss-policy.xml | 49 + .../_docs/code-snippets/xml/peer-class-loading.xml | 44 + .../code-snippets/xml/persistence-metrics.xml | 64 + .../_docs/code-snippets/xml/persistence-tuning.xml | 81 + docs/_docs/code-snippets/xml/persistence.xml | 50 + docs/_docs/code-snippets/xml/plugins.xml | 47 + docs/_docs/code-snippets/xml/query-entities.xml | 71 + .../_docs/code-snippets/xml/rebalancing-config.xml | 65 + .../xml/round-robin-load-balancing.xml | 69 + docs/_docs/code-snippets/xml/schemas.xml | 48 + docs/_docs/code-snippets/xml/services.xml | 52 + docs/_docs/code-snippets/xml/slf4j.xml | 57 + docs/_docs/code-snippets/xml/snapshots.xml | 52 + docs/_docs/code-snippets/xml/sql-on-heap-cache.xml | 44 + .../code-snippets/xml/ssl-without-validation.xml | 58 + docs/_docs/code-snippets/xml/ssl.xml | 58 + docs/_docs/code-snippets/xml/swap.xml | 47 + docs/_docs/code-snippets/xml/tcp-ip-discovery.xml | 45 + docs/_docs/code-snippets/xml/tde.xml | 61 + .../xml/thin-client-cluster-config.xml | 65 + docs/_docs/code-snippets/xml/thread-pool.xml | 48 + docs/_docs/code-snippets/xml/tracing.xml | 45 + docs/_docs/code-snippets/xml/transactions.xml | 57 + docs/_docs/code-snippets/xml/wal.xml | 57 + .../code-snippets/xml/weighted-load-balancing.xml | 59 + docs/_docs/configuring-caches/atomicity-modes.adoc | 113 + docs/_docs/configuring-caches/cache-groups.adoc | 80 + .../configuring-caches/configuration-overview.adoc | 153 + .../configuring-caches/configuring-backups.adoc | 92 + docs/_docs/configuring-caches/expiry-policies.adoc | 90 + docs/_docs/configuring-caches/near-cache.adoc | 102 + docs/_docs/configuring-caches/on-heap-caching.adoc | 182 ++ .../configuring-caches/partition-loss-policy.adoc | 196 ++ docs/_docs/cpp-specific/cpp-objects-lifetime.adoc | 92 + .../cpp-platform-interoperability.adoc | 250 ++ docs/_docs/cpp-specific/cpp-serialization.adoc | 266 ++ docs/_docs/cpp-specific/index.adoc | 22 + docs/_docs/data-modeling/affinity-collocation.adoc | 123 + docs/_docs/data-modeling/binary-marshaller.adoc | 299 ++ docs/_docs/data-modeling/data-modeling.adoc | 74 + docs/_docs/data-modeling/data-partitioning.adoc | 140 + docs/_docs/data-rebalancing.adoc | 151 + docs/_docs/data-streaming.adoc | 190 ++ docs/_docs/data-structures/atomic-sequence.adoc | 38 + docs/_docs/data-structures/atomic-types.adoc | 63 + docs/_docs/data-structures/countdownlatch.adoc | 39 + docs/_docs/data-structures/id-generator.adoc | 76 + docs/_docs/data-structures/queue-and-set.adoc | 81 + docs/_docs/data-structures/semaphore.adoc | 33 + .../distributed-computing/cluster-groups.adoc | 62 + .../collocated-computations.adoc | 179 ++ .../distributed-computing.adoc | 388 +++ .../distributed-computing/executor-service.adoc | 39 + .../distributed-computing/fault-tolerance.adoc | 65 + .../distributed-computing/job-scheduling.adoc | 78 + .../distributed-computing/load-balancing.adoc | 127 + docs/_docs/distributed-computing/map-reduce.adoc | 140 + docs/_docs/distributed-locks.adoc | 59 + docs/_docs/events/events.adoc | 342 +++ docs/_docs/events/listening-to-events.adoc | 268 ++ .../cassandra/configuration.adoc | 588 ++++ .../cassandra/ddl-generator.adoc | 99 + .../cassandra/overview.adoc | 54 + .../cassandra/usage-examples.adoc | 691 +++++ .../hibernate-l2-cache.adoc | 308 ++ .../ignite-for-spark/ignite-dataframe.adoc | 380 +++ .../ignite-for-spark/ignitecontext-and-rdd.adoc | 106 + .../ignite-for-spark/installation.adoc | 171 ++ .../ignite-for-spark/overview.adoc | 49 + .../ignite-for-spark/spark-shell.adoc | 202 ++ .../ignite-for-spark/troubleshooting.adoc | 23 + .../mybatis-l2-cache.adoc | 55 + .../_docs/extensions-and-integrations/php-pdo.adoc | 247 ++ .../spring/spring-boot.adoc | 210 ++ .../spring/spring-caching.adoc | 232 ++ .../spring/spring-data.adoc | 228 ++ .../streaming/camel-streamer.adoc | 153 + .../streaming/flink-streamer.adoc | 78 + .../streaming/flume-sink.adoc | 79 + .../streaming/jms-streamer.adoc | 123 + .../streaming/kafka-streamer.adoc | 221 ++ .../streaming/mqtt-streamer.adoc | 76 + .../streaming/rocketmq-streamer.adoc | 85 + .../streaming/storm-streamer.adoc | 62 + .../streaming/twitter-streamer.adoc | 65 + .../streaming/zeromq-streamer.adoc | 67 + docs/_docs/images/111.gif | Bin 0 -> 419 bytes docs/_docs/images/222.gif | Bin 0 -> 1163 bytes docs/_docs/images/333.gif | Bin 0 -> 719 bytes docs/_docs/images/555.gif | Bin 0 -> 1197 bytes docs/_docs/images/666.gif | Bin 0 -> 1309 bytes docs/_docs/images/bagging.png | Bin 0 -> 4675 bytes docs/_docs/images/cache_table.png | Bin 0 -> 166752 bytes docs/_docs/images/checkpointing-chainsaw.png | Bin 0 -> 70186 bytes docs/_docs/images/checkpointing-persistence.png | Bin 0 -> 58508 bytes docs/_docs/images/client-to-aws.png | Bin 0 -> 71068 bytes docs/_docs/images/collocated_joins.png | Bin 0 -> 174755 bytes docs/_docs/images/data_streaming.png | Bin 0 -> 159011 bytes docs/_docs/images/defragmented.png | Bin 0 -> 45437 bytes docs/_docs/images/durable-memory-diagram.png | Bin 0 -> 311833 bytes docs/_docs/images/durable-memory-overview.png | Bin 0 -> 213676 bytes docs/_docs/images/external_storage.png | Bin 0 -> 125073 bytes docs/_docs/images/fragmented.png | Bin 0 -> 26245 bytes docs/_docs/images/ignite_clustering.png | Bin 0 -> 117282 bytes docs/_docs/images/ijfull.png | Bin 0 -> 548711 bytes docs/_docs/images/ijimport.png | Bin 0 -> 43919 bytes docs/_docs/images/ijrun.png | Bin 0 -> 50135 bytes docs/_docs/images/integrations/camel-streamer.png | Bin 0 -> 120217 bytes .../images/integrations/hibernate-l2-cache.png | Bin 0 -> 135173 bytes docs/_docs/images/jconsole.png | Bin 0 -> 97939 bytes docs/_docs/images/k8s/aks-node-number.png | Bin 0 -> 43709 bytes docs/_docs/images/k8s/create-aks-cluster.png | Bin 0 -> 60411 bytes docs/_docs/images/logistic-regression.png | Bin 0 -> 9666 bytes docs/_docs/images/logistic-regression2.png | Bin 0 -> 8764 bytes docs/_docs/images/machine_learning.png | Bin 0 -> 68453 bytes docs/_docs/images/memory-segment.png | Bin 0 -> 28735 bytes docs/_docs/images/naive-bayes.png | Bin 0 -> 18067 bytes docs/_docs/images/naive-bayes2.png | Bin 0 -> 27103 bytes docs/_docs/images/naive-bayes3.png | Bin 0 -> 13713 bytes docs/_docs/images/naive-bayes3png | Bin 0 -> 13713 bytes docs/_docs/images/net-view-details.png | Bin 0 -> 56828 bytes docs/_docs/images/network_segmentation.png | Bin 0 -> 37812 bytes docs/_docs/images/non_collocated_joins.png | Bin 0 -> 190860 bytes docs/_docs/images/odbc_dsn_configuration.png | Bin 0 -> 13372 bytes docs/_docs/images/off_heap_memory_eviction.png | Bin 0 -> 168793 bytes docs/_docs/images/partitionawareness01.png | Bin 0 -> 35538 bytes docs/_docs/images/partitionawareness02.png | Bin 0 -> 31181 bytes docs/_docs/images/partitioned_cache.png | Bin 0 -> 183181 bytes docs/_docs/images/partitioning.png | Bin 0 -> 160390 bytes docs/_docs/images/persistent_store_structure.png | Bin 0 -> 96783 bytes docs/_docs/images/preprocessing.png | Bin 0 -> 6588 bytes docs/_docs/images/preprocessing2.png | Bin 0 -> 4548 bytes docs/_docs/images/replicated_cache.png | Bin 0 -> 181143 bytes docs/_docs/images/segmentation_resolved.png | Bin 0 -> 41915 bytes docs/_docs/images/set-streaming.png | Bin 0 -> 56005 bytes docs/_docs/images/span.png | Bin 0 -> 34434 bytes docs/_docs/images/spark_integration.png | Bin 0 -> 115826 bytes docs/_docs/images/split_brain.png | Bin 0 -> 15844 bytes docs/_docs/images/split_brain_resolved.png | Bin 0 -> 15887 bytes docs/_docs/images/tools/gg-control-center.png | Bin 0 -> 251342 bytes .../images/tools/informatica-import-tables.png | Bin 0 -> 54326 bytes .../images/tools/informatica-rel-connection.png | Bin 0 -> 40510 bytes .../images/tools/pentaho-ignite-connection.png | Bin 0 -> 77439 bytes .../images/tools/pentaho-new-transformation.png | Bin 0 -> 81849 bytes .../tools/pentaho-running-and-inspecting-data.png | Bin 0 -> 56310 bytes docs/_docs/images/tools/tableau-choose_dsn_01.png | Bin 0 -> 12515 bytes docs/_docs/images/tools/tableau-choose_dsn_02.png | Bin 0 -> 12860 bytes .../images/tools/tableau-choosing_driver_01.png | Bin 0 -> 100372 bytes .../images/tools/tableau-creating_dataset.png | Bin 0 -> 59092 bytes .../_docs/images/tools/tableau-edit_connection.png | Bin 0 -> 7123 bytes .../images/tools/tableau-visualizing_data.png | Bin 0 -> 86105 bytes docs/_docs/images/tools/visor-cmd.png | Bin 0 -> 208235 bytes docs/_docs/images/trace_in_zipkin.png | Bin 0 -> 118677 bytes docs/_docs/images/zookeeper.png | Bin 0 -> 139311 bytes docs/_docs/images/zookeeper_split.png | Bin 0 -> 56004 bytes .../includes/cpp-linux-build-prerequisites.adoc | 45 + docs/_docs/includes/cpp-prerequisites.adoc | 23 + docs/_docs/includes/dotnet-prerequisites.adoc | 20 + docs/_docs/includes/exampleprojects.adoc | 37 + docs/_docs/includes/install-ignite.adoc | 26 + docs/_docs/includes/install-nodejs-npm.adoc | 19 + docs/_docs/includes/install-php-composer.adoc | 25 + docs/_docs/includes/install-python-pip.adoc | 29 + docs/_docs/includes/intro-languages.adoc | 47 + docs/_docs/includes/java9.adoc | 42 + docs/_docs/includes/nodes-and-clustering.adoc | 33 + docs/_docs/includes/note-on-deactivation.adoc | 19 + docs/_docs/includes/partition-awareness.adoc | 40 + docs/_docs/includes/prereqs.adoc | 23 + docs/_docs/includes/starting-node.adoc | 93 + docs/_docs/includes/thick-and-thin-clients.adoc | 42 + docs/_docs/index.adoc | 33 + docs/_docs/installation/deb-rpm.adoc | 95 + docs/_docs/installation/index.adoc | 21 + .../installation/installing-using-docker.adoc | 212 ++ docs/_docs/installation/installing-using-zip.adoc | 27 + .../kubernetes/amazon-eks-deployment.adoc | 68 + .../installation/kubernetes/azure-deployment.adoc | 84 + .../kubernetes/generic-configuration.adoc | 402 +++ .../installation/kubernetes/gke-deployment.adoc | 78 + docs/_docs/installation/vmware-installation.adoc | 59 + .../key-value-api/basic-cache-operations.adoc | 421 +++ docs/_docs/key-value-api/binary-objects.adoc | 236 ++ docs/_docs/key-value-api/continuous-queries.adoc | 177 ++ docs/_docs/key-value-api/transactions.adoc | 330 +++ docs/_docs/key-value-api/using-scan-queries.adoc | 124 + docs/_docs/key-value-api/with-expiry-policy.adoc | 40 + docs/_docs/logging.adoc | 184 ++ .../binary-classification/ann.adoc | 87 + .../binary-classification/decision-trees.adoc | 77 + .../binary-classification/introduction.adoc | 36 + .../binary-classification/knn-classification.adoc | 63 + .../binary-classification/linear-svm.adoc | 52 + .../binary-classification/logistic-regression.adoc | 85 + .../multilayer-perceptron.adoc | 78 + .../binary-classification/naive-bayes.adoc | 109 + .../clustering/gaussian-mixture.adoc | 71 + .../machine-learning/clustering/introduction.adoc | 22 + .../clustering/k-means-clustering.adoc | 80 + .../machine-learning/ensemble-methods/bagging.adoc | 56 + .../ensemble-methods/gradient-boosting.adoc | 99 + .../ensemble-methods/introduction.adoc | 25 + .../ensemble-methods/random-forest.adoc | 85 + .../ensemble-methods/stacking.adoc | 49 + .../importing-model/introduction.adoc | 26 + .../model-import-from-apache-spark.adoc | 84 + .../importing-model/model-import-from-gxboost.adoc | 35 + docs/_docs/machine-learning/machine-learning.adoc | 139 + .../model-selection/cross-validation.adoc | 90 + .../model-selection/evaluator.adoc | 107 + .../model-selection/hyper-parameter-tuning.adoc | 65 + .../model-selection/introduction.adoc | 32 + .../model-selection/pipeline-api.adoc | 125 + ...lit-the-dataset-on-test-and-train-datasets.adoc | 66 + .../multiclass-classification.adoc | 55 + .../machine-learning/partition-based-dataset.adoc | 100 + docs/_docs/machine-learning/preprocessing.adoc | 253 ++ .../machine-learning/recommendation-systems.adoc | 71 + .../regression/decision-trees-regression.adoc | 75 + .../machine-learning/regression/introduction.adoc | 23 + .../regression/knn-regression.adoc | 63 + .../regression/linear-regression.adoc | 99 + .../machine-learning/updating-trained-models.adoc | 77 + docs/_docs/memory-architecture.adoc | 93 + docs/_docs/memory-configuration/data-regions.adoc | 84 + .../memory-configuration/eviction-policies.adoc | 177 ++ docs/_docs/memory-configuration/index.adoc | 21 + docs/_docs/messaging.adoc | 106 + docs/_docs/monitoring-metrics/cluster-id.adoc | 62 + docs/_docs/monitoring-metrics/cluster-states.adoc | 97 + .../monitoring-metrics/configuring-metrics.adoc | 149 + docs/_docs/monitoring-metrics/intro.adoc | 58 + docs/_docs/monitoring-metrics/metrics.adoc | 507 ++++ .../monitoring-metrics/new-metrics-system.adoc | 220 ++ docs/_docs/monitoring-metrics/new-metrics.adoc | 342 +++ docs/_docs/monitoring-metrics/system-views.adoc | 678 +++++ docs/_docs/monitoring-metrics/tracing.adoc | 183 ++ .../_docs/net-specific/asp-net-output-caching.adoc | 93 + .../asp-net-session-state-caching.adoc | 81 + docs/_docs/net-specific/index.adoc | 23 + .../net-specific/net-configuration-options.adoc | 190 ++ .../net-specific/net-cross-platform-support.adoc | 65 + .../_docs/net-specific/net-deployment-options.adoc | 152 + .../net-specific/net-entity-framework-cache.adoc | 198 ++ .../net-specific/net-java-services-execution.adoc | 116 + docs/_docs/net-specific/net-linq.adoc | 256 ++ docs/_docs/net-specific/net-logging.adoc | 133 + docs/_docs/net-specific/net-platform-cache.adoc | 125 + .../net-platform-interoperability.adoc | 195 ++ docs/_docs/net-specific/net-plugins.adoc | 169 ++ .../net-specific/net-remote-assembly-loading.adoc | 154 + docs/_docs/net-specific/net-serialization.adoc | 314 +++ docs/_docs/net-specific/net-standalone-nodes.adoc | 130 + docs/_docs/net-specific/net-troubleshooting.adoc | 161 ++ .../general-perf-tips.adoc | 49 + .../handling-exceptions.adoc | 248 ++ docs/_docs/perf-and-troubleshooting/index.adoc | 18 + .../perf-and-troubleshooting/memory-tuning.adoc | 185 ++ .../persistence-tuning.adoc | 269 ++ .../_docs/perf-and-troubleshooting/sql-tuning.adoc | 525 ++++ .../thread-pools-tuning.adoc | 117 + .../perf-and-troubleshooting/troubleshooting.adoc | 164 ++ .../yardstick-benchmarking.adoc | 176 ++ docs/_docs/persistence/custom-cache-store.adoc | 103 + docs/_docs/persistence/disk-compression.adoc | 62 + docs/_docs/persistence/external-storage.adoc | 224 ++ docs/_docs/persistence/native-persistence.adoc | 362 +++ docs/_docs/persistence/persistence-tuning.adoc | 258 ++ docs/_docs/persistence/snapshots.adoc | 208 ++ docs/_docs/persistence/swap.adoc | 66 + docs/_docs/plugins.adoc | 129 + docs/_docs/quick-start/cpp.adoc | 131 + docs/_docs/quick-start/dotnet.adoc | 95 + docs/_docs/quick-start/index.adoc | 18 + docs/_docs/quick-start/java.adoc | 171 ++ docs/_docs/quick-start/nodejs.adoc | 104 + docs/_docs/quick-start/php.adoc | 125 + docs/_docs/quick-start/python.adoc | 88 + docs/_docs/quick-start/restapi.adoc | 96 + docs/_docs/quick-start/sql.adoc | 129 + docs/_docs/read-repair.adoc | 56 + docs/_docs/resources-injection.adoc | 88 + docs/_docs/restapi.adoc | 2953 ++++++++++++++++++++ docs/_docs/security/authentication.adoc | 65 + docs/_docs/security/index.adoc | 18 + docs/_docs/security/master-key-rotation.adoc | 131 + docs/_docs/security/sandbox.adoc | 94 + docs/_docs/security/ssl-tls.adoc | 217 ++ docs/_docs/security/tde.adoc | 142 + docs/_docs/services/services.adoc | 267 ++ docs/_docs/setup.adoc | 303 ++ docs/_docs/sql-reference/aggregate-functions.adoc | 397 +++ docs/_docs/sql-reference/data-types.adoc | 182 ++ docs/_docs/sql-reference/date-time-functions.adoc | 399 +++ docs/_docs/sql-reference/ddl.adoc | 520 ++++ docs/_docs/sql-reference/dml.adoc | 363 +++ docs/_docs/sql-reference/index.adoc | 18 + docs/_docs/sql-reference/numeric-functions.adoc | 981 +++++++ docs/_docs/sql-reference/operational-commands.adoc | 372 +++ docs/_docs/sql-reference/sql-conformance.adoc | 471 ++++ docs/_docs/sql-reference/string-functions.adoc | 942 +++++++ docs/_docs/sql-reference/system-functions.adoc | 225 ++ docs/_docs/sql-reference/transactions.adoc | 66 + docs/_docs/starting-nodes.adoc | 262 ++ docs/_docs/thin-client-comparison.csv | 15 + docs/_docs/thin-clients/cpp-thin-client.adoc | 117 + docs/_docs/thin-clients/dotnet-thin-client.adoc | 260 ++ .../getting-started-with-thin-clients.adoc | 126 + docs/_docs/thin-clients/java-thin-client.adoc | 329 +++ docs/_docs/thin-clients/nodejs-thin-client.adoc | 240 ++ docs/_docs/thin-clients/php-thin-client.adoc | 149 + docs/_docs/thin-clients/python-thin-client.adoc | 488 ++++ docs/_docs/tools/control-script.adoc | 649 +++++ docs/_docs/tools/gg-control-center.adoc | 34 + docs/_docs/tools/informatica.adoc | 304 ++ docs/_docs/tools/pentaho.adoc | 65 + docs/_docs/tools/sqlline.adoc | 225 ++ docs/_docs/tools/tableau.adoc | 66 + docs/_docs/tools/visor-cmd.adoc | 68 + docs/_docs/transactions/mvcc.adoc | 193 ++ docs/_docs/understanding-configuration.adoc | 111 + docs/_includes/copyright.html | 22 + docs/_includes/footer.html | 20 + docs/_includes/header.html | 36 + docs/_includes/left-nav.html | 88 + docs/_includes/right-nav.html | 21 + docs/_includes/section-toc.html | 31 + docs/_includes/toc.html | 63 + docs/_layouts/default.html | 72 + docs/_layouts/doc.html | 33 + docs/_layouts/toc.html | 32 + docs/_plugins/asciidoctor-extensions.rb | 180 ++ docs/_sass/callouts.scss | 75 + docs/_sass/code.scss | 115 + docs/_sass/docs.scss | 238 ++ docs/_sass/footer.scss | 48 + docs/_sass/github.scss | 223 ++ docs/_sass/header.scss | 374 +++ docs/_sass/layout.scss | 45 + docs/_sass/left-nav.scss | 109 + docs/_sass/right-nav.scss | 73 + docs/_sass/rouge-base16-solarized.scss | 99 + docs/_sass/text.scss | 62 + docs/_sass/variables.scss | 33 + docs/assets/css/asciidoc-pygments.css | 59 + docs/assets/css/docs.scss | 21 + docs/assets/css/styles.scss | 30 + docs/assets/images/apple-blob.svg | 16 + docs/assets/images/arrow-down-white.svg | 3 + docs/assets/images/arrow-down.svg | 3 + docs/assets/images/background-lines.svg | 54 + docs/assets/images/cancel.svg | 11 + docs/assets/images/checkmark-green.svg | 3 + docs/assets/images/copy-icon.svg | 6 + docs/assets/images/cpp.svg | 9 + docs/assets/images/dev-internal-bg.jpg | Bin 0 -> 23014 bytes docs/assets/images/dotnet.svg | 9 + docs/assets/images/edition-ce.svg | 16 + docs/assets/images/edition-ee.svg | 25 + docs/assets/images/edition-ue.svg | 28 + docs/assets/images/events-nav-arrow.svg | 3 + docs/assets/images/feature-easy-installation.svg | 28 + docs/assets/images/feature-fast.svg | 16 + docs/assets/images/feature-reliable.svg | 25 + docs/assets/images/github-gray.svg | 3 + docs/assets/images/github-white.svg | 3 + docs/assets/images/glowing-box.svg | 170 ++ docs/assets/images/integrations/hibernate.svg | 6 + docs/assets/images/integrations/kafka.svg | 3 + docs/assets/images/integrations/more.svg | 18 + docs/assets/images/integrations/oracle.svg | 3 + docs/assets/images/integrations/osgi.svg | 17 + docs/assets/images/integrations/spark.svg | 7 + docs/assets/images/integrations/spring.svg | 3 + docs/assets/images/java.svg | 9 + docs/assets/images/left-nav-arrow.svg | 3 + docs/assets/images/lines-bg-1.svg | 54 + docs/assets/images/lines-bg-2.svg | 54 + docs/assets/images/lines-bg-3.svg | 54 + docs/assets/images/lines-bg-4.svg | 54 + docs/assets/images/menu-icon.svg | 3 + docs/assets/images/mousepad-blob.svg | 9 + ...piece-of-paper-with-folded-top-right-corner.svg | 117 + docs/assets/images/scala.svg | 31 + docs/assets/images/search.svg | 15 + docs/assets/images/violent-blob.svg | 28 + docs/assets/images/watermelon-blob.svg | 9 + docs/assets/js/anchor.min.js | 9 + docs/assets/js/code-copy-to-clipboard.js | 70 + docs/assets/js/code-tabs.js | 155 + docs/assets/js/docs-menu.js | 64 + docs/assets/js/index.js | 51 + docs/assets/js/page-nav.js | 37 + docs/assets/js/top-navigation.js | 92 + docs/favicon.ico | Bin 0 -> 9780 bytes docs/run.sh | 23 + examples/README.md | 2 +- examples/config/servlet/README.txt | 3 - examples/redis/redis-example.php | 2 - examples/redis/redis-example.py | 2 - .../ml/tutorial/TutorialStepByStepExample.java | 56 - .../examples/MLTutorialExamplesSelfTest.java | 166 ++ .../testsuites/IgniteExamplesSelfTestSuite.java | 4 +- .../cassandra/persistence/PersistenceSettings.java | 4 +- .../tests/IgnitePersistentStorePrimitiveTest.java | 142 + .../store/IgniteCassandraStoreTestSuite.java | 4 +- .../persistence/MetaStorageCompatibilityTest.java | 12 +- .../WalPageCompressionIntegrationTest.java | 6 +- .../ignite/internal/commandline/CommandList.java | 6 +- .../internal/commandline/metric/MetricCommand.java | 149 + .../commandline/metric/MetricCommandArg.java | 44 + .../commandline/systemview/SystemViewCommand.java | 55 +- .../commandline/CommandHandlerParsingTest.java | 3 +- .../testsuites/IgniteControlUtilityTestSuite.java | 4 +- .../org/apache/ignite/util/MetricCommandTest.java | 379 +++ .../org/apache/ignite/IgniteSystemProperties.java | 10 +- .../apache/ignite/client/ClientAddressFinder.java | 42 + .../client/ClientAuthenticationException.java | 10 + .../client/ClientAuthorizationException.java | 10 + ...ClientFeatureNotSupportedByServerException.java | 10 + .../ignite/client/ClientReconnectedException.java | 10 + .../org/apache/ignite/cluster/ClusterMetrics.java | 2 +- .../ignite/configuration/CacheConfiguration.java | 1 + .../ignite/configuration/ClientConfiguration.java | 58 +- .../ClientConnectorConfiguration.java | 38 +- .../configuration/NearCacheConfiguration.java | 1 - .../java/org/apache/ignite/events/EventType.java | 56 + .../org/apache/ignite/events/SnapshotEvent.java | 53 + .../apache/ignite/internal/GridKernalContext.java | 9 + .../ignite/internal/GridKernalContextImpl.java | 14 + .../org/apache/ignite/internal/IgniteFeatures.java | 28 +- .../org/apache/ignite/internal/IgniteKernal.java | 22 +- .../internal/binary/BinaryThreadLocalContext.java | 2 +- .../binary/streams/BinaryHeapOutputStream.java | 2 +- .../binary/streams/BinaryMemoryAllocator.java | 280 +- .../binary/streams/BinaryMemoryAllocatorChunk.java | 73 +- .../internal/client/thin/ReliableChannel.java | 752 +++-- .../internal/client/thin/TcpClientChannel.java | 219 +- .../internal/client/thin/TcpIgniteClient.java | 2 + .../internal/maintenance/MaintenanceFileStore.java | 229 ++ .../internal/maintenance/MaintenanceProcessor.java | 276 ++ .../managers/discovery/GridDiscoveryManager.java | 11 +- .../managers/encryption/GridEncryptionManager.java | 2 +- .../pagemem/store/IgnitePageStoreManager.java | 5 - .../pagemem/wal/IgniteWriteAheadLogManager.java | 1 + .../ignite/internal/pagemem/wal/WALIterator.java | 1 + .../ignite/internal/pagemem/wal/WALPointer.java | 30 - .../pagemem/wal/record/CheckpointRecord.java | 2 +- .../pagemem/wal/record/MarshalledRecord.java | 2 +- .../internal/pagemem/wal/record/WALRecord.java | 2 +- .../cache/CacheAffinitySharedManager.java | 32 +- .../cache/CacheConfigurationEnricher.java | 33 +- .../cache/CacheConfigurationEnrichment.java | 30 +- .../cache/CacheConfigurationSplitterImpl.java | 35 +- .../processors/cache/ClusterCachesInfo.java | 12 +- .../processors/cache/GridCacheAttributes.java | 6 +- .../cache/GridCacheLocalConcurrentMap.java | 2 +- .../processors/cache/GridCacheMapEntry.java | 2 +- .../processors/cache/GridCacheMvccManager.java | 12 +- .../cache/GridCachePartitionExchangeManager.java | 7 +- .../processors/cache/GridCacheProcessor.java | 59 +- .../processors/cache/GridCacheUpdateTxResult.java | 2 +- .../binary/CacheObjectBinaryProcessorImpl.java | 2 +- .../distributed/GridDistributedCacheEntry.java | 2 +- .../distributed/GridDistributedTxMapping.java | 2 +- .../GridDistributedTxRemoteAdapter.java | 2 +- .../cache/distributed/dht/GridDhtTxRemote.java | 18 +- .../dht/colocated/GridDhtDetachedCacheEntry.java | 2 +- .../preloader/GridDhtPartitionsExchangeFuture.java | 6 +- .../dht/preloader/GridDhtPreloader.java | 24 +- .../preloader/IgniteDhtDemandedPartitionsMap.java | 8 + .../dht/topology/GridClientPartitionTopology.java | 5 + .../dht/topology/GridDhtLocalPartition.java | 78 +- .../dht/topology/GridDhtPartitionTopology.java | 9 + .../dht/topology/GridDhtPartitionTopologyImpl.java | 45 +- .../dht/topology/PartitionsEvictManager.java | 15 +- .../cache/distributed/near/GridNearCacheEntry.java | 2 +- .../cache/distributed/near/GridNearTxRemote.java | 5 +- .../cache/extras/GridCacheEntryExtras.java | 2 +- .../CleanCacheStoresMaintenanceAction.java | 75 + .../CorruptedPdsMaintenanceCallback.java | 79 + .../GridCacheDatabaseSharedManager.java | 46 +- .../cache/persistence/GridCacheOffheapManager.java | 156 +- .../IgniteCacheDatabaseSharedManager.java | 2 +- .../persistence/checkpoint/CheckpointEntry.java | 2 +- .../persistence/checkpoint/CheckpointHistory.java | 57 +- .../persistence/checkpoint/CheckpointManager.java | 2 +- .../checkpoint/CheckpointMarkersStorage.java | 19 +- .../checkpoint/CheckpointReadWriteLock.java | 7 + .../persistence/checkpoint/CheckpointStatus.java | 5 +- .../checkpoint/CheckpointTimeoutLock.java | 3 + .../persistence/checkpoint/CheckpointWorkflow.java | 2 +- .../cache/persistence/checkpoint/Checkpointer.java | 2 +- .../persistence/file/FilePageStoreManager.java | 85 +- .../cache/persistence/metastorage/MetaStorage.java | 2 +- .../pagemem/CheckpointMetricsTracker.java | 2 +- .../cache/persistence/pagemem/PageMemoryImpl.java | 2 +- .../snapshot/IgniteSnapshotManager.java | 112 +- .../wal/AbstractWalRecordsIterator.java | 17 +- .../cache/persistence/wal/FileWALPointer.java | 125 - .../persistence/wal/FileWriteAheadLogManager.java | 116 +- .../wal/SingleSegmentLogicalRecordsIterator.java | 1 - .../cache/persistence/wal/WALPointer.java | 127 + .../wal/filehandle/FileHandleManager.java | 2 +- .../wal/filehandle/FileHandleManagerImpl.java | 9 +- .../wal/filehandle/FileWriteHandle.java | 9 +- .../wal/filehandle/FileWriteHandleImpl.java | 25 +- .../wal/filehandle/FsyncFileHandleManagerImpl.java | 9 +- .../wal/filehandle/FsyncFileWriteHandle.java | 36 +- .../wal/reader/FilteredWalIterator.java | 2 +- .../wal/reader/IgniteWalIteratorFactory.java | 21 +- .../wal/reader/StandaloneGridKernalContext.java | 6 + .../wal/reader/StandaloneWalRecordsIterator.java | 25 +- .../cache/persistence/wal/reader/WalFilters.java | 2 +- .../wal/scanner/PrintRawToFileHandler.java | 2 +- .../wal/scanner/PrintToFileHandler.java | 2 +- .../persistence/wal/scanner/PrintToLogHandler.java | 2 +- .../persistence/wal/scanner/ScannerHandler.java | 2 +- .../cache/persistence/wal/scanner/WalScanner.java | 2 +- .../wal/serializer/RecordDataV1Serializer.java | 15 +- .../wal/serializer/RecordDataV2Serializer.java | 17 +- .../wal/serializer/RecordSerializer.java | 2 +- .../wal/serializer/RecordSerializerFactory.java | 4 +- .../serializer/RecordSerializerFactoryImpl.java | 2 +- .../wal/serializer/RecordV1Serializer.java | 15 +- .../wal/serializer/RecordV2Serializer.java | 21 +- .../persistence/wal/serializer/io/RecordIO.java | 2 +- .../cache/transactions/IgniteTxAdapter.java | 2 +- .../cache/transactions/IgniteTxEntry.java | 9 +- .../cache/transactions/IgniteTxHandler.java | 116 +- .../cache/transactions/IgniteTxLocalAdapter.java | 2 +- .../cache/transactions/IgniteTxManager.java | 5 +- .../diagnostic/PageHistoryDiagnoster.java | 8 +- .../metric/impl/HistogramMetricImpl.java | 6 + .../odbc/ClientListenerBufferedParser.java | 80 - .../odbc/ClientListenerMessageParser.java | 8 +- .../processors/odbc/ClientListenerNioListener.java | 14 +- .../odbc/ClientListenerNioMessageParser.java | 94 + .../odbc/ClientListenerNioServerBuffer.java | 113 - .../processors/odbc/ClientListenerProcessor.java | 25 +- .../internal/processors/odbc/ClientMessage.java | 189 ++ .../odbc/jdbc/JdbcConnectionContext.java | 4 +- .../processors/odbc/jdbc/JdbcMessageParser.java | 19 +- .../odbc/odbc/OdbcConnectionContext.java | 4 +- .../processors/odbc/odbc/OdbcMessageParser.java | 19 +- .../platform/client/ClientMessageParser.java | 18 +- .../processors/query/GridQueryProcessor.java | 14 + .../processors/query/IgniteSQLException.java | 4 +- .../processors/query/QueryTypeDescriptorImpl.java | 66 + .../apache/ignite/internal/util/IgniteUtils.java | 4 +- .../internal/util/io/GridUnsafeDataInput.java | 2 +- .../internal/util/io/GridUnsafeDataOutput.java | 2 +- .../ignite/internal/util/nio/GridNioServer.java | 62 +- .../internal/visor/metric/VisorMetricTask.java | 130 + .../internal/visor/metric/VisorMetricTaskArg.java | 64 + .../ignite/internal/visor/misc/VisorWalTask.java | 7 +- .../visor/systemview/VisorSystemViewTask.java | 13 +- .../systemview/VisorSystemViewTaskResult.java | 8 +- .../ignite/internal/worker/WorkersRegistry.java | 2 +- .../ignite/maintenance/MaintenanceAction.java | 52 + .../ignite/maintenance/MaintenanceRegistry.java | 157 ++ .../apache/ignite/maintenance/MaintenanceTask.java | 88 + .../maintenance/MaintenanceWorkflowCallback.java | 68 + .../apache/ignite/maintenance/package-info.java | 21 + .../ignite/plugin/security/SecurityPermission.java | 5 +- .../checkpoint/sharedfs/SharedFsCheckpointSpi.java | 37 +- .../discovery/isolated/IsolatedDiscoverySpi.java | 256 ++ .../spi/discovery/isolated/IsolatedNode.java | 153 + .../main/resources/META-INF/classnames.properties | 2 +- .../ignite/cache/RebalanceCancellationTest.java | 26 +- .../org/apache/ignite/client/ReliabilityTest.java | 31 +- .../failure/ExchangeWorkerWaitingForTaskTest.java | 77 + .../ignite/failure/SystemWorkersBlockingTest.java | 106 +- .../ignite/internal/GridAffinityMappedTest.java | 13 +- .../ignite/internal/GridAffinityP2PSelfTest.java | 201 -- .../ignite/internal/GridP2PAffinitySelfTest.java | 203 ++ .../internal/binary/BinaryMarshallerSelfTest.java | 14 +- .../internal/client/thin/ReliableChannelTest.java | 443 +++ .../ThinClientPartitionAwarenessDiscoveryTest.java | 167 ++ ...ientPartitionAwarenessUnstableTopologyTest.java | 11 +- .../wal/record/WALRecordSerializationTest.java | 7 +- .../GridCacheInterceptorAbstractSelfTest.java | 13 +- .../NoPresentCacheInterceptorOnClientTest.java | 203 ++ .../cache/WalModeChangeAdvancedSelfTest.java | 192 +- .../cache/binary/BinaryMetadataInMemoryTest.java | 47 + .../cache/distributed/CacheExchangeMergeTest.java | 39 +- .../IgniteCacheNearRestartRollbackSelfTest.java | 2 - .../distributed/OnePhaseCommitAndNodeLeftTest.java | 247 ++ .../dht/topology/BlockedEvictionsTest.java | 8 +- .../topology/DelayedOwningDuringExchangeTest.java | 191 ++ .../EvictionWhilePartitionGroupIsReservedTest.java | 8 +- ...MovingPartitionIsEvictedDuringClearingTest.java | 5 +- ...reloadingRestartWhileClearingPartitionTest.java | 2 +- .../RentingPartitionIsOwnedDuringEvictionTest.java | 2 +- .../IgnitePdsClientNearCachePutGetTest.java | 2 + .../IgnitePdsRecoveryAfterFileCorruptionTest.java | 2 +- .../IgnitePdsSporadicDataRecordsOnBackupTest.java | 2 +- .../IgnitePersistenceSequentialCheckpointTest.java | 2 +- .../IgnitePersistentStoreCacheGroupsTest.java | 10 +- ...ocalWalModeChangeDuringRebalancingSelfTest.java | 244 +- ...NoChangeDuringRebalanceOnNonNodeAssignTest.java | 2 +- .../persistence/MaintenanceRegistrySimpleTest.java | 345 +++ .../db/IgnitePdsReserveWalSegmentsTest.java | 19 +- .../db/checkpoint/ProgressWatchdog.java | 8 +- .../db/file/IgnitePdsCheckpointSimpleTest.java | 1 - ...CheckpointSimulationWithRealCpDisabledTest.java | 2 +- ...ailIsReachedDuringIterationOverArchiveTest.java | 17 +- .../IgniteWalIteratorExceptionDuringReadTest.java | 13 +- .../db/wal/IgniteWalIteratorSwitchSegmentTest.java | 2 +- .../db/wal/IgniteWalRebalanceLoggingTest.java | 2 +- .../persistence/db/wal/IgniteWalRebalanceTest.java | 4 +- .../wal/IgniteWalRecoverySeveralRestartsTest.java | 10 + .../db/wal/IgniteWalReplayingAfterRestartTest.java | 2 +- .../db/wal/IgniteWalSerializerVersionTest.java | 2 +- .../db/wal/WalCompactionNoArchiverTest.java | 135 + .../persistence/db/wal/WalOnNodeStartTest.java | 5 +- .../db/wal/WalRecoveryTxLogicalRecordsTest.java | 18 +- .../persistence/db/wal/WalRolloverTypesTest.java | 19 +- .../IgniteAbstractWalIteratorInvalidCrcTest.java | 11 +- ...teWithoutArchiverWalIteratorInvalidCrcTest.java | 10 +- .../cache/persistence/db/wal/crc/WalTestUtils.java | 25 +- .../db/wal/reader/IgniteWalReaderTest.java | 43 +- .../persistence/pagemem/NoOpPageStoreManager.java | 5 - .../cache/persistence/pagemem/NoOpWALManager.java | 2 +- .../pagemem/PageIdDistributionTest.java | 8 +- .../snapshot/AbstractSnapshotSelfTest.java | 18 + .../snapshot/IgniteClusterSnapshotSelfTest.java | 20 + .../wal/memtracker/PageMemoryTracker.java | 2 +- .../wal/reader/FilteredWalIteratorTest.java | 7 +- .../reader/StandaloneWalRecordsIteratorTest.java | 19 +- .../persistence/wal/scanner/WalScannerTest.java | 61 +- .../cache/transactions/TxDeadlockCauseTest.java | 19 +- .../TxPartitionCounterStateConsistencyTest.java | 2 +- .../security/impl/TestSecurityContext.java | 1 + .../snapshot/SnapshotPermissionCheckTest.java | 154 + .../ignite/p2p/GridP2PTestTaskExecutionTest.java | 55 - .../ignite/platform/PlatformProcessUtils.java | 120 + ...SharedFsCheckpointSpiMultiThreadedSelfTest.java | 183 +- .../AbstractDiscoveryRandomStartStopTest.java | 219 -- .../tcp/TcpDiscoveryConcurrentStartTest.java | 10 +- .../tcp/TcpDiscoverySpiRandomStartStopTest.java | 33 - .../testframework/wal/record/RecordUtils.java | 4 +- .../ignite/testsuites/IgniteBasicTestSuite.java | 2 + .../testsuites/IgniteBinaryObjectsTestSuite.java | 2 + .../testsuites/IgniteCacheMvccTestSuite2.java | 2 + .../testsuites/IgniteCacheMvccTestSuite6.java | 2 + .../ignite/testsuites/IgniteCacheTestSuite2.java | 2 + .../ignite/testsuites/IgniteCacheTestSuite6.java | 2 + .../ignite/testsuites/IgniteCacheTestSuite7.java | 2 + .../testsuites/IgniteComputeGridTestSuite.java | 7 +- .../ignite/testsuites/IgniteP2PSelfTestSuite.java | 3 +- .../ignite/testsuites/IgnitePdsMvccTestSuite2.java | 2 + .../ignite/testsuites/IgnitePdsTestSuite.java | 21 +- .../ignite/testsuites/IgnitePdsTestSuite2.java | 52 +- .../IgniteSpiCheckpointSelfTestSuite.java | 3 +- .../IgniteSpiCommunicationSelfTestSuite.java | 5 +- .../IgniteSpiDiscoverySelfTestSuite.java | 10 +- .../ignite/testsuites/SecurityTestSuite.java | 2 + .../testsuites/TxDeadlockDetectionTestSuite.java | 3 +- ...ridCommandHandlerClusterByClassTest_help.output | 7 + ...andHandlerClusterByClassWithSSLTest_help.output | 7 + .../development/utils/IgniteWalConverter.java | 2 +- .../apache/ignite/development/utils/WalStat.java | 9 +- .../apache/ignite/tests/p2p/cache/Container.java | 29 + .../tests/p2p/cache/OddEvenCacheInterceptor.java | 58 + modules/indexing/pom.xml | 8 + .../processors/query/h2/CommandProcessor.java | 2 +- .../processors/query/h2/database/H2TreeIndex.java | 70 +- .../processors/query/h2/opt/GridH2IndexBase.java | 9 - .../processors/query/h2/opt/GridH2Table.java | 12 +- .../org/apache/ignite/client/ClientTestSuite.java | 4 + .../org/apache/ignite/client/SecurityTest.java | 26 +- .../processors/cache/index/BasicIndexTest.java | 4 +- .../DynamicEnableIndexingConcurrentSelfTest.java | 9 +- .../db/LongDestroyDurableBackgroundTaskTest.java | 103 +- .../MultipleParallelCacheDeleteDeadlockTest.java | 328 +++ .../persistence/db/wal/IgniteWalRecoveryTest.java | 2 +- .../query/CreateIndexOnInvalidDataTypeTest.java | 18 +- .../query/WrongQueryEntityFieldTypeTest.java | 289 ++ .../IgniteBinaryCacheQueryTestSuite2.java | 2 + .../IgnitePdsWithIndexingCoreTestSuite.java | 2 + .../testsuites/IgnitePdsWithIndexingTestSuite.java | 4 +- modules/kafka/README.txt | 210 -- modules/kafka/licenses/apache-2.0.txt | 202 -- modules/kafka/pom.xml | 155 - .../apache/ignite/stream/kafka/KafkaStreamer.java | 205 -- .../stream/kafka/connect/IgniteSinkConnector.java | 100 - .../stream/kafka/connect/IgniteSinkConstants.java | 41 - .../stream/kafka/connect/IgniteSinkTask.java | 201 -- .../kafka/connect/IgniteSourceConnector.java | 90 - .../kafka/connect/IgniteSourceConstants.java | 44 - .../stream/kafka/connect/IgniteSourceTask.java | 359 --- .../ignite/stream/kafka/connect/package-info.java | 22 - .../connect/serialization/CacheEventConverter.java | 67 - .../serialization/CacheEventDeserializer.java | 55 - .../serialization/CacheEventSerializer.java | 55 - .../kafka/connect/serialization/package-info.java | 22 - .../apache/ignite/stream/kafka/package-info.java | 22 - .../kafka/IgniteKafkaStreamerSelfTestSuite.java | 45 - .../stream/kafka/KafkaIgniteStreamerSelfTest.java | 275 -- .../ignite/stream/kafka/TestKafkaBroker.java | 237 -- .../kafka/connect/IgniteSinkConnectorMock.java | 30 - .../kafka/connect/IgniteSinkConnectorTest.java | 307 -- .../stream/kafka/connect/IgniteSinkTaskMock.java | 29 - .../kafka/connect/IgniteSourceConnectorMock.java | 30 - .../kafka/connect/IgniteSourceConnectorTest.java | 355 --- .../stream/kafka/connect/IgniteSourceTaskMock.java | 31 - .../stream/kafka/connect/TestCacheEventFilter.java | 31 - .../apache/ignite/stream/kafka/package-info.java | 22 - .../kafka/src/test/resources/example-ignite.xml | 73 - modules/kubernetes/pom.xml | 20 + .../client/ThinClientKubernetesAddressFinder.java | 68 + .../KubernetesServiceAddressResolver.java | 225 ++ .../kubernetes/connection/package-info.java | 23 + .../KubernetesConnectionConfiguration.java | 159 ++ .../kubernetes/configuration/package-info.java | 23 + .../kubernetes/TcpDiscoveryKubernetesIpFinder.java | 283 +- .../ignite/client/TestClusterClientConnection.java | 157 ++ .../KubernetesServiceAddressResolverTest.java | 209 ++ .../KubernetesConnectionConfigurationTest.java | 73 + .../testsuites/IgniteKubernetesTestSuite.java | 10 +- .../ml/math/distances/BrayCurtisDistance.java | 54 + .../ignite/ml/math/distances/CanberraDistance.java | 64 + .../ml/math/distances/JensenShannonDistance.java | 91 + .../math/distances/WeightedMinkowskiDistance.java | 73 + .../ml/math/primitives/vector/AbstractVector.java | 3 +- .../ml/selection/cv/AbstractCrossValidation.java | 44 +- .../ml/selection/cv/CrossValidationResult.java | 127 +- .../paramgrid/EvolutionOptimizationStrategy.java | 31 +- .../util/DatasetAffinityFunctionWrapperTest.java | 2 +- .../ml/math/distances/BrayCurtisDistanceTest.java | 103 + .../ml/math/distances/CanberraDistanceTest.java | 103 + .../ignite/ml/math/distances/DistanceTest.java | 55 + .../math/distances/JensenShannonDistanceTest.java | 105 + .../distances/WeightedMinkowskiDistanceTest.java | 112 + .../primitives/vector/VectorNormCasesTest.java | 103 + .../ml/math/primitives/vector/VectorNormTest.java | 2 +- modules/osgi-karaf/src/main/resources/features.xml | 6 +- modules/platforms/cpp/CMakeLists.txt | 13 + .../binary/include/ignite/binary/binary_consts.h | 2 +- .../include/ignite/binary/binary_containers.h | 2 +- .../include/ignite/binary/binary_raw_reader.h | 2 +- .../binary/include/ignite/binary/binary_reader.h | 2 +- .../include/ignite/impl/binary/binary_common.h | 34 +- .../include/ignite/impl/binary/binary_field_meta.h | 2 +- .../ignite/impl/binary/binary_object_header.h | 2 +- .../ignite/impl/binary/binary_object_impl.h | 5 +- .../ignite/impl/binary/binary_reader_impl.h | 7 +- .../include/ignite/impl/binary/binary_schema.h | 4 +- .../ignite/impl/binary/binary_type_handler.h | 4 +- .../ignite/impl/binary/binary_type_manager.h | 2 +- .../ignite/impl/binary/binary_type_snapshot.h | 2 +- .../ignite/impl/binary/binary_type_updater.h | 2 +- .../ignite/impl/binary/binary_writer_impl.h | 58 +- .../binary/include/ignite/impl/interop/interop.h | 2 +- .../ignite/impl/interop/interop_input_stream.h | 34 +- .../include/ignite/impl/interop/interop_memory.h | 9 +- .../ignite/impl/interop/interop_output_stream.h | 4 +- .../impl/interop/interop_stream_position_guard.h | 2 +- .../cpp/binary/src/binary/binary_containers.cpp | 2 +- .../cpp/binary/src/binary/binary_raw_reader.cpp | 2 +- .../cpp/binary/src/binary/binary_raw_writer.cpp | 2 +- .../cpp/binary/src/binary/binary_reader.cpp | 2 +- .../cpp/binary/src/binary/binary_type.cpp | 2 +- .../cpp/binary/src/binary/binary_writer.cpp | 2 +- .../binary/src/impl/binary/binary_object_impl.cpp | 25 +- .../binary/src/impl/binary/binary_reader_impl.cpp | 146 + .../cpp/binary/src/impl/binary/binary_schema.cpp | 6 +- .../binary/src/impl/binary/binary_type_handler.cpp | 2 +- .../binary/src/impl/binary/binary_type_manager.cpp | 6 +- .../src/impl/binary/binary_type_snapshot.cpp | 2 +- .../cpp/binary/src/impl/binary/binary_utils.cpp | 2 +- .../binary/src/impl/binary/binary_writer_impl.cpp | 81 +- .../src/impl/interop/interop_input_stream.cpp | 13 +- .../cpp/binary/src/impl/interop/interop_memory.cpp | 2 +- .../cpp/common/include/ignite/common/big_integer.h | 8 +- .../cpp/common/include/ignite/common/bits.h | 2 +- .../cpp/common/include/ignite/common/concurrent.h | 13 +- .../cpp/common/include/ignite/common/decimal.h | 4 +- .../include/ignite/common/default_allocator.h | 6 +- .../include/ignite/common/dynamic_size_array.h | 2 +- .../include/ignite/common/fixed_size_array.h | 2 +- .../common/include/ignite/common/platform_utils.h | 2 +- .../cpp/common/include/ignite/common/promise.h | 8 +- .../cpp/common/include/ignite/common/utils.h | 17 +- modules/platforms/cpp/common/include/ignite/guid.h | 4 +- .../cpp/common/include/ignite/ignite_predicate.h | 49 + .../common/os/linux/include/ignite/common/common.h | 6 +- .../os/linux/include/ignite/common/concurrent_os.h | 34 +- .../common/os/linux/src/common/platform_utils.cpp | 2 +- .../common/os/win/include/ignite/common/common.h | 2 + .../platforms/cpp/common/project/vs/common.vcxproj | 1 + .../cpp/common/project/vs/common.vcxproj.filters | 3 + .../cpp/common/src/common/big_integer.cpp | 16 +- modules/platforms/cpp/common/src/common/bits.cpp | 40 +- .../platforms/cpp/common/src/common/concurrent.cpp | 2 +- .../platforms/cpp/common/src/common/decimal.cpp | 2 +- modules/platforms/cpp/common/src/common/utils.cpp | 35 +- modules/platforms/cpp/common/src/guid.cpp | 2 +- modules/platforms/cpp/core-test/CMakeLists.txt | 5 +- .../config/cache-native-persistence-test-32.xml | 52 + .../cache-native-persistence-test-default.xml | 138 + .../config/cache-native-persistence-test.xml | 34 + .../cpp/core-test/config/cache-test-default.xml | 20 +- .../cpp/core-test/config/compute-client-32.xml | 52 + .../core-test/config/compute-client-default.xml | 70 + .../cpp/core-test/config/compute-client.xml | 34 + .../cpp/core-test/config/compute-server0-32.xml | 52 + .../core-test/config/compute-server0-default.xml | 139 + .../cpp/core-test/config/compute-server0.xml | 34 + .../cpp/core-test/config/compute-server1-32.xml | 52 + .../core-test/config/compute-server1-default.xml | 139 + .../cpp/core-test/config/compute-server1.xml | 34 + .../core-test/include/ignite/binary_test_defs.h | 8 +- .../core-test/include/ignite/binary_test_utils.h | 34 +- .../cpp/core-test/include/ignite/complex_type.h | 2 +- .../cpp/core-test/include/ignite/test_type.h | 2 +- .../cpp/core-test/include/ignite/test_utils.h | 49 +- .../cpp/core-test/project/vs/core-test.vcxproj | 18 +- .../core-test/project/vs/core-test.vcxproj.filters | 50 +- .../platforms/cpp/core-test/src/affinity_test.cpp | 156 ++ .../src/binary_reader_writer_raw_test.cpp | 130 +- .../core-test/src/binary_reader_writer_test.cpp | 2 +- modules/platforms/cpp/core-test/src/cache_test.cpp | 64 + .../cpp/core-test/src/cluster_group_test.cpp | 563 ++++ .../cpp/core-test/src/cluster_node_test.cpp | 261 ++ .../platforms/cpp/core-test/src/cluster_test.cpp | 308 +- .../platforms/cpp/core-test/src/compute_test.cpp | 477 +++- .../cpp/core-test/src/continuous_query_test.cpp | 7 +- .../platforms/cpp/core-test/src/decimal_test.cpp | 110 +- .../platforms/cpp/core-test/src/ignition_test.cpp | 32 +- .../cpp/core-test/src/interop_memory_test.cpp | 4 +- .../platforms/cpp/core-test/src/teamcity_boost.cpp | 11 +- modules/platforms/cpp/core-test/src/test_utils.cpp | 17 + .../cpp/core-test/src/transactions_test.cpp | 8 + modules/platforms/cpp/core/CMakeLists.txt | 8 +- .../cpp/core/include/ignite/cache/cache.h | 2 +- .../cpp/core/include/ignite/cache/cache_affinity.h | 241 ++ .../include/ignite/cache/query/query_sql_fields.h | 2 +- .../core/include/ignite/cluster/cluster_group.h | 246 ++ .../cpp/core/include/ignite/cluster/cluster_node.h | 157 ++ .../core/include/ignite/cluster/ignite_cluster.h | 152 + .../cpp/core/include/ignite/compute/compute.h | 83 + .../cpp/core/include/ignite/compute/compute_func.h | 40 + modules/platforms/cpp/core/include/ignite/ignite.h | 45 +- .../core/include/ignite/ignite_product_version.h | 70 + .../ignite/impl/binary/binary_type_updater_impl.h | 4 +- .../ignite/impl/cache/cache_affinity_impl.h | 404 +++ .../core/include/ignite/impl/cache/cache_impl.h | 6 +- .../impl/cache/query/query_fields_row_impl.h | 4 +- .../ignite/impl/cluster/cluster_group_impl.h | 339 ++- .../ignite/impl/cluster/cluster_node_impl.h | 238 ++ .../ignite/impl/cluster/ignite_cluster_impl.h | 160 ++ .../include/ignite/impl/compute/compute_impl.h | 119 +- .../ignite/impl/compute/compute_job_holder.h | 18 +- .../ignite/impl/compute/compute_task_holder.h | 18 +- .../compute/multiple_job_compute_task_holder.h | 66 +- .../impl/compute/single_job_compute_task_holder.h | 50 +- .../core/include/ignite/impl/ignite_binding_impl.h | 5 +- .../core/include/ignite/impl/ignite_environment.h | 76 +- .../cpp/core/include/ignite/impl/ignite_impl.h | 105 +- .../ignite/impl/interop/interop_external_memory.h | 4 +- .../include/ignite/impl/interop/interop_target.h | 32 +- .../cpp/core/include/ignite/impl/operations.h | 30 +- .../ignite/impl/transactions/transaction_impl.h | 4 +- .../ignite/impl/transactions/transactions_impl.h | 4 +- modules/platforms/cpp/core/project/vs/core.vcxproj | 14 + .../cpp/core/project/vs/core.vcxproj.filters | 45 + .../cpp/core/src/cluster/cluster_group.cpp | 160 ++ .../cpp/core/src/cluster/cluster_node.cpp | 88 + .../cpp/core/src/cluster/ignite_cluster.cpp | 99 + modules/platforms/cpp/core/src/ignite.cpp | 10 + modules/platforms/cpp/core/src/ignition.cpp | 24 +- .../src/impl/binary/binary_type_updater_impl.cpp | 2 +- .../core/src/impl/cache/cache_affinity_impl.cpp | 167 ++ .../cpp/core/src/impl/cache/cache_impl.cpp | 6 +- .../cpp/core/src/impl/cache/query/query_impl.cpp | 5 +- .../core/src/impl/cluster/cluster_group_impl.cpp | 588 +++- .../core/src/impl/cluster/cluster_node_impl.cpp | 182 ++ .../core/src/impl/cluster/ignite_cluster_impl.cpp | 109 + .../cpp/core/src/impl/ignite_environment.cpp | 264 +- .../platforms/cpp/core/src/impl/ignite_impl.cpp | 140 +- .../cpp/core/src/impl/interop/interop_target.cpp | 63 +- .../src/impl/transactions/transactions_impl.cpp | 8 +- .../cluster-compute-example/CMakeLists.txt | 30 + .../config/cluster-compute-example-client.xml | 55 + .../config/cluster-compute-example1.xml | 59 + .../config/cluster-compute-example2.xml | 59 + .../project/vs/cluster-compute-example.vcxproj | 104 + .../vs/cluster-compute-example.vcxproj.filters | 33 + .../src/cluster_compute_example.cpp | 157 ++ .../cpp/examples/project/vs/ignite-examples.sln | 6 + .../platforms/cpp/jni/include/ignite/jni/exports.h | 24 +- .../platforms/cpp/jni/include/ignite/jni/java.h | 184 +- .../platforms/cpp/jni/include/ignite/jni/utils.h | 2 +- modules/platforms/cpp/jni/src/exports.cpp | 24 +- modules/platforms/cpp/jni/src/java.cpp | 64 +- .../os/linux/src/network/tcp_socket_client.cpp | 4 +- .../cpp/network/src/network/ssl/ssl_gateway.cpp | 2 +- .../cpp/network/src/network/tcp_socket_client.h | 4 +- .../platforms/cpp/odbc-test/include/complex_type.h | 2 +- .../cpp/odbc-test/include/sql_test_suite_fixture.h | 4 +- .../platforms/cpp/odbc-test/include/test_type.h | 2 +- .../odbc-test/src/application_data_buffer_test.cpp | 36 +- .../cpp/odbc-test/src/attributes_test.cpp | 2 +- .../cpp/odbc-test/src/odbc_test_suite.cpp | 5 +- .../platforms/cpp/odbc-test/src/queries_test.cpp | 68 +- modules/platforms/cpp/odbc-test/src/row_test.cpp | 20 +- .../cpp/odbc-test/src/sql_operators_test.cpp | 58 +- .../cpp/odbc-test/src/sql_test_suite_fixture.cpp | 11 +- .../platforms/cpp/odbc-test/src/sql_types_test.cpp | 5 +- .../cpp/odbc-test/src/teamcity/teamcity_boost.cpp | 11 +- .../cpp/odbc/include/ignite/odbc/connection.h | 2 +- .../odbc/include/ignite/odbc/meta/column_meta.h | 4 +- .../include/ignite/odbc/query/internal_query.h | 6 +- .../cpp/odbc/src/app/application_data_buffer.cpp | 12 +- modules/platforms/cpp/odbc/src/app/parameter.cpp | 2 +- .../platforms/cpp/odbc/src/app/parameter_set.cpp | 2 +- .../platforms/cpp/odbc/src/config/config_tools.cpp | 2 +- .../odbc/src/config/connection_string_parser.cpp | 6 +- modules/platforms/cpp/odbc/src/connection.cpp | 4 +- modules/platforms/cpp/odbc/src/entry_points.cpp | 146 + modules/platforms/cpp/odbc/src/environment.cpp | 2 + modules/platforms/cpp/odbc/src/message.cpp | 3 +- modules/platforms/cpp/odbc/src/odbc.cpp | 9 + .../platforms/cpp/odbc/src/query/batch_query.cpp | 4 +- .../cpp/odbc/src/query/column_metadata_query.cpp | 8 +- .../cpp/odbc/src/query/foreign_keys_query.cpp | 4 +- .../cpp/odbc/src/query/special_columns_query.cpp | 4 +- .../cpp/odbc/src/query/type_info_query.cpp | 18 +- .../cpp/odbc/src/sql/sql_set_streaming_command.cpp | 3 +- modules/platforms/cpp/odbc/src/statement.cpp | 4 +- modules/platforms/cpp/odbc/src/type_traits.cpp | 4 +- modules/platforms/cpp/odbc/src/utility.cpp | 2 + .../thin-client-test/include/ignite/complex_type.h | 2 +- .../src/teamcity/teamcity_boost.cpp | 11 +- .../cpp/thin-client/include/ignite/thin/ssl_mode.h | 2 +- .../ignite/thin/transactions/transactions.h | 3 +- .../cpp/thin-client/src/ignite_client.cpp | 15 - .../src/impl/cache/cache_client_proxy.cpp | 5 - .../platforms/cpp/thin-client/src/impl/message.cpp | 2 +- .../platforms/cpp/thin-client/src/impl/message.h | 22 +- .../cpp/thin-client/src/impl/response_status.h | 4 +- .../src/impl/transactions/transaction_impl.h | 2 +- .../src/impl/transactions/transactions_impl.cpp | 2 +- .../src/impl/transactions/transactions_impl.h | 2 +- .../platforms/cpp/thin-client/src/impl/utility.cpp | 2 +- .../Apache.Ignite.Core.Tests.csproj | 1 + .../Binary/BinarySelfTest.cs | 27 + .../Platform/PlatformCacheTopologyChangeTest.cs | 33 +- .../Compatibility/ClientServerCompatibilityTest.cs | 7 +- .../dotnet/Apache.Ignite.Core.Tests/JavaServer.cs | 96 +- .../Apache.Ignite.Core.Tests/TestUtilsJni.cs | 126 + .../Apache.Ignite.Core/Cache/ICacheAffinity.cs | 2 +- .../Apache.Ignite.Core/Impl/Binary/BinaryObject.cs | 2 +- .../Apache.Ignite.Core/Impl/Binary/BinaryWriter.cs | 26 +- .../repository/query/IgniteQueryGenerator.java | 29 +- .../IgniteSpringDataCompoundKeyTest.java | 125 + .../apache/ignite/springdata/compoundkey/City.java | 113 + .../ignite/springdata/compoundkey/CityKey.java | 76 + .../springdata/compoundkey/CityRepository.java | 43 + .../CompoundKeyApplicationConfiguration.java | 39 + .../testsuites/IgniteSpringData2TestSuite.java | 4 +- .../repository/query/IgniteQueryGenerator.java | 29 +- .../IgniteSpringDataCompoundKeyTest.java | 125 + .../apache/ignite/springdata/compoundkey/City.java | 113 + .../ignite/springdata/compoundkey/CityKey.java | 79 + .../springdata/compoundkey/CityRepository.java | 43 + .../CompoundKeyApplicationConfiguration.java | 39 + .../testsuites/IgniteSpringData22TestSuite.java | 4 +- .../repository/query/IgniteQueryGenerator.java | 29 +- .../IgniteSpringDataCompoundKeyTest.java | 116 + .../apache/ignite/springdata/compoundkey/City.java | 113 + .../ignite/springdata/compoundkey/CityKey.java | 79 + .../springdata/compoundkey/CityRepository.java | 43 + .../CompoundKeyApplicationConfiguration.java | 39 + .../testsuites/IgniteSpringDataTestSuite.java | 4 +- .../zk/internal/ZookeeperDiscoveryImpl.java | 8 +- .../zk/internal/ZookeeperDiscoveryMiscTest.java | 18 + parent/pom.xml | 11 +- pom.xml | 1 - 1262 files changed, 96735 insertions(+), 7298 deletions(-)