You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by ag...@apache.org on 2018/04/13 09:34:06 UTC
[54/54] [abbrv] ignite git commit: Merge branch 'master' of
https://git-wip-us.apache.org/repos/asf/ignite into ignite-6083
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/ignite into ignite-6083
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/ecefdd33
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/ecefdd33
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/ecefdd33
Branch: refs/heads/ignite-6083
Commit: ecefdd335fedfe4c8020a401a63ce4477bd15737
Parents: 6e92fff 44c4656
Author: Alexey Goncharuk <al...@gmail.com>
Authored: Fri Apr 13 12:32:50 2018 +0300
Committer: Alexey Goncharuk <al...@gmail.com>
Committed: Fri Apr 13 12:32:50 2018 +0300
----------------------------------------------------------------------
.gitignore | 1 +
.../ignite/examples/ml/genetic/change/Coin.java | 7 +-
.../OptimizeMakeChangeFitnessFunction.java | 3 +-
.../change/OptimizeMakeChangeGAExample.java | 8 +-
.../OptimizeMakeChangeTerminateCriteria.java | 3 +-
.../helloworld/HelloWorldFitnessFunction.java | 3 +-
.../genetic/helloworld/HelloWorldGAExample.java | 9 +-
.../helloworld/HelloWorldTerminateCriteria.java | 3 +-
.../ignite/examples/ml/genetic/movie/Movie.java | 4 +-
.../ml/genetic/movie/MovieFitnessFunction.java | 3 +-
.../ml/genetic/movie/MovieGAExample.java | 4 +-
.../genetic/movie/MovieTerminateCriteria.java | 4 +-
.../ml/knn/KNNClassificationExample.java | 11 +-
.../examples/ml/nn/MLPTrainerExample.java | 4 +-
.../ml/preprocessing/NormalizationExample.java | 17 +-
...nWithLSQRTrainerAndNormalizationExample.java | 23 +-
...dLinearRegressionWithLSQRTrainerExample.java | 14 +-
...tedLinearRegressionWithQRTrainerExample.java | 9 +-
...edLinearRegressionWithSGDTrainerExample.java | 78 +-
.../binary/SVMBinaryClassificationExample.java | 11 +-
.../SVMMultiClassClassificationExample.java | 24 +-
...ecisionTreeClassificationTrainerExample.java | 148 +
.../DecisionTreeRegressionTrainerExample.java | 124 +
.../ignite/examples/ml/tree/package-info.java | 22 +
.../examples/ml/trees/DecisionTreesExample.java | 354 --
.../ignite/examples/ml/trees/package-info.java | 22 -
.../jdbc2/JdbcAbstractDmlStatementSelfTest.java | 6 +-
.../jdbc/thin/JdbcThinConnectionSelfTest.java | 233 +-
.../jdbc/thin/JdbcThinMetadataSelfTest.java | 22 +-
.../junits/IgniteCompatibilityAbstractTest.java | 4 +-
.../junits/IgniteCompatibilityNodeRunner.java | 4 +-
.../util/CompatibilityTestsUtils.java | 93 +
.../apache/ignite/IgniteSystemProperties.java | 33 +
.../org/apache/ignite/cache/CacheMetrics.java | 7 +
.../org/apache/ignite/cache/QueryEntity.java | 41 +-
.../cache/query/annotations/QuerySqlField.java | 16 +-
.../client/ClientAuthenticationException.java | 18 +-
.../client/ClientAuthorizationException.java | 46 +
.../apache/ignite/client/ClientException.java | 3 +-
.../ignite/compute/ComputeTaskAdapter.java | 2 +-
.../CommunicationFailureContext.java | 62 +
.../CommunicationFailureResolver.java | 28 +
.../configuration/DataStorageConfiguration.java | 6 +-
.../DefaultCommunicationFailureResolver.java | 305 ++
.../configuration/IgniteConfiguration.java | 22 +
.../failure/StopNodeOrHaltFailureHandler.java | 2 +-
.../ignite/internal/GridKernalContext.java | 8 +
.../ignite/internal/GridKernalContextImpl.java | 10 +
.../org/apache/ignite/internal/GridTopic.java | 8 +-
.../apache/ignite/internal/IgniteKernal.java | 23 +-
.../org/apache/ignite/internal/IgnitionEx.java | 68 +-
.../GridClientConnectionManagerAdapter.java | 6 +
.../impl/GridTcpRouterNioListenerAdapter.java | 6 +
.../internal/client/thin/ClientChannel.java | 3 +-
.../internal/client/thin/ClientQueryCursor.java | 6 +-
.../internal/client/thin/ClientUtils.java | 38 +-
.../internal/client/thin/TcpClientChannel.java | 48 +-
.../jdbc/thin/ConnectionPropertiesImpl.java | 161 +-
.../jdbc/thin/JdbcThinDatabaseMetadata.java | 6 +-
.../internal/managers/GridManagerAdapter.java | 8 +
.../managers/communication/GridIoManager.java | 4 +-
.../communication/GridIoMessageFactory.java | 18 +
.../discovery/CustomMessageWrapper.java | 5 +
.../internal/managers/discovery/DiscoCache.java | 8 +
.../discovery/DiscoveryCustomMessage.java | 10 +-
.../DiscoveryMessageResultsCollector.java | 222 +
.../discovery/GridDiscoveryManager.java | 159 +-
.../managers/discovery/IgniteClusterNode.java | 69 +
.../managers/discovery/IgniteDiscoverySpi.java | 67 +
.../IgniteDiscoverySpiInternalListener.java | 42 +
.../pagemem/impl/PageMemoryNoStoreImpl.java | 17 +-
.../MetaPageUpdatePartitionDataRecord.java | 2 +-
.../affinity/GridAffinityAssignmentCache.java | 50 +-
.../IgniteAuthenticationProcessor.java | 5 +-
.../authentication/UserAcceptedMessage.java | 5 +
.../authentication/UserProposedMessage.java | 5 +
.../cache/CacheAffinityChangeMessage.java | 5 +
.../cache/CacheAffinitySharedManager.java | 26 +-
.../processors/cache/CacheMetricsImpl.java | 2 +-
.../cache/CacheStatisticsModeChangeMessage.java | 5 +
.../ClientCacheChangeDiscoveryMessage.java | 5 +
.../ClientCacheChangeDummyDiscoveryMessage.java | 5 +
.../cache/DynamicCacheChangeBatch.java | 5 +
.../processors/cache/GridCacheAdapter.java | 3 +-
.../processors/cache/GridCacheMvccManager.java | 38 +
.../GridCachePartitionExchangeManager.java | 48 +-
.../processors/cache/GridCacheProcessor.java | 36 +-
.../cache/GridCacheSharedContext.java | 9 +-
.../cache/GridCacheSharedTtlCleanupManager.java | 44 +-
.../processors/cache/GridCacheUtils.java | 16 +-
.../cache/IgniteCacheOffheapManager.java | 8 +-
.../cache/IgniteCacheOffheapManagerImpl.java | 10 +-
.../processors/cache/IgniteCacheProxyImpl.java | 3 +
.../processors/cache/WalStateFinishMessage.java | 5 +
.../processors/cache/WalStateManager.java | 8 +-
.../cache/WalStateProposeMessage.java | 5 +
.../cache/binary/BinaryMetadataTransport.java | 24 +-
.../binary/MetadataUpdateAcceptedMessage.java | 5 +
.../binary/MetadataUpdateProposedMessage.java | 5 +
.../dht/GridClientPartitionTopology.java | 44 +
.../distributed/dht/GridDhtCacheAdapter.java | 4 +
.../distributed/dht/GridDhtLocalPartition.java | 9 +-
.../dht/GridDhtPartitionTopology.java | 12 +
.../dht/GridDhtPartitionTopologyImpl.java | 65 +-
.../dht/GridDhtPartitionsStateValidator.java | 255 +
.../cache/distributed/dht/GridDhtTxLocal.java | 5 +
.../GridDhtPartitionsExchangeFuture.java | 122 +-
.../GridDhtPartitionsSingleMessage.java | 68 +-
.../dht/preloader/InitNewCoordinatorFuture.java | 2 +-
.../preloader/latch/ExchangeLatchManager.java | 696 +++
.../distributed/dht/preloader/latch/Latch.java | 52 +
.../dht/preloader/latch/LatchAckMessage.java | 165 +
.../cache/distributed/near/GridNearTxLocal.java | 19 +
.../GridCacheDatabaseSharedManager.java | 60 +-
.../persistence/GridCacheOffheapManager.java | 10 +-
.../persistence/pagemem/PageMemoryImpl.java | 17 +-
.../TrackingPageIsCorruptedException.java | 60 +
.../cache/persistence/tree/BPlusTree.java | 41 +-
.../cache/persistence/tree/io/PageMetaIO.java | 6 +-
.../persistence/tree/io/TrackingPageIO.java | 158 +-
.../wal/FileWriteAheadLogManager.java | 157 +-
.../wal/FsyncModeFileWriteAheadLogManager.java | 34 +-
.../wal/reader/StandaloneGridKernalContext.java | 6 +
.../cache/query/QueryEntityTypeDescriptor.java | 21 +
.../cache/store/GridCacheWriteBehindStore.java | 2 +-
.../cache/transactions/IgniteTxAdapter.java | 2 +-
.../cache/transactions/IgniteTxManager.java | 36 +-
.../cluster/ChangeGlobalStateFinishMessage.java | 5 +
.../cluster/ChangeGlobalStateMessage.java | 5 +
.../cluster/ClusterMetricsUpdateMessage.java | 158 +
.../processors/cluster/ClusterNodeMetrics.java | 62 +
.../processors/cluster/ClusterProcessor.java | 249 +-
.../continuous/AbstractContinuousMessage.java | 5 +
.../continuous/ContinuousRoutineInfo.java | 100 +
.../ContinuousRoutineStartResultMessage.java | 206 +
.../ContinuousRoutinesCommonDiscoveryData.java | 45 +
.../continuous/ContinuousRoutinesInfo.java | 132 +
...tinuousRoutinesJoiningNodeDiscoveryData.java | 45 +
.../continuous/GridContinuousProcessor.java | 865 +++-
.../continuous/StartRequestDataV2.java | 164 +
.../StartRoutineDiscoveryMessageV2.java | 77 +
.../StopRoutineAckDiscoveryMessage.java | 5 +
.../datastreamer/DataStreamProcessor.java | 3 +
.../datastreamer/DataStreamerImpl.java | 27 +-
.../processors/failure/FailureProcessor.java | 11 +
.../processors/igfs/IgfsMetaManager.java | 30 +-
.../internal/processors/job/GridJobWorker.java | 10 +-
.../marshaller/MappingAcceptedMessage.java | 5 +
.../marshaller/MappingProposedMessage.java | 5 +
.../odbc/ClientListenerNioListener.java | 19 +
.../processors/odbc/jdbc/JdbcColumnMeta.java | 14 +
.../processors/odbc/jdbc/JdbcColumnMetaV4.java | 90 +
.../odbc/jdbc/JdbcConnectionContext.java | 4 +-
.../odbc/jdbc/JdbcMetaColumnsResultV4.java | 50 +
.../odbc/jdbc/JdbcRequestHandler.java | 14 +-
.../processors/odbc/jdbc/JdbcResult.java | 8 +
.../client/ClientConnectionContext.java | 53 +-
.../platform/client/ClientRequest.java | 29 +
.../platform/client/ClientRequestHandler.java | 7 +-
.../platform/client/ClientStatus.java | 6 +
.../cache/ClientCacheClearKeyRequest.java | 3 +
.../cache/ClientCacheClearKeysRequest.java | 3 +
.../client/cache/ClientCacheClearRequest.java | 3 +
.../cache/ClientCacheContainsKeyRequest.java | 3 +
.../cache/ClientCacheContainsKeysRequest.java | 3 +
...ientCacheCreateWithConfigurationRequest.java | 6 +-
.../cache/ClientCacheCreateWithNameRequest.java | 3 +
.../client/cache/ClientCacheDestroyRequest.java | 3 +
.../client/cache/ClientCacheGetAllRequest.java | 3 +
.../ClientCacheGetAndPutIfAbsentRequest.java | 3 +
.../cache/ClientCacheGetAndPutRequest.java | 3 +
.../cache/ClientCacheGetAndRemoveRequest.java | 3 +
.../cache/ClientCacheGetAndReplaceRequest.java | 3 +
...acheGetOrCreateWithConfigurationRequest.java | 6 +-
.../ClientCacheGetOrCreateWithNameRequest.java | 3 +
.../client/cache/ClientCacheGetRequest.java | 3 +
.../client/cache/ClientCacheGetSizeRequest.java | 3 +
.../client/cache/ClientCachePutAllRequest.java | 3 +
.../cache/ClientCachePutIfAbsentRequest.java | 3 +
.../client/cache/ClientCachePutRequest.java | 3 +
.../cache/ClientCacheRemoveAllRequest.java | 3 +
.../cache/ClientCacheRemoveIfEqualsRequest.java | 3 +
.../cache/ClientCacheRemoveKeyRequest.java | 3 +
.../cache/ClientCacheRemoveKeysRequest.java | 3 +
.../ClientCacheReplaceIfEqualsRequest.java | 3 +
.../client/cache/ClientCacheReplaceRequest.java | 3 +
.../client/cache/ClientCacheRequest.java | 32 +
.../cache/ClientCacheScanQueryRequest.java | 3 +
.../cache/ClientCacheSqlFieldsQueryRequest.java | 18 +-
.../cache/ClientCacheSqlQueryRequest.java | 1 +
.../platform/services/PlatformServices.java | 8 +-
.../utils/PlatformConfigurationUtils.java | 20 +
.../processors/query/GridQueryProcessor.java | 9 +-
.../processors/query/GridQueryProperty.java | 14 +
.../internal/processors/query/QueryField.java | 26 +-
.../internal/processors/query/QueryUtils.java | 28 +-
.../query/property/QueryBinaryProperty.java | 23 +-
.../query/property/QueryClassProperty.java | 10 +
.../message/SchemaFinishDiscoveryMessage.java | 5 +
.../message/SchemaProposeDiscoveryMessage.java | 5 +
.../cluster/GridChangeStateCommandHandler.java | 3 +-
.../security/SecurityContextHolder.java | 53 +
.../service/GridServiceProcessor.java | 15 +-
.../processors/service/GridServiceProxy.java | 27 +-
.../processors/task/GridTaskProcessor.java | 2 +-
.../timeout/GridTimeoutProcessor.java | 105 +-
.../suggestions/OsConfigurationSuggestions.java | 14 +-
.../ignite/internal/util/IgniteUtils.java | 39 +-
.../ignite/internal/util/StripedExecutor.java | 69 +-
.../ignite/internal/util/nio/GridNioServer.java | 61 +-
.../util/nio/GridNioServerListener.java | 6 +
.../util/nio/GridNioServerListenerAdapter.java | 6 +
.../util/nio/ssl/BlockingSslHandler.java | 10 +-
.../apache/ignite/internal/util/typedef/X.java | 37 +-
.../visor/baseline/VisorBaselineTask.java | 24 +-
.../cache/VisorCacheLostPartitionsTask.java | 85 +
.../cache/VisorCacheLostPartitionsTaskArg.java | 73 +
.../VisorCacheLostPartitionsTaskResult.java | 74 +
.../VisorCacheResetLostPartitionsTask.java | 65 +
.../VisorCacheResetLostPartitionsTaskArg.java | 73 +
.../visor/util/VisorExceptionWrapper.java | 11 +-
.../worker/WorkersControlMXBeanImpl.java | 62 +
.../ignite/internal/worker/WorkersRegistry.java | 80 +
.../ignite/internal/worker/package-info.java | 22 +
.../ignite/mxbean/WorkersControlMXBean.java | 49 +
.../plugin/security/AuthenticationContext.java | 40 +
.../plugin/security/SecurityPermission.java | 11 +-
.../org/apache/ignite/spi/IgniteSpiAdapter.java | 10 +
.../org/apache/ignite/spi/IgniteSpiContext.java | 11 +
.../communication/tcp/TcpCommunicationSpi.java | 259 +-
.../tcp/internal/ConnectionKey.java | 117 +
.../TcpCommunicationConnectionCheckFuture.java | 519 ++
...pCommunicationNodeConnectionCheckFuture.java | 30 +
.../discovery/DiscoverySpiCustomMessage.java | 15 +-
...DiscoverySpiMutableCustomMessageSupport.java | 40 +
.../ignite/spi/discovery/tcp/ServerImpl.java | 63 +-
.../spi/discovery/tcp/TcpDiscoverySpi.java | 55 +-
.../tcp/internal/TcpDiscoveryNode.java | 32 +-
.../thread/IgniteStripedThreadPoolExecutor.java | 8 +-
.../ignite/thread/IgniteThreadFactory.java | 30 +-
.../ignite/thread/IgniteThreadPoolExecutor.java | 12 +-
.../ignite/thread/OomExceptionHandler.java | 44 +
.../resources/META-INF/classnames.properties | 2 +
.../ignite/GridSuppressedExceptionSelfTest.java | 23 +-
.../AffinityDistributionLoggingTest.java | 268 +
...unctionExcludeNeighborsAbstractSelfTest.java | 8 +-
.../failure/AbstractFailureHandlerTest.java | 74 +
.../failure/FailureHandlerTriggeredTest.java | 4 +
.../ignite/failure/IoomFailureHandlerTest.java | 144 +
.../ignite/failure/OomFailureHandlerTest.java | 255 +
.../internal/ClusterGroupHostsSelfTest.java | 3 +
.../ignite/internal/ClusterGroupSelfTest.java | 2 +
.../internal/ClusterNodeMetricsUpdateTest.java | 173 +
.../internal/DiscoverySpiTestListener.java | 162 +
.../ignite/internal/GridDiscoverySelfTest.java | 14 +-
.../GridJobMasterLeaveAwareSelfTest.java | 2 +
.../internal/GridJobStealingSelfTest.java | 2 +
.../internal/GridSameVmStartupSelfTest.java | 19 +-
.../apache/ignite/internal/GridSelfTest.java | 2 +
.../IgniteClientReconnectAbstractTest.java | 53 +-
.../IgniteClientReconnectApiExceptionTest.java | 21 +-
.../IgniteClientReconnectAtomicsTest.java | 30 +-
.../IgniteClientReconnectCacheTest.java | 49 +-
.../IgniteClientReconnectCollectionsTest.java | 14 +-
.../IgniteClientReconnectComputeTest.java | 6 +-
...eClientReconnectContinuousProcessorTest.java | 13 +-
...IgniteClientReconnectDiscoveryStateTest.java | 22 +-
...niteClientReconnectFailoverAbstractTest.java | 12 +-
.../IgniteClientReconnectServicesTest.java | 8 +-
.../internal/IgniteClientReconnectStopTest.java | 12 +-
.../IgniteClientReconnectStreamerTest.java | 4 +-
.../ignite/internal/IgniteClientRejoinTest.java | 3 +
.../IgniteComputeResultExceptionTest.java | 186 +
.../GridDiscoveryManagerAliveCacheSelfTest.java | 16 +-
.../GridAffinityProcessorAbstractSelfTest.java | 4 +-
...cheDhtLocalPartitionAfterRemoveSelfTest.java | 2 +-
.../cache/CacheGroupsMetricsRebalanceTest.java | 31 +-
.../CacheMetricsForClusterGroupSelfTest.java | 12 +-
.../DataStorageConfigurationValidationTest.java | 33 +-
.../cache/GridCacheAbstractFullApiSelfTest.java | 9 +-
.../cache/GridCacheAbstractSelfTest.java | 2 +
.../processors/cache/IgniteCacheGroupsTest.java | 1 +
.../cache/IgniteCacheNearLockValueSelfTest.java | 4 +-
.../IgniteCacheP2pUnmarshallingErrorTest.java | 11 +
.../IgniteClusterActivateDeactivateTest.java | 65 +
.../IgniteDaemonNodeMarshallerCacheTest.java | 3 +-
.../binary/BinaryMetadataUpdatesFlowTest.java | 12 +-
...ntNodeBinaryObjectMetadataMultinodeTest.java | 2 +-
.../GridCacheQueueClientDisconnectTest.java | 10 +
.../IgniteClientDataStructuresAbstractTest.java | 3 +-
...ExchangeLatchManagerCoordinatorFailTest.java | 244 +
.../CacheLateAffinityAssignmentTest.java | 127 +-
.../GridCacheNodeFailureAbstractTest.java | 5 +-
.../distributed/IgniteCache150ClientsTest.java | 2 +
.../distributed/IgniteCacheManyClientsTest.java | 44 +-
.../IgniteOptimisticTxSuspendResumeTest.java | 2 +
...ridCacheDhtPreloadMultiThreadedSelfTest.java | 4 +
.../dht/GridCacheDhtPreloadSelfTest.java | 2 +
.../GridCachePartitionsStateValidationTest.java | 316 ++
...idCachePartitionsStateValidatorSelfTest.java | 158 +
.../dht/TxRecoveryStoreEnabledTest.java | 15 +-
...titionedExplicitLockNodeFailureSelfTest.java | 3 +-
.../db/wal/IgniteWalFlushFailoverTest.java | 4 +-
...lFlushMultiNodeFailoverAbstractSelfTest.java | 4 +-
.../persistence/pagemem/PageMemoryImplTest.java | 9 +
.../persistence/tree/io/TrackingPageIOTest.java | 116 +-
.../ClientReconnectContinuousQueryTest.java | 19 +-
...yRemoteFilterMissingInClassPathSelfTest.java | 23 +-
...CacheContinuousQueryClientReconnectTest.java | 3 +
.../GridCacheWriteBehindStoreSelfTest.java | 41 +-
.../TxOptimisticOnPartitionExchangeTest.java | 322 ++
.../CacheVersionedEntryAbstractTest.java | 33 +-
.../closure/GridClosureSerializationTest.java | 2 +-
.../continuous/GridEventConsumeSelfTest.java | 34 +-
.../processors/database/BPlusTreeSelfTest.java | 29 +
.../service/ClosureServiceClientsNodesTest.java | 19 +-
.../GridServiceProcessorProxySelfTest.java | 12 +-
.../internal/util/GridTestClockTimer.java | 9 +
.../internal/util/StripedExecutorTest.java | 2 +-
.../GridMarshallerMappingConsistencyTest.java | 4 +
.../ignite/messaging/GridMessagingSelfTest.java | 126 +-
.../GridTcpCommunicationSpiAbstractTest.java | 71 +
.../TcpCommunicationSpiSkipMessageSendTest.java | 414 ++
.../FilterDataForClientNodeDiscoveryTest.java | 5 +
.../testframework/GridSpiTestContext.java | 10 +
.../ignite/testframework/GridTestUtils.java | 2 +-
.../config/GridTestProperties.java | 9 +
.../testframework/junits/GridAbstractTest.java | 129 +-
.../junits/multijvm/IgniteNodeRunner.java | 2 +
.../ignite/testsuites/IgniteBasicTestSuite.java | 4 +
.../ignite/testsuites/IgniteCacheTestSuite.java | 4 +
.../testsuites/IgniteCacheTestSuite5.java | 9 +-
.../testsuites/IgniteCacheTestSuite6.java | 6 +
.../testsuites/IgniteComputeGridTestSuite.java | 4 +
.../IgniteSpiCommunicationSelfTestSuite.java | 3 +
.../ignite/util/GridCommandHandlerTest.java | 43 +
.../query/h2/ddl/DdlStatementsProcessor.java | 22 +-
.../processors/query/h2/sql/GridSqlColumn.java | 17 +-
.../query/h2/sql/GridSqlCreateTable.java | 7 +-
.../query/h2/twostep/GridMapQueryExecutor.java | 7 +
.../query/h2/twostep/MapQueryLazyWorker.java | 13 +-
...niteCacheLockPartitionOnAffinityRunTest.java | 46 +-
...niteCacheDistributedQueryCancelSelfTest.java | 2 +-
.../DynamicIndexAbstractBasicSelfTest.java | 5 +-
.../cache/index/H2DynamicTableSelfTest.java | 37 +
.../cache/index/IgniteDecimalSelfTest.java | 265 +
.../h2/GridIndexingSpiAbstractSelfTest.java | 12 +-
.../IgniteCacheQuerySelfTestSuite.java | 2 +
.../GridJtaTransactionManagerSelfTest.java | 21 +-
.../GridPartitionedCacheJtaFactorySelfTest.java | 19 +-
.../main/java/org/apache/ignite/ml/Trainer.java | 3 -
.../apache/ignite/ml/genetic/Chromosome.java | 8 +-
.../apache/ignite/ml/genetic/CrossOverJob.java | 5 +-
.../apache/ignite/ml/genetic/CrossOverTask.java | 3 +-
.../apache/ignite/ml/genetic/FitnessJob.java | 6 +-
.../apache/ignite/ml/genetic/FitnessTask.java | 6 +-
.../org/apache/ignite/ml/genetic/GAGrid.java | 38 +-
.../java/org/apache/ignite/ml/genetic/Gene.java | 6 +-
.../ignite/ml/genetic/IFitnessFunction.java | 2 -
.../org/apache/ignite/ml/genetic/MutateJob.java | 10 +-
.../apache/ignite/ml/genetic/MutateTask.java | 19 +-
.../ignite/ml/genetic/TruncateSelectionJob.java | 11 +-
.../ml/genetic/TruncateSelectionTask.java | 64 +-
.../ml/genetic/cache/GeneCacheConfig.java | 2 -
.../ml/genetic/cache/PopulationCacheConfig.java | 2 -
.../ml/genetic/functions/GAGridFunction.java | 33 +-
.../genetic/parameter/ChromosomeCriteria.java | 7 +-
.../ml/genetic/parameter/GAConfiguration.java | 6 +-
.../ml/genetic/parameter/GAGridConstants.java | 4 +-
.../ignite/ml/genetic/utils/GAGridUtils.java | 10 +-
.../java/org/apache/ignite/ml/knn/KNNUtils.java | 59 +
.../KNNClassificationTrainer.java | 23 +-
.../ml/knn/regression/KNNRegressionModel.java | 87 +
.../ml/knn/regression/KNNRegressionTrainer.java | 40 +
.../ignite/ml/knn/regression/package-info.java | 22 +
.../org/apache/ignite/ml/nn/Activators.java | 20 +
.../org/apache/ignite/ml/nn/MLPTrainer.java | 46 +-
.../ml/preprocessing/PreprocessingTrainer.java | 41 +-
.../normalization/NormalizationTrainer.java | 35 +-
.../linear/FeatureExtractorWrapper.java | 55 +
.../linear/LinearRegressionLSQRTrainer.java | 38 +-
.../linear/LinearRegressionSGDTrainer.java | 118 +-
.../ignite/ml/trainers/DatasetTrainer.java | 46 +
.../org/apache/ignite/ml/tree/DecisionTree.java | 252 +
.../tree/DecisionTreeClassificationTrainer.java | 93 +
.../ml/tree/DecisionTreeConditionalNode.java | 78 +
.../ignite/ml/tree/DecisionTreeLeafNode.java | 48 +
.../apache/ignite/ml/tree/DecisionTreeNode.java | 26 +
.../ml/tree/DecisionTreeRegressionTrainer.java | 60 +
.../org/apache/ignite/ml/tree/TreeFilter.java | 38 +
.../ignite/ml/tree/data/DecisionTreeData.java | 128 +
.../ml/tree/data/DecisionTreeDataBuilder.java | 73 +
.../ignite/ml/tree/data/package-info.java | 22 +
.../ml/tree/impurity/ImpurityMeasure.java | 55 +
.../impurity/ImpurityMeasureCalculator.java | 38 +
.../tree/impurity/gini/GiniImpurityMeasure.java | 115 +
.../gini/GiniImpurityMeasureCalculator.java | 110 +
.../ml/tree/impurity/gini/package-info.java | 22 +
.../tree/impurity/mse/MSEImpurityMeasure.java | 133 +
.../mse/MSEImpurityMeasureCalculator.java | 80 +
.../ml/tree/impurity/mse/package-info.java | 22 +
.../ignite/ml/tree/impurity/package-info.java | 22 +
.../util/SimpleStepFunctionCompressor.java | 149 +
.../ml/tree/impurity/util/StepFunction.java | 162 +
.../impurity/util/StepFunctionCompressor.java | 55 +
.../ml/tree/impurity/util/package-info.java | 22 +
.../ml/tree/leaf/DecisionTreeLeafBuilder.java | 38 +
.../tree/leaf/MeanDecisionTreeLeafBuilder.java | 73 +
.../leaf/MostCommonDecisionTreeLeafBuilder.java | 86 +
.../ignite/ml/tree/leaf/package-info.java | 22 +
.../org/apache/ignite/ml/tree/package-info.java | 22 +
.../ignite/ml/trees/CategoricalRegionInfo.java | 72 -
.../ignite/ml/trees/CategoricalSplitInfo.java | 68 -
.../ignite/ml/trees/ContinuousRegionInfo.java | 74 -
.../ml/trees/ContinuousSplitCalculator.java | 51 -
.../org/apache/ignite/ml/trees/RegionInfo.java | 62 -
.../ml/trees/models/DecisionTreeModel.java | 44 -
.../ignite/ml/trees/models/package-info.java | 22 -
.../ml/trees/nodes/CategoricalSplitNode.java | 50 -
.../ml/trees/nodes/ContinuousSplitNode.java | 56 -
.../ignite/ml/trees/nodes/DecisionTreeNode.java | 33 -
.../org/apache/ignite/ml/trees/nodes/Leaf.java | 49 -
.../apache/ignite/ml/trees/nodes/SplitNode.java | 100 -
.../ignite/ml/trees/nodes/package-info.java | 22 -
.../apache/ignite/ml/trees/package-info.java | 22 -
.../ml/trees/trainers/columnbased/BiIndex.java | 113 -
...exedCacheColumnDecisionTreeTrainerInput.java | 57 -
.../CacheColumnDecisionTreeTrainerInput.java | 141 -
.../columnbased/ColumnDecisionTreeTrainer.java | 568 --
.../ColumnDecisionTreeTrainerInput.java | 55 -
.../MatrixColumnDecisionTreeTrainerInput.java | 83 -
.../trainers/columnbased/RegionProjection.java | 109 -
.../trainers/columnbased/TrainingContext.java | 166 -
.../columnbased/caches/ContextCache.java | 68 -
.../columnbased/caches/FeaturesCache.java | 151 -
.../columnbased/caches/ProjectionsCache.java | 286 --
.../trainers/columnbased/caches/SplitCache.java | 206 -
.../columnbased/caches/package-info.java | 22 -
.../ContinuousSplitCalculators.java | 34 -
.../contsplitcalcs/GiniSplitCalculator.java | 234 -
.../contsplitcalcs/VarianceSplitCalculator.java | 179 -
.../contsplitcalcs/package-info.java | 22 -
.../trainers/columnbased/package-info.java | 22 -
.../columnbased/regcalcs/RegionCalculators.java | 85 -
.../columnbased/regcalcs/package-info.java | 22 -
.../vectors/CategoricalFeatureProcessor.java | 212 -
.../vectors/ContinuousFeatureProcessor.java | 111 -
.../vectors/ContinuousSplitInfo.java | 71 -
.../columnbased/vectors/FeatureProcessor.java | 82 -
.../vectors/FeatureVectorProcessorUtils.java | 57 -
.../columnbased/vectors/SampleInfo.java | 80 -
.../trainers/columnbased/vectors/SplitInfo.java | 106 -
.../columnbased/vectors/package-info.java | 22 -
.../org/apache/ignite/ml/IgniteMLTestSuite.java | 4 +-
.../ml/genetic/GAGridCalculateFitnessTest.java | 6 +-
.../genetic/GAGridInitializePopulationTest.java | 7 +-
.../ignite/ml/knn/KNNClassificationTest.java | 20 +-
.../apache/ignite/ml/knn/KNNRegressionTest.java | 143 +
.../org/apache/ignite/ml/knn/KNNTestSuite.java | 1 +
.../ignite/ml/nn/MLPTrainerIntegrationTest.java | 14 +-
.../org/apache/ignite/ml/nn/MLPTrainerTest.java | 22 +-
.../MLPTrainerMnistIntegrationTest.java | 7 +-
.../ml/nn/performance/MLPTrainerMnistTest.java | 11 +-
.../ml/nn/performance/MnistMLPTestUtil.java | 9 +-
.../normalization/NormalizationTrainerTest.java | 10 +-
.../ml/regressions/RegressionsTestSuite.java | 15 +-
...stributedLinearRegressionSGDTrainerTest.java | 35 -
...stributedLinearRegressionSGDTrainerTest.java | 35 -
...wareAbstractLinearRegressionTrainerTest.java | 3 +
.../linear/LinearRegressionLSQRTrainerTest.java | 14 +-
.../linear/LinearRegressionSGDTrainerTest.java | 94 +
.../LocalLinearRegressionSGDTrainerTest.java | 35 -
.../ignite/ml/svm/SVMBinaryTrainerTest.java | 11 +-
.../ignite/ml/svm/SVMMultiClassTrainerTest.java | 11 +-
...reeClassificationTrainerIntegrationTest.java | 101 +
.../DecisionTreeClassificationTrainerTest.java | 87 +
...ionTreeRegressionTrainerIntegrationTest.java | 101 +
.../tree/DecisionTreeRegressionTrainerTest.java | 87 +
.../ignite/ml/tree/DecisionTreeTestSuite.java | 48 +
.../ml/tree/data/DecisionTreeDataTest.java | 59 +
.../gini/GiniImpurityMeasureCalculatorTest.java | 103 +
.../impurity/gini/GiniImpurityMeasureTest.java | 131 +
.../mse/MSEImpurityMeasureCalculatorTest.java | 59 +
.../impurity/mse/MSEImpurityMeasureTest.java | 109 +
.../util/SimpleStepFunctionCompressorTest.java | 75 +
.../ml/tree/impurity/util/StepFunctionTest.java | 71 +
.../tree/impurity/util/TestImpurityMeasure.java | 88 +
.../DecisionTreeMNISTIntegrationTest.java | 106 +
.../tree/performance/DecisionTreeMNISTTest.java | 75 +
.../ignite/ml/trees/BaseDecisionTreeTest.java | 70 -
.../ml/trees/ColumnDecisionTreeTrainerTest.java | 191 -
.../ignite/ml/trees/DecisionTreesTestSuite.java | 33 -
.../ml/trees/GiniSplitCalculatorTest.java | 141 -
.../ignite/ml/trees/SplitDataGenerator.java | 390 --
.../ml/trees/VarianceSplitCalculatorTest.java | 84 -
.../ColumnDecisionTreeTrainerBenchmark.java | 456 --
.../IgniteSessionStateStoreProviderTest.cs | 7 +-
.../Apache.Ignite.Benchmarks/BenchmarkRunner.cs | 1 -
.../ApiParity/IgniteConfigurationParityTest.cs | 3 +-
.../QueryEntityConfigurationParityTest.cs | 5 +-
.../Binary/BinaryDynamicRegistrationTest.cs | 2 +-
.../Cache/CacheAbstractTransactionalTest.cs | 5 +-
.../Cache/CacheConfigurationTest.cs | 2 +
.../Client/ClientConnectionTest.cs | 164 +-
.../Apache.Ignite.Core.Tests/EventsTest.cs | 9 +-
.../Apache.Ignite.Core.Tests/ExceptionsTest.cs | 3 +-
.../IgniteStartStopTest.cs | 5 +-
.../Apache.Ignite.Core.Tests/MessagingTest.cs | 5 +-
.../Apache.Ignite.Core.csproj | 1 +
.../Cache/Configuration/QueryEntity.cs | 4 +-
.../Cache/Configuration/QueryField.cs | 16 +-
.../Configuration/QuerySqlFieldAttribute.cs | 10 +
.../Client/ClientStatusCode.cs | 12 +-
.../Client/IgniteClientConfiguration.cs | 13 +
.../IgniteClientConfigurationSection.xsd | 10 +
.../IgniteConfigurationSection.xsd | 10 +
.../Impl/Client/ClientProtocolVersion.cs | 22 +-
.../Impl/Client/ClientSocket.cs | 89 +-
.../Impl/Common/TaskRunner.cs | 70 +
.../Impl/Datastream/DataStreamerBatch.cs | 2 +-
.../Impl/Datastream/DataStreamerImpl.cs | 2 +-
.../Apache.Ignite.Core/Impl/Events/Events.cs | 2 +-
.../Impl/Transactions/TransactionImpl.cs | 3 +-
.../org/apache/ignite/spark/IgniteRDD.scala | 9 +-
.../jdbc/CacheJdbcPojoStoreFactorySelfTest.java | 11 +-
.../ignite/internal/GridFactorySelfTest.java | 3 +-
.../resource/GridServiceInjectionSelfTest.java | 64 +-
.../GridSpringResourceInjectionSelfTest.java | 58 +-
.../p2p/GridP2PUserVersionChangeSelfTest.java | 5 +-
.../commands/cache/VisorCacheCommand.scala | 34 +-
.../cache/VisorCacheLostPartitionsCommand.scala | 170 +
.../VisorCacheResetLostPartitionsCommand.scala | 132 +
modules/web-console/backend/routes/demo.js | 2 +
modules/web-console/frontend/app/app.config.js | 14 +-
modules/web-console/frontend/app/app.js | 2 -
.../components/cache-edit-form/template.tpl.pug | 22 +-
.../cache-edit-form/templates/affinity.pug | 86 +
.../cache-edit-form/templates/concurrency.pug | 64 +
.../cache-edit-form/templates/general.pug | 113 +
.../cache-edit-form/templates/memory.pug | 158 +
.../templates/near-cache-client.pug | 50 +
.../templates/near-cache-server.pug | 51 +
.../cache-edit-form/templates/node-filter.pug | 53 +
.../cache-edit-form/templates/query.pug | 114 +
.../cache-edit-form/templates/rebalance.pug | 66 +
.../cache-edit-form/templates/statistics.pug | 34 +
.../cache-edit-form/templates/store.pug | 310 ++
.../cluster-edit-form/template.tpl.pug | 62 +-
.../cluster-edit-form/templates/atomic.pug | 75 +
.../cluster-edit-form/templates/attributes.pug | 40 +
.../cluster-edit-form/templates/binary.pug | 80 +
.../templates/cache-key-cfg.pug | 63 +
.../cluster-edit-form/templates/checkpoint.pug | 82 +
.../templates/checkpoint/fs.pug | 36 +
.../templates/checkpoint/jdbc.pug | 47 +
.../templates/checkpoint/s3.pug | 204 +
.../templates/client-connector.pug | 76 +
.../cluster-edit-form/templates/collision.pug | 58 +
.../templates/collision/custom.pug | 23 +
.../templates/collision/fifo-queue.pug | 26 +
.../templates/collision/job-stealing.pug | 51 +
.../templates/collision/priority-queue.pug | 41 +
.../templates/communication.pug | 134 +
.../cluster-edit-form/templates/connector.pug | 100 +
.../templates/data-storage.pug | 301 ++
.../cluster-edit-form/templates/deployment.pug | 192 +
.../cluster-edit-form/templates/discovery.pug | 97 +
.../cluster-edit-form/templates/events.pug | 66 +
.../cluster-edit-form/templates/failover.pug | 89 +
.../cluster-edit-form/templates/general.pug | 89 +
.../templates/general/discovery/cloud.pug | 78 +
.../templates/general/discovery/google.pug | 38 +
.../templates/general/discovery/jdbc.pug | 35 +
.../templates/general/discovery/kubernetes.pug | 38 +
.../templates/general/discovery/multicast.pug | 63 +
.../templates/general/discovery/s3.pug | 38 +
.../templates/general/discovery/shared.pug | 24 +
.../templates/general/discovery/vm.pug | 55 +
.../templates/general/discovery/zookeeper.pug | 84 +
.../retrypolicy/bounded-exponential-backoff.pug | 26 +
.../discovery/zookeeper/retrypolicy/custom.pug | 25 +
.../retrypolicy/exponential-backoff.pug | 26 +
.../discovery/zookeeper/retrypolicy/forever.pug | 23 +
.../discovery/zookeeper/retrypolicy/n-times.pug | 24 +
.../zookeeper/retrypolicy/one-time.pug | 23 +
.../zookeeper/retrypolicy/until-elapsed.pug | 24 +
.../cluster-edit-form/templates/hadoop.pug | 87 +
.../cluster-edit-form/templates/igfs.pug | 34 +
.../templates/load-balancing.pug | 115 +
.../cluster-edit-form/templates/logger.pug | 60 +
.../templates/logger/custom.pug | 24 +
.../templates/logger/log4j.pug | 49 +
.../templates/logger/log4j2.pug | 38 +
.../cluster-edit-form/templates/marshaller.pug | 75 +
.../cluster-edit-form/templates/memory.pug | 195 +
.../cluster-edit-form/templates/metrics.pug | 46 +
.../cluster-edit-form/templates/misc.pug | 58 +
.../cluster-edit-form/templates/odbc.pug | 70 +
.../cluster-edit-form/templates/persistence.pug | 82 +
.../cluster-edit-form/templates/service.pug | 89 +
.../templates/sql-connector.pug | 58 +
.../cluster-edit-form/templates/ssl.pug | 89 +
.../cluster-edit-form/templates/swap.pug | 74 +
.../cluster-edit-form/templates/thread.pug | 144 +
.../cluster-edit-form/templates/time.pug | 44 +
.../templates/transactions.pug | 65 +
.../components/igfs-edit-form/template.tpl.pug | 12 +-
.../igfs-edit-form/templates/dual.pug | 42 +
.../igfs-edit-form/templates/fragmentizer.pug | 37 +
.../igfs-edit-form/templates/general.pug | 72 +
.../components/igfs-edit-form/templates/ipc.pug | 55 +
.../igfs-edit-form/templates/misc.pug | 110 +
.../igfs-edit-form/templates/secondary.pug | 55 +
.../components/model-edit-form/template.tpl.pug | 6 +-
.../model-edit-form/templates/general.pug | 57 +
.../model-edit-form/templates/query.pug | 255 +
.../model-edit-form/templates/store.pug | 123 +
.../page-configure-basic/template.pug | 18 +-
.../components/modal-import-models/component.js | 4 +-
.../components/preview-panel/directive.js | 246 +
.../components/preview-panel/index.js | 23 +
.../app/components/page-configure/index.js | 25 +-
.../services/ConfigurationResource.js | 49 +
.../page-configure/services/SummaryZipper.js | 44 +
.../page-configure/services/summary.worker.js | 147 +
.../app/components/page-configure/states.js | 270 +
.../app/components/page-profile/controller.js | 4 +-
.../frontend/app/modules/ace.module.js | 47 +-
.../app/modules/states/configuration.state.js | 297 --
.../configuration/Configuration.resource.js | 42 -
.../states/configuration/caches/affinity.pug | 86 -
.../states/configuration/caches/concurrency.pug | 64 -
.../states/configuration/caches/general.pug | 113 -
.../states/configuration/caches/memory.pug | 158 -
.../configuration/caches/near-cache-client.pug | 50 -
.../configuration/caches/near-cache-server.pug | 51 -
.../states/configuration/caches/node-filter.pug | 53 -
.../states/configuration/caches/query.pug | 114 -
.../states/configuration/caches/rebalance.pug | 66 -
.../states/configuration/caches/statistics.pug | 34 -
.../states/configuration/caches/store.pug | 310 --
.../states/configuration/clusters/atomic.pug | 75 -
.../configuration/clusters/attributes.pug | 40 -
.../states/configuration/clusters/binary.pug | 80 -
.../configuration/clusters/cache-key-cfg.pug | 63 -
.../configuration/clusters/checkpoint.pug | 82 -
.../configuration/clusters/checkpoint/fs.pug | 36 -
.../configuration/clusters/checkpoint/jdbc.pug | 47 -
.../configuration/clusters/checkpoint/s3.pug | 204 -
.../configuration/clusters/client-connector.pug | 76 -
.../states/configuration/clusters/collision.pug | 58 -
.../configuration/clusters/collision/custom.pug | 23 -
.../clusters/collision/fifo-queue.pug | 26 -
.../clusters/collision/job-stealing.pug | 51 -
.../clusters/collision/priority-queue.pug | 41 -
.../configuration/clusters/communication.pug | 134 -
.../states/configuration/clusters/connector.pug | 100 -
.../configuration/clusters/data-storage.pug | 301 --
.../configuration/clusters/deployment.pug | 192 -
.../states/configuration/clusters/discovery.pug | 97 -
.../states/configuration/clusters/events.pug | 66 -
.../states/configuration/clusters/failover.pug | 89 -
.../states/configuration/clusters/general.pug | 89 -
.../clusters/general/discovery/cloud.pug | 78 -
.../clusters/general/discovery/google.pug | 38 -
.../clusters/general/discovery/jdbc.pug | 35 -
.../clusters/general/discovery/kubernetes.pug | 38 -
.../clusters/general/discovery/multicast.pug | 63 -
.../clusters/general/discovery/s3.pug | 38 -
.../clusters/general/discovery/shared.pug | 24 -
.../clusters/general/discovery/vm.pug | 55 -
.../clusters/general/discovery/zookeeper.pug | 84 -
.../retrypolicy/bounded-exponential-backoff.pug | 26 -
.../discovery/zookeeper/retrypolicy/custom.pug | 25 -
.../retrypolicy/exponential-backoff.pug | 26 -
.../discovery/zookeeper/retrypolicy/forever.pug | 23 -
.../discovery/zookeeper/retrypolicy/n-times.pug | 24 -
.../zookeeper/retrypolicy/one-time.pug | 23 -
.../zookeeper/retrypolicy/until-elapsed.pug | 24 -
.../states/configuration/clusters/hadoop.pug | 87 -
.../states/configuration/clusters/igfs.pug | 34 -
.../configuration/clusters/load-balancing.pug | 115 -
.../states/configuration/clusters/logger.pug | 60 -
.../configuration/clusters/logger/custom.pug | 24 -
.../configuration/clusters/logger/log4j.pug | 49 -
.../configuration/clusters/logger/log4j2.pug | 38 -
.../configuration/clusters/marshaller.pug | 75 -
.../states/configuration/clusters/memory.pug | 195 -
.../states/configuration/clusters/metrics.pug | 46 -
.../states/configuration/clusters/misc.pug | 58 -
.../states/configuration/clusters/odbc.pug | 70 -
.../configuration/clusters/persistence.pug | 82 -
.../states/configuration/clusters/service.pug | 89 -
.../configuration/clusters/sql-connector.pug | 58 -
.../states/configuration/clusters/ssl.pug | 89 -
.../states/configuration/clusters/swap.pug | 74 -
.../states/configuration/clusters/thread.pug | 144 -
.../states/configuration/clusters/time.pug | 44 -
.../configuration/clusters/transactions.pug | 65 -
.../states/configuration/domains/general.pug | 57 -
.../states/configuration/domains/query.pug | 255 -
.../states/configuration/domains/store.pug | 123 -
.../modules/states/configuration/igfs/dual.pug | 42 -
.../states/configuration/igfs/fragmentizer.pug | 37 -
.../states/configuration/igfs/general.pug | 72 -
.../modules/states/configuration/igfs/ipc.pug | 55 -
.../modules/states/configuration/igfs/misc.pug | 110 -
.../states/configuration/igfs/secondary.pug | 55 -
.../configuration/preview-panel.directive.js | 239 -
.../summary/summary-zipper.service.js | 39 -
.../configuration/summary/summary.worker.js | 147 -
.../services/AngularStrapSelect.decorator.js | 5 +-
.../services/AngularStrapTooltip.decorator.js | 8 +-
.../frontend/app/services/FormUtils.service.js | 3 +-
modules/web-console/frontend/package-lock.json | 929 ++--
.../demo/service/DemoCachesLoadService.java | 22 +-
modules/yardstick/pom-standalone.xml | 6 +
modules/yardstick/pom.xml | 6 +
.../IgniteColumnDecisionTreeGiniBenchmark.java | 70 -
...niteColumnDecisionTreeVarianceBenchmark.java | 71 -
.../yardstick/ml/trees/SplitDataGenerator.java | 426 --
.../ignite/yardstick/ml/trees/package-info.java | 22 -
modules/zookeeper/pom.xml | 40 +
.../spi/discovery/zk/ZookeeperDiscoverySpi.java | 557 ++
.../zk/internal/ZkAbstractCallabck.java | 83 +
.../zk/internal/ZkAbstractChildrenCallback.java | 61 +
.../zk/internal/ZkAbstractWatcher.java | 55 +
.../discovery/zk/internal/ZkAliveNodeData.java | 40 +
.../zk/internal/ZkBulkJoinContext.java | 50 +
.../discovery/zk/internal/ZkClusterNodes.java | 103 +
.../internal/ZkCommunicationErrorNodeState.java | 46 +
.../ZkCommunicationErrorProcessFuture.java | 411 ++
...kCommunicationErrorResolveFinishMessage.java | 69 +
.../ZkCommunicationErrorResolveResult.java | 45 +
...ZkCommunicationErrorResolveStartMessage.java | 61 +
.../internal/ZkCommunicationFailureContext.java | 188 +
.../zk/internal/ZkDiscoveryCustomEventData.java | 89 +
.../zk/internal/ZkDiscoveryEventData.java | 165 +
.../zk/internal/ZkDiscoveryEventsData.java | 121 +
.../internal/ZkDiscoveryNodeFailEventData.java | 55 +
.../internal/ZkDiscoveryNodeJoinEventData.java | 60 +
.../ZkDistributedCollectDataFuture.java | 250 +
.../zk/internal/ZkForceNodeFailMessage.java | 65 +
.../discovery/zk/internal/ZkIgnitePaths.java | 307 ++
.../zk/internal/ZkInternalJoinErrorMessage.java | 44 +
.../zk/internal/ZkInternalMessage.java | 27 +
.../zk/internal/ZkJoinEventDataForJoined.java | 83 +
.../zk/internal/ZkJoinedNodeEvtData.java | 79 +
.../zk/internal/ZkJoiningNodeData.java | 87 +
.../zk/internal/ZkNoServersMessage.java | 50 +
.../zk/internal/ZkNodeValidateResult.java | 43 +
.../spi/discovery/zk/internal/ZkRunnable.java | 51 +
.../discovery/zk/internal/ZkRuntimeState.java | 135 +
.../discovery/zk/internal/ZkTimeoutObject.java | 54 +
.../discovery/zk/internal/ZookeeperClient.java | 1219 +++++
.../ZookeeperClientFailedException.java | 40 +
.../zk/internal/ZookeeperClusterNode.java | 362 ++
.../zk/internal/ZookeeperDiscoveryImpl.java | 4464 ++++++++++++++++
.../java/org/apache/ZookeeperNodeStart.java | 46 +
...CacheEntryListenerWithZkDiscoAtomicTest.java | 32 +
.../ZookeeperDiscoverySpiAbstractTestSuite.java | 118 +
.../zk/ZookeeperDiscoverySpiTestSuite1.java | 44 +
.../zk/ZookeeperDiscoverySpiTestSuite2.java | 94 +
...ZookeeperDiscoverySuitePreprocessorTest.java | 101 +
.../zk/internal/ZookeeperClientTest.java | 495 ++
...okeeperDiscoverySpiSaslAuthAbstractTest.java | 247 +
...ZookeeperDiscoverySpiSaslFailedAuthTest.java | 44 +
...eeperDiscoverySpiSaslSuccessfulAuthTest.java | 48 +
.../zk/internal/ZookeeperDiscoverySpiTest.java | 4847 ++++++++++++++++++
.../zookeeper/ZkTestClientCnxnSocketNIO.java | 137 +
parent/pom.xml | 4 +
771 files changed, 41784 insertions(+), 15883 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/ecefdd33/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/near/GridNearTxLocal.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/ecefdd33/modules/core/src/test/java/org/apache/ignite/testsuites/IgniteCacheTestSuite.java
----------------------------------------------------------------------