You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2019/01/21 17:00:25 UTC
[ignite] 01/01: Merge remote-tracking branch
'remotes/origin/master' into ignite-601
This is an automated email from the ASF dual-hosted git repository.
sboikov pushed a commit to branch ignite-601
in repository https://gitbox.apache.org/repos/asf/ignite.git
commit 3b77455aca882e1bc749a46bb969ec4156cbab6f
Merge: 0b4e230 4a3213b
Author: sboikov <sb...@apache.org>
AuthorDate: Mon Jan 21 19:58:59 2019 +0300
Merge remote-tracking branch 'remotes/origin/master' into ignite-601
bin/ignite.bat | 6 +-
bin/include/parseargs.sh | 10 +
doap_Ignite.rdf | 4 +-
examples/pom.xml | 24 +
.../ml/TrainingWithBinaryObjectExample.java | 85 +
.../ml/clustering/KMeansClusterizationExample.java | 2 +-
.../ml/genetic/helloworld/HelloWorldGAExample.java | 23 +-
...=> IgniteModelDistributedInferenceExample.java} | 22 +-
.../examples/ml/inference/ModelStorageExample.java | 22 +-
.../TensorFlowDistributedInferenceExample.java | 20 +-
.../inference/TensorFlowLocalInferenceExample.java | 20 +-
.../TensorFlowThreadedInferenceExample.java | 20 +-
.../LogRegFromSparkThroughPMMLExample.java | 2 +-
...LogRegFromSparkViaSparkModelParserExample.java} | 58 +-
.../examples/ml/inference/spark/package-info.java | 14 +-
.../examples/ml/knn/ANNClassificationExample.java | 2 +-
.../examples/ml/knn/KNNClassificationExample.java | 52 +-
.../examples/ml/knn/KNNRegressionExample.java | 6 +-
.../multiclass/OneVsRestClassificationExample.java | 4 +-
.../DiscreteNaiveBayesTrainerExample.java | 53 +-
.../GaussianNaiveBayesTrainerExample.java | 55 +-
.../ignite/examples/ml/nn/MLPTrainerExample.java | 2 +-
.../linear/LinearRegressionLSQRTrainerExample.java | 2 +-
...gressionLSQRTrainerWithMinMaxScalerExample.java | 2 +-
.../linear/LinearRegressionSGDTrainerExample.java | 2 +-
.../BaggedLogisticRegressionSGDTrainerExample.java | 8 +-
.../LogisticRegressionSGDTrainerExample.java | 54 +-
.../ml/selection/scoring/EvaluatorExample.java | 10 +-
.../split/TrainTestDatasetSplitterExample.java | 2 +-
.../ml/svm/SVMBinaryClassificationExample.java | 59 +-
.../DecisionTreeClassificationTrainerExample.java | 2 +-
.../tree/DecisionTreeRegressionTrainerExample.java | 2 +-
.../GDBOnTreesClassificationTrainerExample.java | 2 +-
.../GDBOnTreesRegressionTrainerExample.java | 4 +-
.../RandomForestClassificationExample.java | 2 +-
.../RandomForestRegressionExample.java | 2 +-
.../ml/tutorial/Step_10_Scaling_With_Stacking.java | 142 +
.../ml/xgboost/XGBoostModelParserExample.java | 18 +-
.../resources/models/mleap/airbnb.model.rf.zip | Bin 0 -> 35932 bytes
.../models/spark/serialized/data/._SUCCESS.crc | Bin 0 -> 8 bytes
...-4ed7-afe4-a464aabc7f80-c000.snappy.parquet.crc | Bin 0 -> 40 bytes
.../models/spark/serialized/data/_SUCCESS | 0
...c0a8-4ed7-afe4-a464aabc7f80-c000.snappy.parquet | Bin 0 -> 3839 bytes
.../models/spark/serialized/metadata/._SUCCESS.crc | Bin 0 -> 8 bytes
.../spark/serialized/metadata/.part-00000.crc | Bin 0 -> 12 bytes
.../models/spark/serialized/metadata/_SUCCESS | 0
.../models/spark/serialized/metadata/part-00000 | 1 +
.../examples/ml/mleap/MLeapModelParserExample.java | 73 +
.../ignite/examples/ml/mleap/package-info.java | 14 +-
.../ignite/testsuites/IgniteAopSelfTestSuite.java | 37 +-
.../checkpoint/s3/S3CheckpointManagerSelfTest.java | 6 +-
.../spi/checkpoint/s3/S3CheckpointSpiSelfTest.java | 8 +-
.../s3/S3CheckpointSpiStartStopSelfTest.java | 4 +-
.../checkpoint/s3/S3SessionCheckpointSelfTest.java | 4 +-
.../s3/TcpDiscoveryS3IpFinderAbstractSelfTest.java | 4 +-
.../ignite/testsuites/IgniteElbTestSuite.java | 18 +-
.../ignite/testsuites/IgniteS3TestSuite.java | 65 +-
modules/benchmarks/pom.xml | 6 +
.../SmallHashSetsVsReadOnlyViewBenchmark.java | 154 +
.../jol/GridAffinityAssignmentJolBenchmark.java | 177 +
.../ignite/internal/benchmarks/model/Node.java} | 27 +-
.../stream/camel/IgniteCamelStreamerTestSuite.java | 26 +-
modules/cassandra/store/pom.xml | 4 +-
.../apache/ignite/tests/utils/CassandraHelper.java | 4 +-
.../ignite/tests/utils/CassandraLifeCycleBean.java | 1 +
.../client/ClientReconnectionSelfTest.java | 4 +-
.../client/suite/IgniteClientTestSuite.java | 198 +-
.../jdbc2/JdbcAbstractDmlStatementSelfTest.java | 2 +-
.../jdbc/suite/IgniteJdbcDriverTestSuite.java | 4 +
.../jdbc/thin/JdbcThinStatementCancelSelfTest.java | 769 +
.../jdbc/thin/JdbcThinStatementSelfTest.java | 95 -
.../thin/JdbcThinStatementTimeoutSelfTest.java | 312 +
...dbcThinTransactionsAbstractComplexSelfTest.java | 2 +-
.../clients/src/test/resources/bulkload20_000.csv | 20000 +++++++++++++++++++
.../cloud/TcpDiscoveryCloudIpFinderSelfTest.java | 12 +-
.../ignite/testsuites/IgniteCloudTestSuite.java | 20 +-
.../IgniteCompatibilityBasicTestSuite.java | 26 +-
.../testsuites/IgnitePdsCompressionTestSuite.java | 30 +-
.../testsuites/IgnitePdsCompressionTestSuite2.java | 19 +-
.../ignite/IgniteCacheRestartingException.java | 25 +-
.../main/java/org/apache/ignite/IgniteCluster.java | 8 +
.../org/apache/ignite/IgniteSystemProperties.java | 28 +
.../cache/query/QueryCancelledException.java | 5 +-
.../ignite/configuration/IgniteConfiguration.java | 87 +-
.../org/apache/ignite/internal/GridComponent.java | 5 +-
.../apache/ignite/internal/GridKernalContext.java | 26 +-
.../ignite/internal/GridKernalContextImpl.java | 24 +
.../org/apache/ignite/internal/IgniteKernal.java | 46 +-
.../internal/binary/BinaryMetadataHandler.java | 10 +-
.../cluster/DistributedBaselineConfiguration.java | 109 +
.../internal/cluster/IgniteClusterAsyncImpl.java | 5 +
.../ignite/internal/cluster/IgniteClusterImpl.java | 50 +-
.../internal/commandline/CommandHandler.java | 76 +-
.../internal/commandline/cache/CacheArguments.java | 34 +
.../internal/jdbc/thin/JdbcThinConnection.java | 148 +-
.../internal/jdbc/thin/JdbcThinResultSet.java | 54 +-
.../internal/jdbc/thin/JdbcThinStatement.java | 188 +-
.../ignite/internal/jdbc/thin/JdbcThinTcpIo.java | 93 +-
.../managers/communication/GridIoManager.java | 8 +-
.../communication/GridIoMessageFactory.java | 12 +-
.../managers/discovery/ConsistentIdMapper.java | 10 +-
.../managers/discovery/GridDiscoveryManager.java | 6 +-
.../managers/encryption/GridEncryptionManager.java | 18 +-
.../processors/affinity/AffinityAssignment.java | 34 +-
.../affinity/GridAffinityAssignment.java | 133 +-
.../processors/affinity/GridAffinityUtils.java | 2 +-
.../affinity/HistoryAffinityAssignment.java | 45 +-
.../IgniteAuthenticationProcessor.java | 14 +-
.../cache/AutoClosableCursorIterator.java} | 49 +-
.../cache/CacheAffinitySharedManager.java | 2 +-
.../processors/cache/CacheEvictionManager.java | 6 +-
.../cache/CacheOffheapEvictionManager.java | 5 +-
.../processors/cache/ClusterCachesInfo.java | 571 +-
.../cache/DynamicCacheChangeRequest.java | 22 +-
.../processors/cache/ExchangeDiscoveryEvents.java | 5 -
.../cache/GatewayProtectedCacheProxy.java | 25 +-
.../processors/cache/GridCacheAdapter.java | 27 +-
.../cache/GridCacheConcurrentMapImpl.java | 2 +-
.../processors/cache/GridCacheContext.java | 2 +-
.../processors/cache/GridCacheEntryEx.java | 16 +-
.../processors/cache/GridCacheEvictionManager.java | 3 +-
.../processors/cache/GridCacheIoManager.java | 23 +-
.../processors/cache/GridCacheMapEntry.java | 138 +-
.../processors/cache/GridCacheMvccManager.java | 36 +-
.../cache/GridCachePartitionExchangeManager.java | 42 +-
.../processors/cache/GridCacheProcessor.java | 152 +-
.../processors/cache/GridCacheTtlManager.java | 2 +-
.../processors/cache/GridCacheUpdateTxResult.java | 26 -
.../internal/processors/cache/GridCacheUtils.java | 17 +-
.../cache/IgniteCacheOffheapManager.java | 81 -
.../cache/IgniteCacheOffheapManagerImpl.java | 191 -
.../processors/cache/IgniteCacheProxyImpl.java | 457 +-
.../internal/processors/cache/QueryCursorImpl.java | 19 +-
.../internal/processors/cache/WalStateManager.java | 9 +-
.../cache/binary/BinaryMetadataFileStore.java | 33 +-
.../processors/cache/binary/BinaryMetadataKey.java | 2 +-
.../binary/CacheObjectBinaryProcessorImpl.java | 16 +-
.../binary/MetadataUpdateProposedMessage.java | 12 +-
.../GridDistributedTxRemoteAdapter.java | 31 +-
.../cache/distributed/dht/GridDhtCacheAdapter.java | 6 +-
.../cache/distributed/dht/GridDhtGetFuture.java | 2 +-
.../distributed/dht/GridDhtGetSingleFuture.java | 2 +-
.../dht/GridDhtTransactionalCacheAdapter.java | 21 +-
.../dht/GridDhtTxAbstractEnlistFuture.java | 68 +-
.../distributed/dht/GridDhtTxEnlistFuture.java | 1 -
.../distributed/dht/GridDhtTxFinishFuture.java | 41 +-
.../distributed/dht/GridDhtTxPrepareFuture.java | 6 +-
.../dht/GridDhtTxQueryAbstractEnlistFuture.java | 8 +-
.../dht/GridDhtTxQueryEnlistFuture.java | 53 +-
.../dht/GridDhtTxQueryResultsEnlistFuture.java | 1 -
.../distributed/dht/GridPartitionedGetFuture.java | 66 +-
.../dht/GridPartitionedSingleGetFuture.java | 12 +-
.../dht/NearTxQueryEnlistResultHandler.java | 31 +-
.../distributed/dht/atomic/GridDhtAtomicCache.java | 25 +-
.../atomic/GridNearAtomicSingleUpdateFuture.java | 8 +-
.../dht/atomic/GridNearAtomicUpdateFuture.java | 8 +-
.../dht/colocated/GridDhtColocatedCache.java | 76 +-
.../dht/colocated/GridDhtColocatedLockFuture.java | 6 +-
.../CachePartitionPartialCountersMap.java | 2 +-
.../dht/preloader/GridDhtPartitionDemander.java | 4 +-
.../preloader/GridDhtPartitionsExchangeFuture.java | 52 +-
.../dht/topology/GridDhtPartitionTopologyImpl.java | 7 +-
.../distributed/near/AckCoordinatorOnRollback.java | 54 -
.../distributed/near/GridNearAtomicCache.java | 2 +-
.../cache/distributed/near/GridNearGetFuture.java | 21 +-
.../cache/distributed/near/GridNearLockFuture.java | 6 +-
.../near/GridNearPessimisticTxPrepareFuture.java | 2 +-
.../near/GridNearTransactionalCache.java | 6 +-
.../near/GridNearTxAbstractEnlistFuture.java | 19 +-
.../distributed/near/GridNearTxEnlistFuture.java | 2 -
.../near/GridNearTxFinishAndAckFuture.java | 109 +-
.../distributed/near/GridNearTxFinishFuture.java | 24 +-
.../cache/distributed/near/GridNearTxLocal.java | 110 +-
.../near/GridNearTxQueryEnlistFuture.java | 3 +-
.../distributed/near/TxTopologyVersionFuture.java | 12 +-
.../processors/cache/local/GridLocalCache.java | 2 +-
.../cache/local/atomic/GridLocalAtomicCache.java | 21 +-
.../processors/cache/mvcc/MvccCoordinator.java | 92 +-
.../cache/mvcc/MvccPreviousCoordinatorQueries.java | 6 +
.../processors/cache/mvcc/MvccProcessor.java | 87 +-
.../processors/cache/mvcc/MvccProcessorImpl.java | 642 +-
.../processors/cache/mvcc/MvccQueryTracker.java | 28 -
.../cache/mvcc/MvccQueryTrackerImpl.java | 326 +-
.../internal/processors/cache/mvcc/MvccUtils.java | 71 +-
.../cache/mvcc/StaticMvccQueryTracker.java | 17 -
.../cache/mvcc/msg/MvccWaitTxsRequest.java | 159 -
.../processors/cache/mvcc/txlog/TxLog.java | 7 +-
.../cache/persistence/DbCheckpointListener.java | 10 +
.../GridCacheDatabaseSharedManager.java | 183 +-
.../cache/persistence/GridCacheOffheapManager.java | 19 +-
.../cache/persistence/file/FilePageStore.java | 7 +
.../persistence/file/FilePageStoreManager.java | 109 +-
.../cache/persistence/metastorage/MetaStorage.java | 139 +-
.../metastorage/ReadOnlyMetastorage.java | 21 +-
.../metastorage/ReadWriteMetastorage.java | 3 +
.../pagemem/DelayedPageReplacementTracker.java | 8 +-
.../cache/persistence/pagemem/PageMemoryEx.java | 2 +-
.../cache/persistence/pagemem/PageMemoryImpl.java | 66 +-
.../pagemem/PagesWriteSpeedBasedThrottle.java | 4 +-
.../processors/cache/persistence/pagemem/README.md | 30 +-
.../wal/reader/StandaloneGridKernalContext.java | 12 +
.../cache/query/GridCacheQueryManager.java | 2 +-
.../cache/query/IgniteQueryErrorCode.java | 6 +
.../cache/store/GridCacheWriteBehindStore.java | 149 +-
.../cache/transactions/IgniteInternalTx.java | 3 +-
.../cache/transactions/IgniteTxAdapter.java | 56 +-
.../cache/transactions/IgniteTxHandler.java | 71 +-
.../IgniteTxImplicitSingleStateImpl.java | 6 +-
.../cache/transactions/IgniteTxLocalAdapter.java | 82 +-
.../cache/transactions/IgniteTxManager.java | 139 +-
.../cache/transactions/IgniteTxStateImpl.java | 6 +-
.../cache/tree/mvcc/data/MvccUpdateDataRow.java | 2 +-
.../tree/mvcc/data/MvccUpdateDataRowNative.java | 240 -
.../cache/verify/GridNotIdleException.java | 69 +
.../cache/verify/IdleVerifyException.java | 61 +
.../cache/verify/IdleVerifyResultV2.java | 124 +-
.../processors/cache/verify/IdleVerifyUtility.java | 120 +
.../verify/VerifyBackupPartitionsDumpTask.java | 108 +-
.../cache/verify/VerifyBackupPartitionsTaskV2.java | 381 +-
.../cacheobject/IgniteCacheObjectProcessor.java | 10 +-
.../cluster/GridClusterStateProcessor.java | 12 +-
.../distributed/DetachedPropertyException.java} | 15 +-
.../distributed/DistributedBooleanProperty.java} | 35 +-
.../distributed/DistributedComparableProperty.java | 63 +
...DistributedConfigurationLifecycleListener.java} | 16 +-
.../DistributedConfigurationProcessor.java | 281 +
.../distributed/DistributedLongProperty.java} | 35 +-
.../distributed/DistributedProperty.java | 118 +
.../distributed/DistributedPropertyDispatcher.java | 53 +
.../processors/datastreamer/DataStreamerImpl.java | 2 +-
.../datastructures/AtomicDataStructureProxy.java | 2 +-
.../datastructures/DataStructuresProcessor.java | 22 +-
.../datastructures/GridCacheRemovable.java | 7 +
.../datastructures/GridCacheSetProxy.java | 2 +-
.../metastorage/DistributedMetaStorage.java | 74 +
.../DistributedMetaStorageListener.java} | 27 +-
.../DistributedMetastorageLifecycleListener.java | 43 +
.../ReadableDistributedMetaStorage.java | 62 +
.../persistence/DistributedMetaStorageBridge.java | 91 +
.../DistributedMetaStorageCasAckMessage.java} | 34 +-
.../DistributedMetaStorageCasMessage.java | 67 +
.../DistributedMetaStorageClusterNodeData.java} | 48 +-
.../DistributedMetaStorageHistoryItem.java | 76 +
.../persistence/DistributedMetaStorageImpl.java | 1169 ++
.../DistributedMetaStorageJoiningNodeData.java} | 36 +-
.../DistributedMetaStorageUpdateAckMessage.java | 97 +
.../DistributedMetaStorageUpdateMessage.java | 119 +
.../persistence/DistributedMetaStorageUtil.java | 109 +
.../persistence/DistributedMetaStorageVersion.java | 159 +
.../EmptyDistributedMetaStorageBridge.java | 64 +
...InMemoryCachedDistributedMetaStorageBridge.java | 109 +
.../NotAvailableDistributedMetaStorageBridge.java | 62 +
.../ReadOnlyDistributedMetaStorageBridge.java | 212 +
.../metastorage/persistence/StartupExtras.java} | 18 +-
.../WritableDistributedMetaStorageBridge.java | 163 +
.../odbc/ClientListenerMessageParser.java | 20 +-
.../processors/odbc/ClientListenerNioListener.java | 11 +-
.../processors/odbc/ClientListenerProcessor.java | 44 +
.../odbc/ClientListenerRequestHandler.java | 27 +-
.../internal/processors/odbc/SqlStateCode.java | 3 +
.../odbc/jdbc/JdbcBatchExecuteRequest.java | 6 +-
.../odbc/jdbc/JdbcBulkLoadAckResult.java | 24 +-
.../odbc/jdbc/JdbcBulkLoadBatchRequest.java | 30 +-
.../odbc/jdbc/JdbcBulkLoadProcessor.java | 21 +-
.../odbc/jdbc/JdbcConnectionContext.java | 6 +-
.../JdbcCursor.java} | 45 +-
.../processors/odbc/jdbc/JdbcMessageParser.java | 17 +-
...ataRequest.java => JdbcQueryCancelRequest.java} | 36 +-
.../odbc/jdbc/JdbcQueryCloseRequest.java | 20 +-
.../processors/odbc/jdbc/JdbcQueryCursor.java | 28 +-
.../processors/odbc/jdbc/JdbcQueryDescriptor.java | 95 +
.../odbc/jdbc/JdbcQueryExecuteResult.java | 28 +-
.../odbc/jdbc/JdbcQueryFetchRequest.java | 22 +-
.../odbc/jdbc/JdbcQueryMetadataRequest.java | 20 +-
.../internal/processors/odbc/jdbc/JdbcRequest.java | 57 +-
.../processors/odbc/jdbc/JdbcRequestHandler.java | 544 +-
.../processors/odbc/jdbc/JdbcResultInfo.java | 20 +-
.../odbc/odbc/OdbcConnectionContext.java | 7 +-
.../processors/odbc/odbc/OdbcMessageParser.java | 13 +
.../processors/odbc/odbc/OdbcRequestHandler.java | 15 +
.../platform/client/ClientMessageParser.java | 14 +
.../platform/client/ClientRequestHandler.java | 16 +
.../platform/utils/PlatformConfigurationUtils.java | 12 +
.../processors/query/GridQueryProcessor.java | 58 +-
.../processors/query/RunningQueryManager.java | 17 +-
.../query/schema/SchemaIndexCacheVisitorImpl.java | 3 +-
.../rest/protocols/tcp/GridTcpRestNioListener.java | 146 +-
.../processors/service/GridServiceProcessor.java | 19 +-
.../processors/service/IgniteServiceProcessor.java | 3 +
.../service/ServiceDeploymentManager.java | 35 +-
.../GridInternalSubscriptionProcessor.java | 53 +-
.../apache/ignite/internal/util/BitSetIntSet.java | 184 +
.../apache/ignite/internal/util/IgniteUtils.java | 42 +
.../lang/IgniteThrowableBiConsumer.java} | 24 +-
.../org/apache/ignite/internal/util/typedef/X.java | 28 +-
.../internal/visor/baseline/VisorBaselineTask.java | 4 +
.../cache/VisorCacheConfigurationCollectorJob.java | 3 +-
.../cache/VisorCacheMetricsCollectorTask.java | 15 +-
.../visor/cache/VisorCachePartitionsTask.java | 5 +-
.../visor/verify/VisorIdleVerifyDumpTaskArg.java | 63 +-
.../internal/visor/verify/VisorIdleVerifyJob.java | 13 +-
.../visor/verify/VisorIdleVerifyTaskArg.java | 94 +-
.../visor/verify/VisorIdleVerifyTaskV2.java | 58 +-
.../ignite/marshaller/jdk/JdkMarshaller.java | 3 +
.../ignite/spi/discovery/tcp/ClientImpl.java | 11 +-
.../ignite/spi/discovery/tcp/ServerImpl.java | 36 +-
.../tcp/ipfinder/TcpDiscoveryIpFinderAdapter.java | 34 +-
.../multicast/TcpDiscoveryMulticastIpFinder.java | 213 +-
.../sharedfs/TcpDiscoverySharedFsIpFinder.java | 7 +
.../startup/cmdline/CommandLineTransformer.java | 10 +-
.../org.apache.ignite.plugin.PluginProvider | 1 +
.../RendezvousAffinityFunctionSelfTest.java | 7 +
.../RendezvousAffinityFunctionSimpleBenchmark.java | 7 +
...JdbcPojoWriteBehindStoreWithCoalescingTest.java | 680 +
.../store/jdbc/model/TestJdbcPojoDataSource.java | 523 +
.../jdbc/model/TestJdbcPojoDataSourceFactory.java | 106 +
.../TestJdbcPojoStoreFactoryWithHangWriteAll.java | 136 +
.../ignite/cache/store/jdbc/model/TestPojo.java | 117 +
.../ignite/internal/ClusterGroupSelfTest.java | 7 +
.../ignite/internal/GridCommunicationSelfTest.java | 7 +
.../ignite/internal/GridDiscoverySelfTest.java | 7 +
.../ignite/internal/GridEventStorageSelfTest.java | 8 +
.../GridFailedInputParametersSelfTest.java | 7 +
.../GridJobStealingZeroActiveJobsSelfTest.java | 1 +
.../BinaryObjectBuilderAdditionalSelfTest.java | 7 +-
.../BinaryObjectBuilderDefaultMappersSelfTest.java | 8 +-
.../encryption/EncryptedCacheDestroyTest.java | 4 +-
.../affinity/GridAffinityAssignmentTest.java | 217 +
...GridAffinityAssignmentTestNoOptimizations.java} | 37 +-
.../AuthenticationProcessorNodeRestartTest.java | 4 +-
.../cache/CacheEntryProcessorCopySelfTest.java | 3 +-
.../cache/CacheLocalGetSerializationTest.java | 68 +
.../cache/GridCacheAbstractFullApiSelfTest.java | 2 +-
.../GridCacheMultinodeUpdateAbstractSelfTest.java | 20 +-
.../cache/GridCacheReferenceCleanupSelfTest.java | 6 -
.../processors/cache/GridCacheTestEntryEx.java | 17 +-
...ridProjectionForCachesOnDaemonNodeSelfTest.java | 8 +
.../IgniteCacheConfigVariationsFullApiTest.java | 2 +-
.../IgniteCacheEntryProcessorNodeJoinTest.java | 7 -
.../processors/cache/IgniteCacheGroupsTest.java | 1 -
.../cache/IgniteCacheInterceptorSelfTestSuite.java | 26 +-
.../cache/IgniteClusterActivateDeactivateTest.java | 7 +
...usterActivateDeactivateTestWithPersistence.java | 18 +
.../cache/IgniteDynamicCacheStartSelfTest.java | 66 +-
.../cache/IgnitePdsDataRegionMetricsTxTest.java | 14 +-
.../cache/WalModeChangeAdvancedSelfTest.java | 8 +-
.../distributed/CacheBaselineTopologyTest.java | 113 +-
.../CacheLateAffinityAssignmentTest.java | 2 +-
.../distributed/GridCacheLockAbstractTest.java | 11 +
.../IgniteCacheClientNodeChangingTopologyTest.java | 2 +-
.../distributed/IgniteCachePrimarySyncTest.java | 4 +-
.../distributed/IgniteTxCachePrimarySyncTest.java | 14 +-
.../distributed/IgniteTxPreloadAbstractTest.java | 6 -
.../CachePartitionPartialCountersMapSelfTest.java | 16 +-
.../dht/GridCacheDhtPreloadDelayedSelfTest.java | 6 +-
.../dht/GridCacheTxNodeFailureSelfTest.java | 2 +-
.../near/GridPartitionedBackupLoadSelfTest.java | 4 +
...eRebalanceOnCachesStoppingOrDestroyingTest.java | 207 +-
.../SortedEvictionPolicyPerformanceTest.java | 7 +
.../expiry/IgniteCacheExpiryPolicyTestSuite.java | 59 +-
.../GridCacheLocalByteArrayValuesSelfTest.java | 1 +
.../CacheMvccAbstractCoordinatorFailoverTest.java | 4 -
.../cache/mvcc/CacheMvccAbstractTest.java | 24 +-
...acheMvccPartitionedCoordinatorFailoverTest.java | 7 -
.../cache/mvcc/CacheMvccTransactionsTest.java | 6 +-
.../cache/mvcc/MvccUnsupportedTxModesTest.java | 17 +-
...itePdsCacheStartStopWithFreqCheckpointTest.java | 2 +-
.../IgnitePdsNoSpaceLeftOnDeviceTest.java | 154 +
.../db/IgnitePdsDataRegionMetricsTest.java | 7 +-
.../db/checkpoint/IgniteMassLoadSandboxTest.java | 10 +-
.../db/file/IgnitePdsThreadInterruptionTest.java | 206 +-
.../metastorage/IgniteMetaStorageBasicTest.java | 75 +-
.../wal/CpTriggeredWalDeltaConsistencyTest.java | 4 -
.../wal/ExplicitWalDeltaConsistencyTest.java | 5 +-
.../wal/SysPropWalDeltaConsistencyTest.java | 4 -
.../wal/memtracker/PageMemoryTracker.java | 102 +-
...ContinuousQueryAsyncFailoverMvccTxSelfTest.java | 6 -
...CacheContinuousQueryFailoverMvccTxSelfTest.java | 6 -
.../store/GridCacheWriteBehindStoreSelfTest.java | 4 +
.../TxDataConsistencyOnCommitFailureTest.java | 4 +-
.../cache/transactions/TxRollbackAsyncTest.java | 3 -
.../distributed/DistributedConfigurationTest.java | 242 +
.../TestDistibutedConfigurationPlugin.java | 119 +
.../DataStreamProcessorMvccSelfTest.java | 1 -
...erIpcEndpointRegistrationOnWindowsSelfTest.java | 15 +-
.../DistributedMetaStoragePersistentTest.java | 698 +
.../metastorage/DistributedMetaStorageTest.java | 366 +
.../processors/rest/RestProtocolStartTest.java | 134 +
.../GridServiceProcessorMultiNodeSelfTest.java | 10 +-
.../service/GridServiceProcessorStopSelfTest.java | 75 +
.../ignite/internal/util/BitSetIntSetTest.java | 339 +
...GridStartupWithUndefinedIgniteHomeSelfTest.java | 12 +-
.../ignite/internal/util/IgniteUtilsSelfTest.java | 20 +-
.../tcp/TcpClientDiscoverySpiMulticastTest.java | 8 +-
.../GridInternalTasksLoadBalancingSelfTest.java | 7 +
.../GridCommandLineTransformerSelfTest.java | 6 +-
.../apache/ignite/testframework/GridTestUtils.java | 21 +-
.../ignite/testframework/IgniteTestSuite.java | 429 -
.../ConfigVariationsTestSuiteBuilder.java | 4 +-
.../testframework/junits/GridAbstractTest.java | 18 +-
.../junits/common/GridCommonAbstractTest.java | 12 +-
.../junits/multijvm/IgniteClusterProcessProxy.java | 6 +
.../ignite/testsuites/IgniteBasicTestSuite.java | 247 +-
.../IgniteBasicWithPersistenceTestSuite.java | 69 +-
.../testsuites/IgniteBinaryCacheTestSuite.java | 24 +-
.../IgniteBinaryObjectsCacheTestSuite3.java | 26 +-
.../IgniteBinaryObjectsComputeGridTestSuite.java | 20 +-
...bjectsSimpleNameMapperComputeGridTestSuite.java | 16 +-
.../testsuites/IgniteBinaryObjectsTestSuite.java | 163 +-
...IgniteBinarySimpleNameMapperBasicTestSuite.java | 17 +-
...acheBlockExchangeOnReadOperationsTestSuite.java | 31 +-
.../IgniteCacheEvictionSelfTestSuite.java | 10 +-
.../testsuites/IgniteCacheFailoverTestSuite.java | 73 +-
.../IgniteCacheFailoverTestSuiteSsl.java | 20 +-
.../IgniteCacheIteratorsSelfTestSuite.java | 10 +-
.../IgniteCacheMetricsSelfTestSuite.java | 10 +-
.../testsuites/IgniteCacheMvccTestSuite1.java | 31 +-
.../testsuites/IgniteCacheMvccTestSuite2.java | 33 +-
.../testsuites/IgniteCacheMvccTestSuite3.java | 29 +-
.../testsuites/IgniteCacheMvccTestSuite4.java | 25 +-
.../testsuites/IgniteCacheMvccTestSuite5.java | 21 +-
.../testsuites/IgniteCacheMvccTestSuite6.java | 27 +-
.../testsuites/IgniteCacheMvccTestSuite7.java | 28 +-
.../testsuites/IgniteCacheMvccTestSuite8.java | 24 +-
.../testsuites/IgniteCacheMvccTestSuite9.java | 26 +-
.../IgniteCacheNearOnlySelfTestSuite.java | 26 +-
.../IgniteCacheP2pUnmarshallingErrorTestSuite.java | 34 +-
.../IgniteCacheTcpClientDiscoveryTestSuite.java | 22 +-
.../ignite/testsuites/IgniteCacheTestSuite.java | 29 +-
.../ignite/testsuites/IgniteCacheTestSuite2.java | 26 +-
.../ignite/testsuites/IgniteCacheTestSuite3.java | 32 +-
.../ignite/testsuites/IgniteCacheTestSuite4.java | 357 +-
.../ignite/testsuites/IgniteCacheTestSuite5.java | 31 +-
.../ignite/testsuites/IgniteCacheTestSuite6.java | 26 +-
.../ignite/testsuites/IgniteCacheTestSuite7.java | 24 +-
.../ignite/testsuites/IgniteCacheTestSuite8.java | 33 +-
.../ignite/testsuites/IgniteCacheTestSuite9.java | 26 +-
.../IgniteCacheWriteBehindTestSuite.java | 26 +-
.../testsuites/IgniteComputeGridTestSuite.java | 169 +-
.../IgniteContinuousTaskSelfTestSuite.java | 26 +-
.../ignite/testsuites/IgniteDatabaseTestSuite.java | 21 +-
.../testsuites/IgniteDbMemoryLeakTestSuite.java | 31 +-
.../IgniteExternalizableSelfTestSuite.java | 17 +-
.../ignite/testsuites/IgniteIgfsTestSuite.java | 125 +-
.../org/apache/ignite/testsuites/IgniteIgnore.java | 40 -
.../IgniteIpcSharedMemorySelfTestSuite.java | 25 +-
.../ignite/testsuites/IgniteIpcTestSuite.java | 23 +-
.../testsuites/IgniteJobMetricsSelfTestSuite.java | 17 +-
.../testsuites/IgniteKernalSelfTestSuite.java | 177 +-
.../ignite/testsuites/IgniteLangSelfTestSuite.java | 77 +-
.../testsuites/IgniteLoggingSelfTestSuite.java | 17 +-
.../testsuites/IgniteLostAndFoundTestSuite.java | 76 +-
.../testsuites/IgniteMarshallerSelfTestSuite.java | 52 +-
.../ignite/testsuites/IgniteP2PSelfTestSuite.java | 67 +-
.../ignite/testsuites/IgnitePdsMvccTestSuite.java | 22 +-
.../ignite/testsuites/IgnitePdsMvccTestSuite2.java | 21 +-
.../ignite/testsuites/IgnitePdsMvccTestSuite3.java | 21 +-
.../ignite/testsuites/IgnitePdsMvccTestSuite4.java | 22 +-
.../ignite/testsuites/IgnitePdsTestSuite.java | 34 +-
.../ignite/testsuites/IgnitePdsTestSuite2.java | 30 +-
.../ignite/testsuites/IgnitePdsTestSuite3.java | 30 +-
.../ignite/testsuites/IgnitePdsTestSuite4.java | 28 +-
.../testsuites/IgnitePerformanceTestSuite.java | 107 +-
.../testsuites/IgnitePlatformsTestSuite.java | 22 +-
.../ignite/testsuites/IgniteReproducingSuite.java | 49 +-
.../testsuites/IgniteRestHandlerTestSuite.java | 29 +-
.../testsuites/IgniteServiceGridTestSuite.java | 114 +
.../IgniteSpiCheckpointSelfTestSuite.java | 50 +-
.../IgniteSpiCollisionSelfTestSuite.java | 46 +-
.../IgniteSpiCommunicationSelfTestSuite.java | 73 +-
.../IgniteSpiDeploymentSelfTestSuite.java | 22 +-
.../IgniteSpiDiscoverySelfTestSuite.java | 154 +-
.../IgniteSpiEventStorageSelfTestSuite.java | 25 +-
.../testsuites/IgniteSpiFailoverSelfTestSuite.java | 42 +-
.../IgniteSpiLoadBalancingSelfTestSuite.java | 64 +-
.../ignite/testsuites/IgniteSpiTestSuite.java | 62 +-
.../testsuites/IgniteStandByClusterSuite.java | 61 +-
.../ignite/testsuites/IgniteStartUpTestSuite.java | 17 +-
.../testsuites/IgniteStreamSelfTestSuite.java | 21 +-
.../testsuites/IgniteTaskSessionSelfTestSuite.java | 55 +-
.../IgniteTimeoutProcessorSelfTestSuite.java | 17 +-
.../IgniteTopologyValidatorTestSuite.java | 10 +-
.../ignite/testsuites/IgniteUtilSelfTestSuite.java | 125 +-
.../testsuites/TxDeadlockDetectionTestSuite.java | 37 +-
.../apache/ignite/util/GridCommandHandlerTest.java | 214 +-
...ocalWalModeChangeDuringRebalancingSelfTest.java | 4 +-
.../testsuites/IgnitePdsNativeIoTestSuite.java | 25 +-
.../testsuites/IgnitePdsNativeIoTestSuite2.java | 29 +-
.../cache/CacheNoValueClassOnServerTestClient.java | 2 +-
.../sink/flink/FlinkIgniteSinkSelfTestSuite.java | 17 +-
.../flink/FlinkIgniteSourceSelfTestSuite.java | 20 +-
.../ignite/stream/flume/IgniteSinkTestSuite.java | 17 +-
.../ignite/testsuites/IgniteGCETestSuite.java | 18 +-
.../query/h2/H2IndexingAbstractGeoSelfTest.java | 29 +-
.../testsuites/GeoSpatialIndexingTestSuite.java | 21 +-
.../hadoop/impl/igfs/IgfsEventsTestSuite.java | 69 +-
.../ignite/testsuites/IgniteHadoopTestSuite.java | 155 +-
.../IgniteIgfsLinuxAndMacOSTestSuite.java | 46 +-
.../IgniteIgnoredBinarySimpleMapperTestSuite.java | 22 +-
.../testsuites/IgniteIgnoredBinaryTestSuite.java | 26 +-
.../ignite/testsuites/IgniteIgnoredTestSuite.java | 50 +-
.../processors/query/h2/ConnectionManager.java | 209 +-
.../query/h2/DhtResultSetEnlistFuture.java | 2 +-
.../processors/query/h2/H2ConnectionWrapper.java | 25 +
.../processors/query/h2/H2FieldsIterator.java | 11 +-
.../processors/query/h2/IgniteH2Indexing.java | 174 +-
.../processors/query/h2/SchemaManager.java | 9 +-
.../processors/query/h2/ThreadLocalObjectPool.java | 121 +-
.../affinity/PartitionAffinityFunctionType.java} | 37 +-
.../query/h2/affinity/PartitionAllNode.java | 5 +
.../query/h2/affinity/PartitionCompositeNode.java | 114 +-
.../query/h2/affinity/PartitionConstantNode.java | 6 +-
.../query/h2/affinity/PartitionExtractor.java | 544 +-
.../query/h2/affinity/PartitionGroupNode.java | 23 +-
.../query/h2/affinity/PartitionJoinCondition.java | 132 +
.../query/h2/affinity/PartitionJoinGroup.java | 81 +
.../query/h2/affinity/PartitionNode.java | 5 +
.../query/h2/affinity/PartitionNoneNode.java | 5 +
.../query/h2/affinity/PartitionParameterNode.java | 2 +-
.../query/h2/affinity/PartitionResult.java | 25 +-
.../query/h2/affinity/PartitionSingleNode.java | 21 +-
.../query/h2/affinity/PartitionTable.java | 113 +
.../affinity/PartitionTableAffinityDescriptor.java | 97 +
.../h2/affinity/PartitionTableDescriptor.java | 73 -
.../query/h2/affinity/PartitionTableModel.java | 157 +
.../processors/query/h2/dml/UpdatePlan.java | 6 +-
.../processors/query/h2/opt/GridH2Table.java | 161 +-
.../processors/query/h2/sql/GridSqlColumn.java | 7 +
.../query/h2/sql/GridSqlQuerySplitter.java | 20 +-
.../query/h2/twostep/GridMapQueryExecutor.java | 19 +-
.../query/h2/twostep/GridReduceQueryExecutor.java | 9 +-
.../visor/verify/ValidateIndexesClosure.java | 105 +-
.../cache/GridCacheDynamicLoadOnClientTest.java | 4 +-
.../cache/IgniteCacheDistributedJoinTest.java | 2 +
...acheLockPartitionOnAffinityRunAbstractTest.java | 1 +
.../cache/IgniteCacheOffheapIndexScanTest.java | 7 +
.../cache/IgniteCacheQueriesLoadTest1.java | 4 +-
.../cache/IgniteCacheQueryH2IndexingLeakTest.java | 14 +-
.../IgniteCacheQueryMultiThreadedSelfTest.java | 9 +-
.../cache/IgniteCacheUnionDuplicatesTest.java | 7 +
.../QueryJoinWithDifferentNodeFiltersTest.java | 7 +-
...eCacheQueryAbstractDistributedJoinSelfTest.java | 4 +-
.../near/IgniteCacheQueryNodeRestartSelfTest2.java | 2 +
.../IgniteCacheReplicatedQuerySelfTest.java | 13 +
.../cache/index/AbstractIndexingCommonTest.java | 64 +
.../cache/index/AbstractSchemaSelfTest.java | 5 +-
.../processors/cache/index/BasicIndexTest.java | 7 +-
.../index/ComplexPrimaryKeyUnwrapSelfTest.java | 8 +-
.../index/ComplexSecondaryKeyUnwrapSelfTest.java | 4 +-
.../index/DuplicateKeyValueClassesSelfTest.java | 6 +-
.../cache/index/DynamicColumnsAbstractTest.java | 3 +-
.../index/DynamicIndexAbstractBasicSelfTest.java | 2 +-
.../cache/index/H2ConnectionLeaksSelfTest.java | 60 +-
.../cache/index/H2RowCachePageEvictionTest.java | 3 +-
.../processors/cache/index/H2RowCacheSelfTest.java | 4 +-
.../index/IoStatisticsBasicIndexSelfTest.java | 3 +-
.../processors/cache/index/LongIndexNameTest.java | 11 +-
.../cache/index/MvccEmptyTransactionSelfTest.java | 12 +-
.../index/OptimizedMarshallerIndexNameTest.java | 16 +-
.../cache/index/QueryEntityValidationSelfTest.java | 14 +-
...acheMvccAbstractSqlCoordinatorFailoverTest.java | 2 -
.../mvcc/CacheMvccBasicContinuousQueryTest.java | 2 -
...acheMvccContinuousQueryClientReconnectTest.java | 3 -
...eMvccPartitionedSqlCoordinatorFailoverTest.java | 6 -
.../cache/mvcc/CacheMvccSqlTxModesTest.java | 213 +
.../persistence/db/wal/IgniteWalRecoveryTest.java | 28 +-
...ntConnectorConfigurationValidationSelfTest.java | 6 +-
.../IgnitePersistentStoreSchemaLoadTest.java | 6 +-
...iteStableBaselineBinObjFieldsQuerySelfTest.java | 4 +-
.../query/IgniteSqlDistributedJoinSelfTest.java | 4 +-
.../query/IgniteSqlEntryCacheModeAgnosticTest.java | 7 +-
.../query/IgniteSqlGroupConcatCollocatedTest.java | 4 +-
.../IgniteSqlGroupConcatNotCollocatedTest.java | 4 +-
.../query/IgniteSqlKeyValueFieldsTest.java | 15 +-
.../query/IgniteSqlNotNullConstraintTest.java | 4 +-
.../query/IgniteSqlParameterizedQueryTest.java | 4 +-
.../query/IgniteSqlQueryParallelismTest.java | 4 +-
.../processors/query/IgniteSqlRoutingTest.java | 29 +-
.../query/IgniteSqlSchemaIndexingTest.java | 4 +-
.../query/IgniteSqlSegmentedIndexSelfTest.java | 4 +-
...gniteSqlSkipReducerOnUpdateDmlFlagSelfTest.java | 122 +-
.../IgniteSqlSkipReducerOnUpdateDmlSelfTest.java | 6 +-
.../query/IgniteSqlSplitterSelfTest.java | 7 +-
.../processors/query/LazyQuerySelfTest.java | 13 +-
.../query/MultipleStatementsSqlQuerySelfTest.java | 4 +-
.../processors/query/RunningQueriesTest.java | 78 +-
.../processors/query/SqlIllegalSchemaSelfTest.java | 4 +-
.../SqlLocalQueryConnectionAndStatementTest.java | 114 +
.../processors/query/SqlNestedQuerySelfTest.java | 4 +-
.../processors/query/SqlPushDownFunctionTest.java | 4 +-
.../processors/query/SqlSchemaSelfTest.java | 6 +-
.../processors/query/SqlSystemViewsSelfTest.java | 4 +-
.../CacheQueryEntityWithDateTimeApiFieldsTest.java | 4 +-
.../query/h2/GridIndexRebuildSelfTest.java | 4 +-
.../GridIndexRebuildWithMvccEnabledSelfTest.java | 3 +-
.../query/h2/GridIndexingSpiAbstractSelfTest.java | 15 +-
.../H2ResultSetIteratorNullifyOnEndSelfTest.java | 4 +-
.../query/h2/H2StatementCacheSelfTest.java | 5 +-
.../query/h2/IgniteSqlBigIntegerKeyTest.java | 4 +-
.../query/h2/IgniteSqlQueryMinMaxTest.java | 7 +-
.../query/h2/PreparedStatementExSelfTest.java | 4 +-
.../query/h2/ThreadLocalObjectPoolSelfTest.java | 59 +-
.../query/h2/database/InlineIndexHelperTest.java | 4 +-
.../query/h2/sql/AbstractH2CompareQueryTest.java | 4 +-
.../query/h2/sql/BaseH2CompareQueryTest.java | 8 +-
.../processors/query/h2/sql/ExplainSelfTest.java | 7 +-
.../query/h2/sql/GridQueryParsingTest.java | 6 +-
.../query/h2/sql/H2CompareBigQueryTest.java | 4 +-
.../AndOperationExtractPartitionSelfTest.java | 4 +-
.../BetweenOperationExtractPartitionSelfTest.java | 741 +
.../query/h2/twostep/CacheQueryMemoryLeakTest.java | 4 +-
.../h2/twostep/CreateTableWithDateKeySelfTest.java | 4 +-
.../DisappearedCacheCauseRetryMessageSelfTest.java | 4 +-
...DisappearedCacheWasNotFoundMessageSelfTest.java | 4 +-
.../InOperationExtractPartitionSelfTest.java | 5 +-
.../h2/twostep/JoinPartitionPruningSelfTest.java | 1303 ++
.../query/h2/twostep/JoinSqlTestHelper.java | 23 +-
.../twostep/NonCollocatedRetryMessageSelfTest.java | 4 +-
.../h2/twostep/RetryCauseMessageSelfTest.java | 6 +-
.../h2/twostep/TableViewSubquerySelfTest.java | 12 +-
...achePartitionedAtomicColumnConstraintsTest.java | 4 +-
.../sql/IgniteSQLColumnConstraintsTest.java | 4 +-
...qlConnectorConfigurationValidationSelfTest.java | 21 +-
.../org/apache/ignite/sqltests/BaseSqlTest.java | 4 +-
.../IgniteBinaryCacheQueryTestSuite.java | 600 +-
.../IgniteBinaryCacheQueryTestSuite2.java | 109 +-
...eBinarySimpleNameMapperCacheQueryTestSuite.java | 16 +-
...eBlockExchangeOnSqlReadOperationsTestSuite.java | 21 +-
.../testsuites/IgniteCacheMvccSqlTestSuite.java | 3 +-
...PartitionedCacheJtaLookupClassNameSelfTest.java | 4 +-
.../testsuites/IgniteKubernetesTestSuite.java | 20 +-
modules/ml/mleap-model-parser/pom.xml | 51 +
.../org/apache/ignite/ml/mleap/MLeapModel.java | 122 +
.../apache/ignite/ml/mleap/MLeapModelParser.java | 123 +
.../org/apache/ignite/ml/mleap/package-info.java} | 14 +-
.../ignite/ml/mleap/IgniteMLeapTestSuite.java} | 14 +-
.../ignite/ml/mleap/MLeapModelParserTest.java | 68 +
.../test/resources/datasets/scikit-airbnb.rf.zip | Bin 0 -> 216734 bytes
modules/ml/pom.xml | 15 +-
modules/ml/spark-model-parser/pom.xml | 58 +
.../ml/sparkmodelparser/SparkModelParser.java | 132 +
.../ml/sparkmodelparser/SupportedSparkModels.java} | 17 +-
.../UnsupportedSparkModelException.java} | 16 +-
.../ignite/ml/sparkmodelparser/package-info.java} | 14 +-
.../main/java/org/apache/ignite/ml/Exportable.java | 2 +-
.../ignite/ml/{Model.java => IgniteModel.java} | 48 +-
.../ignite/ml/clustering/kmeans/Clusterer.java | 4 +-
.../ml/clustering/kmeans/ClusterizationModel.java | 4 +-
.../ignite/ml/clustering/kmeans/KMeansModel.java | 2 +-
.../ignite/ml/clustering/kmeans/KMeansTrainer.java | 2 +-
.../ignite/ml/composition/CompositionUtils.java | 85 +
.../ignite/ml/composition/DatasetMapping.java | 68 +
.../ml/composition/ModelOnFeaturesSubspace.java | 14 +-
.../ignite/ml/composition/ModelsComposition.java | 14 +-
.../ml/composition/ModelsCompositionFormat.java | 8 +-
.../bagging/BaggedModel.java} | 47 +-
.../ml/composition/bagging/BaggedTrainer.java | 212 +
.../composition/boosting/GDBLearningStrategy.java | 20 +-
.../ignite/ml/composition/boosting/GDBTrainer.java | 14 +-
.../boosting/convergence/ConvergenceChecker.java | 2 +-
.../ml/composition/combinators/package-info.java} | 14 +-
.../parallel/ModelsParallelComposition.java | 67 +
.../parallel/TrainersParallelComposition.java | 145 +
.../combinators/parallel/package-info.java} | 14 +-
.../sequential/ModelsSequentialComposition.java | 100 +
.../sequential/TrainersSequentialComposition.java | 139 +
.../combinators/sequential/package-info.java} | 14 +-
.../stacking/SimpleStackedDatasetTrainer.java | 6 +-
.../stacking/StackedDatasetTrainer.java | 216 +-
.../ml/composition/stacking/StackedModel.java | 76 +-
.../stacking/StackedVectorDatasetTrainer.java | 11 +-
.../apache/ignite/ml/dataset/DatasetBuilder.java | 2 +-
.../ignite/ml/dataset/UpstreamTransformer.java | 18 +-
.../ml/dataset/UpstreamTransformerBuilder.java | 18 +-
.../ml/dataset/impl/cache/CacheBasedDataset.java | 17 +-
.../impl/cache/CacheBasedDatasetBuilder.java | 40 +-
.../ml/dataset/impl/cache/util/ComputeUtils.java | 65 +-
.../ml/dataset/impl/local/LocalDatasetBuilder.java | 25 +-
.../ml/environment/logging/ConsoleLogger.java | 4 +-
.../ml/environment/logging/CustomMLLogger.java | 4 +-
.../ignite/ml/environment/logging/MLLogger.java | 4 +-
.../ignite/ml/environment/logging/NoOpLogger.java | 4 +-
.../org/apache/ignite/ml/genetic/Chromosome.java | 1 -
.../java/org/apache/ignite/ml/genetic/GAGrid.java | 111 +-
.../org/apache/ignite/ml/genetic/MutateJob.java | 3 +-
.../ml/genetic/RouletteWheelSelectionJob.java | 111 +
.../ml/genetic/RouletteWheelSelectionTask.java | 153 +
.../ignite/ml/genetic/cache/GeneCacheConfig.java | 1 -
.../ml/genetic/cache/PopulationCacheConfig.java | 1 -
.../ml/genetic/parameter/ChromosomeCriteria.java | 1 -
.../ml/genetic/parameter/GAGridConstants.java | 7 +-
.../ml/inference/{InfModel.java => Model.java} | 6 +-
.../ignite/ml/inference/ModelDescriptor.java | 18 +-
...InfModelBuilder.java => AsyncModelBuilder.java} | 16 +-
...der.java => IgniteDistributedModelBuilder.java} | 58 +-
...nfModelBuilder.java => SingleModelBuilder.java} | 12 +-
...cInfModelBuilder.java => SyncModelBuilder.java} | 16 +-
...ModelBuilder.java => ThreadedModelBuilder.java} | 24 +-
...nInfModelParser.java => IgniteModelParser.java} | 37 +-
.../{InfModelParser.java => ModelParser.java} | 8 +-
...lParser.java => TensorFlowBaseModelParser.java} | 14 +-
...Parser.java => TensorFlowGraphModelParser.java} | 2 +-
...r.java => TensorFlowSavedModelModelParser.java} | 4 +-
...ModelReader.java => FileSystemModelReader.java} | 4 +-
...nfModelReader.java => InMemoryModelReader.java} | 6 +-
.../{InfModelReader.java => ModelReader.java} | 2 +-
...delReader.java => ModelStorageModelReader.java} | 6 +-
.../ignite/ml/knn/NNClassificationModel.java | 4 +-
.../ignite/ml/knn/ann/ANNClassificationModel.java | 2 +-
.../ml/knn/ann/ANNClassificationTrainer.java | 2 +-
.../knn/classification/KNNClassificationModel.java | 2 +-
.../classification/KNNClassificationTrainer.java | 2 +-
.../ml/knn/regression/KNNRegressionModel.java | 2 +-
.../ml/knn/regression/KNNRegressionTrainer.java | 2 +-
.../ignite/ml/multiclass/MultiClassModel.java | 8 +-
.../ignite/ml/multiclass/OneVsRestTrainer.java | 6 +-
.../discrete/DiscreteNaiveBayesModel.java | 6 +-
.../discrete/DiscreteNaiveBayesTrainer.java | 4 +-
.../gaussian/GaussianNaiveBayesModel.java | 6 +-
.../gaussian/GaussianNaiveBayesTrainer.java | 2 +-
.../java/org/apache/ignite/ml/nn/MLPTrainer.java | 2 +-
.../apache/ignite/ml/nn/MultilayerPerceptron.java | 6 +-
.../ignite/ml/optimization/SmoothParametrized.java | 4 +-
.../org/apache/ignite/ml/pipeline/Pipeline.java | 4 +-
.../org/apache/ignite/ml/pipeline/PipelineMdl.java | 14 +-
.../linear/LinearRegressionLSQRTrainer.java | 2 +-
.../regressions/linear/LinearRegressionModel.java | 6 +-
.../linear/LinearRegressionSGDTrainer.java | 2 +-
.../logistic/LogisticRegressionModel.java | 6 +-
.../logistic/LogisticRegressionSGDTrainer.java | 2 +-
.../ignite/ml/selection/cv/CrossValidation.java | 4 +-
.../scoring/cursor/CacheBasedLabelPairCursor.java | 10 +-
.../scoring/cursor/LocalLabelPairCursor.java | 8 +-
.../evaluator/BinaryClassificationEvaluator.java | 26 +-
.../ml/svm/SVMLinearClassificationModel.java | 6 +-
.../ml/svm/SVMLinearClassificationTrainer.java | 2 +-
.../ignite/ml/trainers/AdaptableDatasetModel.java | 14 +-
.../ml/trainers/AdaptableDatasetTrainer.java | 181 +-
.../apache/ignite/ml/trainers/DatasetTrainer.java | 44 +-
.../ml/trainers/MultiLabelDatasetTrainer.java | 4 +-
.../ml/trainers/SingleLabelDatasetTrainer.java | 4 +-
.../ignite/ml/trainers/TrainerTransformers.java | 69 +-
.../transformers/BaggingUpstreamTransformer.java | 11 +-
.../org/apache/ignite/ml/tree/DecisionTree.java | 2 +-
.../ml/tree/DecisionTreeConditionalNode.java | 6 +-
.../ignite/ml/tree/DecisionTreeLeafNode.java | 2 +-
.../apache/ignite/ml/tree/DecisionTreeNode.java | 4 +-
.../tree/boosting/GDBOnTreesLearningStrategy.java | 10 +-
.../ml/tree/randomforest/RandomForestTrainer.java | 6 +-
.../ignite/ml/tree/randomforest/data/TreeNode.java | 10 +-
.../ignite/ml/tree/randomforest/data/TreeRoot.java | 8 +-
.../ml/util/generators/DataStreamGenerator.java | 2 +-
.../ml/util/generators/DatasetBuilderAdapter.java | 2 +-
.../test/java/org/apache/ignite/ml/TestUtils.java | 6 +-
.../ignite/ml/clustering/KMeansModelTest.java | 8 +-
.../ignite/ml/clustering/KMeansTrainerTest.java | 12 +-
.../apache/ignite/ml/common/CommonTestSuite.java | 3 +-
.../apache/ignite/ml/common/KeepBinaryTest.java | 115 +
.../org/apache/ignite/ml/common/ModelTest.java | 10 +-
.../apache/ignite/ml/composition/BaggingTest.java | 47 +-
.../apache/ignite/ml/composition/StackingTest.java | 22 +-
.../ml/composition/boosting/GDBTrainerTest.java | 18 +-
.../convergence/ConvergenceCheckerTest.java | 4 +-
.../dataset/impl/cache/util/ComputeUtilsTest.java | 9 +-
.../ml/environment/LearningEnvironmentTest.java | 14 +-
.../ignite/ml/inference/InferenceTestSuite.java | 12 +-
...java => IgniteDistributedModelBuilderTest.java} | 14 +-
...lderTestUtil.java => ModelBuilderTestUtil.java} | 16 +-
...uilderTest.java => SingleModelBuilderTest.java} | 16 +-
...lderTest.java => ThreadedModelBuilderTest.java} | 16 +-
.../ignite/ml/knn/KNNClassificationTest.java | 22 +-
.../apache/ignite/ml/knn/KNNRegressionTest.java | 14 +-
.../apache/ignite/ml/knn/LabeledVectorSetTest.java | 19 +-
.../ignite/ml/multiclass/OneVsRestTrainerTest.java | 8 +-
.../discrete/DiscreteNaiveBayesModelTest.java | 2 +-
.../discrete/DiscreteNaiveBayesTest.java | 2 +-
.../discrete/DiscreteNaiveBayesTrainerTest.java | 1 -
.../gaussian/GaussianNaiveBayesModelTest.java | 2 +-
.../gaussian/GaussianNaiveBayesTest.java | 4 +-
.../gaussian/GaussianNaiveBayesTrainerTest.java | 4 +-
.../test/java/org/apache/ignite/ml/nn/MLPTest.java | 8 +-
.../ignite/ml/nn/MLPTrainerIntegrationTest.java | 2 +-
.../org/apache/ignite/ml/nn/MLPTrainerTest.java | 6 +-
.../MLPTrainerMnistIntegrationTest.java | 2 +-
.../ml/nn/performance/MLPTrainerMnistTest.java | 2 +-
.../apache/ignite/ml/pipeline/PipelineMdlTest.java | 10 +-
.../apache/ignite/ml/pipeline/PipelineTest.java | 8 +-
.../preprocessing/encoding/EncoderTrainerTest.java | 2 +-
.../encoding/OneHotEncoderPreprocessorTest.java | 2 +-
.../linear/LinearRegressionModelTest.java | 12 +-
.../logistic/LogisticRegressionModelTest.java | 18 +-
.../logistic/LogisticRegressionSGDTrainerTest.java | 12 +-
.../ml/selection/cv/CrossValidationTest.java | 2 +-
.../apache/ignite/ml/svm/SVMBinaryTrainerTest.java | 8 +-
.../org/apache/ignite/ml/svm/SVMModelTest.java | 28 +-
.../ml/{composition => trainers}/StackingTest.java | 25 +-
.../DecisionTreeClassificationTrainerTest.java | 6 +-
.../ml/tree/DecisionTreeRegressionTrainerTest.java | 6 +-
.../gini/GiniImpurityMeasureCalculatorTest.java | 2 +-
.../impurity/gini/GiniImpurityMeasureTest.java | 2 +-
.../mse/MSEImpurityMeasureCalculatorTest.java | 2 +-
.../tree/impurity/mse/MSEImpurityMeasureTest.java | 2 +-
.../DecisionTreeMNISTIntegrationTest.java | 2 +-
.../ml/tree/performance/DecisionTreeMNISTTest.java | 4 +-
.../RandomForestClassifierTrainerTest.java | 4 +-
.../RandomForestRegressionTrainerTest.java | 4 +-
.../ml/tree/randomforest/data/TreeNodeTest.java | 4 +-
.../util/generators/DataStreamGeneratorTest.java | 12 +-
.../ignite/ml/xgboost/XGModelComposition.java | 8 +-
.../ignite/ml/xgboost/parser/XGModelParser.java | 4 +-
.../ml/xgboost/parser/XGBoostModelParserTest.java | 14 +-
.../cpp/core/include/ignite/cache/cache.h | 32 +-
modules/platforms/cpp/core/src/ignition.cpp | 17 +-
.../cpp/thin-client-test/src/cache_client_test.cpp | 710 +
.../ignite/impl/thin/cache/cache_client_proxy.h | 83 +
.../include/ignite/thin/cache/cache_client.h | 239 +-
.../src/impl/cache/cache_client_impl.cpp | 70 +-
.../thin-client/src/impl/cache/cache_client_impl.h | 83 +
.../src/impl/cache/cache_client_proxy.cpp | 36 +
.../platforms/cpp/thin-client/src/impl/message.h | 88 +-
.../ApiParity/ClusterParityTest.cs | 3 +-
.../IgniteConfigurationTest.cs | 4 +
.../Services/ServicesTest.cs | 4 +-
.../Apache.Ignite.Core/IgniteConfiguration.cs | 60 +
.../IgniteConfigurationSection.xsd | 15 +
.../Apache.Ignite.Core/Impl/IgniteManager.cs | 8 +-
.../ignite/spark/impl/IgniteRelationProvider.scala | 2 +-
.../ignite/spark/impl/IgniteSQLRelation.scala | 12 +-
.../org/apache/ignite/spark/impl/QueryHelper.scala | 9 +-
.../org/apache/ignite/spark/impl/package.scala | 57 +-
.../spark/sql/ignite/IgniteExternalCatalog.scala | 16 +-
.../ignite/spark/IgniteDataFrameSchemaSpec.scala | 79 +-
.../ignite/spark/IgniteSQLDataFrameWriteSpec.scala | 6 +-
.../p2p/GridP2PUserVersionChangeSelfTest.java | 4 +-
.../testsuites/IgniteResourceSelfTestSuite.java | 27 +-
.../ignite/testsuites/IgniteSpringTestSuite.java | 78 +-
.../internal/IgniteStartStopRestartTestSuite.java | 21 +-
modules/web-console/assembly/README.txt | 25 +-
modules/web-console/backend/app/configure.js | 4 +
modules/web-console/backend/app/mongo.js | 20 +-
modules/web-console/backend/app/schemas.js | 5 +-
modules/web-console/backend/app/settings.js | 14 +
.../backend/config/settings.json.sample | 5 +
.../errors/MissingConfirmRegistrationException.js} | 21 +-
modules/web-console/backend/errors/index.js | 2 +
modules/web-console/backend/middlewares/api.js | 3 +
modules/web-console/backend/package.json | 1 +
modules/web-console/backend/routes/profile.js | 2 +-
modules/web-console/backend/routes/public.js | 53 +-
modules/web-console/backend/services/auth.js | 83 +-
modules/web-console/backend/services/downloads.js | 10 +
modules/web-console/backend/services/mails.js | 18 +
modules/web-console/backend/services/users.js | 39 +-
modules/web-console/frontend/app/app.js | 5 +-
.../form-field/showValidationError.directive.js | 2 +-
.../list-of-registered-users/categories.js | 1 +
.../list-of-registered-users/column-defs.js | 1 +
.../components/modal-import-models/service.js | 6 +-
.../app/components/page-configure/template.pug | 4 +-
.../components/queries-notebook/controller.ts | 2 +-
.../app/components/page-signin/component.ts | 5 +-
.../app/components/page-signin/controller.ts | 10 +-
.../frontend/app/components/page-signin/run.ts | 11 +-
.../app/components/page-signin/template.pug | 4 +-
.../component.ts | 10 +-
.../page-signup-confirmation/controller.ts} | 35 +-
.../index.ts} | 13 +-
.../components/page-signup-confirmation/state.ts | 48 +
.../style.scss} | 14 +-
.../page-signup-confirmation/template.tpl.pug | 24 +
.../app/components/page-signup/controller.ts | 7 +
.../frontend/app/components/ui-grid/component.js | 1 +
.../frontend/app/components/ui-grid/controller.js | 8 +
.../app/directives/auto-focus.directive.js | 2 +-
.../app/modules/agent/AgentManager.service.js | 9 +-
.../app/modules/agent/decompress.worker.js | 6 +-
.../frontend/app/modules/user/Auth.service.ts | 14 +-
.../modules/user/emailConfirmationInterceptor.ts} | 33 +-
.../frontend/app/modules/user/user.module.js | 27 +-
modules/web-console/web-agent/README.txt | 50 +-
.../ignite/console/agent/AgentConfiguration.java | 10 +-
.../apache/ignite/console/agent/AgentLauncher.java | 23 +-
.../apache/ignite/console/agent/AgentUtils.java | 2 +-
.../ignite/console/agent/rest/RestExecutor.java | 4 +-
.../console/agent/rest/RestExecutorSelfTest.java | 7 +-
.../websession/IgniteWebSessionSelfTestSuite.java | 38 +-
.../WebSessionTransactionalSelfTest.java | 8 +-
modules/yardstick/README.txt | 4 +
.../yardstick/config/benchmark-failover.properties | 5 -
modules/yardstick/config/benchmark-ml.properties | 1 -
.../yardstick/config/benchmark-remote.properties | 9 -
.../ignite/yardstick/IgniteBenchmarkArguments.java | 11 +
.../ignite/yardstick/IgniteBenchmarkUtils.java | 54 +-
.../org/apache/ignite/yardstick/IgniteNode.java | 94 +-
.../zk/ZookeeperDiscoverySpiTestConfigurator.java | 88 +
.../zk/ZookeeperDiscoverySpiTestSuite1.java | 45 +-
.../zk/ZookeeperDiscoverySpiTestSuite2.java | 10 +-
.../zk/ZookeeperDiscoverySpiTestSuite3.java | 6 +-
.../zk/ZookeeperDiscoverySpiTestSuite4.java | 6 +-
...ite.java => ZookeeperDiscoverySpiTestUtil.java} | 54 +-
.../discovery/zk/internal/ZookeeperClientTest.java | 4 +-
.../ZookeeperDiscoveryClientDisconnectTest.java | 535 +
...ZookeeperDiscoveryCommunicationFailureTest.java | 1159 ++
...erDiscoveryConcurrentStartAndStartStopTest.java | 476 +
.../ZookeeperDiscoveryCustomEventsTest.java | 399 +
.../zk/internal/ZookeeperDiscoveryMiscTest.java | 546 +
...coverySegmentationAndConnectionRestoreTest.java | 562 +
.../zk/internal/ZookeeperDiscoverySpiTest.java | 5749 ------
.../zk/internal/ZookeeperDiscoverySpiTestBase.java | 822 +
.../internal/ZookeeperDiscoverySpiTestHelper.java | 329 +
.../internal/ZookeeperDiscoverySplitBrainTest.java | 271 +
...perDiscoveryTopologyChangeAndReconnectTest.java | 1069 +
pom.xml | 9 +-
scripts/apply-pull-request.sh | 2 +-
914 files changed, 55646 insertions(+), 16921 deletions(-)