Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/ignite into ignite-8900-repro
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/1e05b996 Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/1e05b996 Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/1e05b996 Branch: refs/heads/ignite-8900-repro Commit: 1e05b9963592e20150d6006752da8a7b9fc87b09 Parents: b3707b4 1caebb8 Author: Alexey Goncharuk <alexey.goncha...@gmail.com> Authored: Sat Jun 30 14:08:45 2018 +0300 Committer: Alexey Goncharuk <alexey.goncha...@gmail.com> Committed: Sat Jun 30 14:08:45 2018 +0300 ---------------------------------------------------------------------- assembly/libs/README.txt | 1 - examples/pom.xml | 58 +- .../ml/preprocessing/ImputingExample.java | 2 +- ...ecisionTreeClassificationTrainerExample.java | 6 +- .../DecisionTreeRegressionTrainerExample.java | 3 +- .../RandomForestClassificationExample.java | 304 + .../RandomForestRegressionExample.java | 636 + .../ml/tree/randomforest/package-info.java | 22 + .../ml/tutorial/Step_1_Read_and_Learn.java | 108 + .../examples/ml/tutorial/Step_2_Imputing.java | 115 + .../examples/ml/tutorial/Step_3_Categorial.java | 131 + .../ml/tutorial/Step_4_Add_age_fare.java | 131 + .../examples/ml/tutorial/Step_5_Scaling.java | 150 + .../ignite/examples/ml/tutorial/Step_6_KNN.java | 150 + .../ml/tutorial/Step_7_Split_train_test.java | 160 + .../ignite/examples/ml/tutorial/Step_8_CV.java | 218 + .../ml/tutorial/Step_9_Change_algorithm.java | 251 + .../examples/ml/tutorial/TitanicUtils.java | 91 + .../examples/ml/tutorial/package-info.java | 22 + .../src/main/resources/datasets/titanic.csv | 1310 ++ .../main/resources/datasets/titanic_10_rows.csv | 11 + .../cluster/TensorFlowClusterExample.java | 118 + .../rest/AbstractRestProcessorSelfTest.java | 4 +- .../JettyRestProcessorAbstractSelfTest.java | 116 +- .../rest/JettyRestProcessorCommonSelfTest.java | 171 + .../rest/JettyRestProcessorSignedSelfTest.java | 6 +- .../JettyRestProcessorUnsignedSelfTest.java | 11 +- .../java/org/apache/ignite/IgniteCache.java | 7 + .../apache/ignite/IgniteSystemProperties.java | 18 +- .../org/apache/ignite/cache/CacheManager.java | 12 +- .../org/apache/ignite/cache/CacheMetrics.java | 10 + .../java/org/apache/ignite/events/JobEvent.java | 73 +- .../apache/ignite/internal/IgniteKernal.java | 18 +- .../org/apache/ignite/internal/IgnitionEx.java | 4 + .../ignite/internal/LongJVMPauseDetector.java | 56 +- .../internal/MarshallerMappingFileStore.java | 85 +- .../internal/UnregisteredClassException.java | 74 + .../ignite/internal/binary/BinaryContext.java | 20 +- .../internal/binary/BinaryEnumObjectImpl.java | 2 +- .../internal/binary/BinaryMarshaller.java | 2 +- .../internal/binary/BinaryReaderExImpl.java | 2 +- .../ignite/internal/binary/BinaryUtils.java | 4 +- .../internal/binary/BinaryWriterExImpl.java | 28 +- .../internal/binary/GridBinaryMarshaller.java | 5 +- .../binary/builder/BinaryBuilderEnum.java | 2 +- .../binary/builder/BinaryBuilderSerializer.java | 2 +- .../builder/BinaryEnumArrayLazyValue.java | 2 +- .../builder/BinaryObjectArrayLazyValue.java | 2 +- .../binary/builder/BinaryObjectBuilderImpl.java | 2 +- .../client/thin/ClientBinaryMarshaller.java | 2 +- .../internal/commandline/CommandHandler.java | 18 +- .../pagemem/wal/IgniteWriteAheadLogManager.java | 5 + .../cache/CacheAffinitySharedManager.java | 3 +- .../cache/CacheClusterMetricsMXBeanImpl.java | 10 + .../CacheDefaultBinaryAffinityKeyMapper.java | 2 +- .../processors/cache/CacheGroupContext.java | 12 + .../cache/CacheLocalMetricsMXBeanImpl.java | 8 + .../processors/cache/CacheMetricsImpl.java | 15 +- .../processors/cache/CacheMetricsSnapshot.java | 30 + .../processors/cache/CacheOperationContext.java | 73 +- .../cache/GatewayProtectedCacheProxy.java | 26 +- .../processors/cache/GridCacheAdapter.java | 66 +- .../processors/cache/GridCacheContext.java | 2 +- .../processors/cache/GridCacheEntryEx.java | 5 - .../processors/cache/GridCacheGateway.java | 29 +- .../processors/cache/GridCacheMapEntry.java | 31 +- .../GridCachePartitionExchangeManager.java | 13 +- .../processors/cache/GridCacheProcessor.java | 7 + .../processors/cache/GridCacheProxyImpl.java | 25 +- .../processors/cache/GridCacheReturn.java | 5 + .../processors/cache/GridCacheTtlManager.java | 9 + .../processors/cache/IgniteCacheProxy.java | 3 + .../processors/cache/IgniteCacheProxyImpl.java | 7 +- .../processors/cache/IgniteInternalCache.java | 5 + .../binary/CacheObjectBinaryProcessor.java | 3 +- .../binary/CacheObjectBinaryProcessorImpl.java | 43 +- .../cache/binary/IgniteBinaryImpl.java | 2 +- .../distributed/GridCacheTxRecoveryFuture.java | 112 +- .../cache/distributed/dht/EvictionContext.java | 28 + .../dht/GridClientPartitionTopology.java | 40 + .../distributed/dht/GridDhtLocalPartition.java | 14 +- .../dht/GridDhtPartitionTopology.java | 15 + .../dht/GridDhtPartitionTopologyImpl.java | 39 + .../dht/GridDhtPartitionsEvictor.java | 326 +- .../dht/GridDhtPartitionsReservation.java | 2 +- .../dht/atomic/GridDhtAtomicCache.java | 70 +- .../dht/preloader/GridDhtPartitionDemander.java | 28 +- .../GridDhtPartitionSupplyMessage.java | 9 +- .../GridDhtPartitionsExchangeFuture.java | 60 +- .../preloader/GridDhtPartitionsFullMessage.java | 80 +- .../GridDhtPartitionsSingleMessage.java | 24 +- .../GridCacheDatabaseSharedManager.java | 224 +- .../cache/persistence/freelist/PagesList.java | 23 +- .../wal/AbstractWalRecordsIterator.java | 27 +- .../wal/FileWriteAheadLogManager.java | 229 +- .../wal/FsyncModeFileWriteAheadLogManager.java | 240 +- .../SingleSegmentLogicalRecordsIterator.java | 4 +- .../wal/reader/IgniteWalIteratorFactory.java | 617 +- .../reader/StandaloneWalRecordsIterator.java | 246 +- .../serializer/RecordSerializerFactoryImpl.java | 39 +- .../wal/serializer/RecordV1Serializer.java | 27 +- .../wal/serializer/RecordV2Serializer.java | 3 + .../cache/transactions/IgniteTxHandler.java | 8 +- .../cache/transactions/IgniteTxManager.java | 20 +- .../cache/version/GridCacheVersionManager.java | 3 + .../cacheobject/IgniteCacheObjectProcessor.java | 11 + .../IgniteCacheObjectProcessorImpl.java | 6 + .../datastreamer/DataStreamerImpl.java | 77 +- .../platform/cache/PlatformCache.java | 2 + .../processors/rest/GridRestProcessor.java | 94 +- .../processors/task/GridTaskWorker.java | 11 +- .../ignite/internal/util/GridArgumentCheck.java | 13 + .../ignite/internal/util/IgniteUtils.java | 20 +- .../util/StripedCompositeReadWriteLock.java | 25 +- .../internal/visor/cache/VisorCacheMetrics.java | 35 + .../visor/compute/VisorGatewayTask.java | 11 +- .../visor/node/VisorNodeDataCollectorJob.java | 20 +- .../ignite/internal/visor/tx/VisorTxInfo.java | 41 +- .../ignite/internal/visor/tx/VisorTxTask.java | 212 +- .../security/SecurityBasicPermissionSet.java | 4 +- .../ignite/spi/discovery/tcp/ClientImpl.java | 12 +- .../ignite/spi/discovery/tcp/ServerImpl.java | 11 +- .../ignite/failure/TestFailureHandler.java | 19 + .../GridEventStorageCheckAllEventsSelfTest.java | 90 +- .../ignite/internal/GridStartStopSelfTest.java | 43 +- .../IgniteClientReconnectCacheTest.java | 8 +- .../internal/LongJVMPauseDetectorTest.java | 58 + .../internal/TestRecordingCommunicationSpi.java | 42 +- .../cache/CacheGroupsMetricsRebalanceTest.java | 50 +- .../cache/CacheReadThroughRestartSelfTest.java | 2 +- ...idAbstractCacheInterceptorRebalanceTest.java | 2 +- .../cache/GridCacheAbstractFullApiSelfTest.java | 20 +- .../GridCacheAbstractLocalStoreSelfTest.java | 25 +- .../cache/GridCacheAbstractSelfTest.java | 2 +- .../processors/cache/GridCacheTestEntryEx.java | 5 - ...idCacheValueConsistencyAbstractSelfTest.java | 6 +- .../IgniteCacheConfigVariationsFullApiTest.java | 2 +- .../IgniteCacheEntryProcessorCallTest.java | 5 + .../IgniteStartCacheInTransactionSelfTest.java | 25 +- ...sExchangeOnDiscoveryHistoryOverflowTest.java | 2 + ...plicatedAtomicCacheGetsDistributionTest.java | 6 +- .../CacheGetInsideLockChangingTopologyTest.java | 10 +- .../GridCacheAbstractNodeRestartSelfTest.java | 4 +- .../IgniteCacheTxIteratorSelfTest.java | 2 +- ...AtomicPartitionedTckMetricsSelfTestImpl.java | 4 + ...idCacheNearOnlyMultiNodeFullApiSelfTest.java | 5 +- .../near/GridNearCacheStoreUpdateTest.java | 8 +- ...dCacheAtomicLocalTckMetricsSelfTestImpl.java | 4 + ...lientAffinityAssignmentWithBaselineTest.java | 2 +- ...lFlushMultiNodeFailoverAbstractSelfTest.java | 6 +- .../db/wal/IgniteWalFormatFileFailoverTest.java | 258 + ...gniteWalIteratorExceptionDuringReadTest.java | 150 + .../db/wal/reader/IgniteWalReaderTest.java | 1053 +- .../persistence/pagemem/NoOpWALManager.java | 5 + .../transactions/AtomicOperationsInTxTest.java | 227 + .../TxOptimisticDeadlockDetectionTest.java | 2 +- .../TxPessimisticDeadlockDetectionTest.java | 2 +- .../datastreamer/DataStreamerImplSelfTest.java | 29 + .../service/SystemCacheNotConfiguredTest.java | 172 + .../platform/PlatformCacheWriteMetricsTask.java | 10 + .../testframework/junits/GridAbstractTest.java | 1 + .../junits/common/GridCommonAbstractTest.java | 4 +- .../multijvm/IgniteCacheProcessProxy.java | 5 + .../ignite/testsuites/IgniteBasicTestSuite.java | 3 + .../testsuites/IgniteKernalSelfTestSuite.java | 4 + .../ignite/testsuites/IgnitePdsTestSuite2.java | 6 + .../ignite/util/GridCommandHandlerTest.java | 303 +- .../util/mbeans/GridMBeanBaselineTest.java | 31 +- .../development/utils/IgniteWalConverter.java | 10 +- .../IgniteNativeIoWalFlushFsyncSelfTest.java | 6 - .../cache/hibernate/HibernateCacheProxy.java | 5 + .../query/h2/DmlStatementsProcessor.java | 2 +- .../visor/verify/ValidateIndexesClosure.java | 15 +- .../cache/IgniteCacheGroupsSqlTest.java | 4 +- .../util/GridCommandHandlerIndexingTest.java | 3 + .../config/example-kube-persistence.xml | 56 + .../ml/composition/BaggingModelTrainer.java | 210 + .../ml/composition/ModelsComposition.java | 131 + .../ignite/ml/composition/package-info.java | 22 + .../MeanValuePredictionsAggregator.java | 32 + .../OnMajorityPredictionsAggregator.java | 44 + .../PredictionsAggregator.java | 26 + .../predictionsaggregator/package-info.java | 23 + .../ignite/ml/dataset/DatasetBuilder.java | 8 + .../impl/cache/CacheBasedDatasetBuilder.java | 6 + .../dataset/impl/local/LocalDatasetBuilder.java | 6 + .../StringEncoderPreprocessor.java | 28 +- .../stringencoder/StringEncoderTrainer.java | 87 +- .../binomial/LogisticRegressionModel.java | 6 +- .../cv/CrossValidationScoreCalculator.java | 4 +- .../CacheBasedTruthWithPredictionCursor.java | 8 +- .../util/LocalTruthWithPredictionCursor.java | 10 +- .../split/mapper/SHA256UniformMapper.java | 2 +- .../org/apache/ignite/ml/tree/DecisionTree.java | 3 +- .../ml/tree/DecisionTreeConditionalNode.java | 6 +- .../ignite/ml/tree/DecisionTreeLeafNode.java | 4 +- .../apache/ignite/ml/tree/DecisionTreeNode.java | 3 +- .../ml/tree/data/DecisionTreeDataBuilder.java | 1 + .../RandomForestClassifierTrainer.java | 103 + .../RandomForestRegressionTrainer.java | 103 + .../tree/randomforest/RandomForestTrainer.java | 83 + .../ml/tree/randomforest/package-info.java | 22 + .../MeanValuePredictionsAggregatorTest.java | 31 + .../OnMajorityPredictionsAggregatorTest.java | 31 + .../encoding/StringEncoderPreprocessorTest.java | 11 +- .../encoding/StringEncoderTrainerTest.java | 4 +- ...CacheBasedTruthWithPredictionCursorTest.java | 2 +- .../LocalTruthWithPredictionCursorTest.java | 2 +- .../ignite/ml/tree/DecisionTreeTestSuite.java | 6 +- .../DecisionTreeMNISTIntegrationTest.java | 6 +- .../tree/performance/DecisionTreeMNISTTest.java | 10 +- .../RandomForestClassifierTrainerTest.java | 80 + .../RandomForestRegressionTrainerTest.java | 80 + .../cpp/core-test/src/compute_test.cpp | 4 +- .../cpp/odbc-test/src/queries_test.cpp | 35 + .../cpp/odbc-test/src/sql_types_test.cpp | 4 +- .../src/sql_value_expressions_test.cpp | 2 +- modules/platforms/cpp/odbc/src/message.cpp | 2 +- .../cpp/odbc/src/query/batch_query.cpp | 6 +- .../platforms/cpp/odbc/src/query/data_query.cpp | 6 +- .../cpp/odbc/src/query/type_info_query.cpp | 2 +- .../ExpiryCacheHolderTest.cs | 7 + .../Cache/CacheTestAsyncWrapper.cs | 13 +- .../dotnet/Apache.Ignite.Core/Cache/ICache.cs | 12 + .../Apache.Ignite.Core/Cache/ICacheMetrics.cs | 18 + .../Apache.Ignite.Core/Impl/Cache/CacheImpl.cs | 34 +- .../Impl/Cache/CacheMetricsImpl.cs | 14 + .../dotnet/Apache.Ignite.Core/Impl/Ignite.cs | 2 +- modules/platforms/nodejs/README.md | 615 + .../platforms/nodejs/api_spec/BinaryObject.html | 1847 +++ .../nodejs/api_spec/BinaryObject.js.html | 549 + .../platforms/nodejs/api_spec/CacheClient.html | 4867 ++++++ .../nodejs/api_spec/CacheClient.js.html | 812 + .../nodejs/api_spec/CacheConfiguration.html | 8527 ++++++++++ .../nodejs/api_spec/CacheConfiguration.js.html | 1784 +++ .../platforms/nodejs/api_spec/CacheEntry.html | 468 + .../nodejs/api_spec/CacheKeyConfiguration.html | 796 + .../nodejs/api_spec/CollectionObjectType.html | 524 + .../nodejs/api_spec/ComplexObjectType.html | 526 + .../nodejs/api_spec/CompositeType.html | 170 + modules/platforms/nodejs/api_spec/Cursor.html | 588 + .../platforms/nodejs/api_spec/Cursor.js.html | 360 + modules/platforms/nodejs/api_spec/EnumItem.html | 1431 ++ .../platforms/nodejs/api_spec/EnumItem.js.html | 255 + .../platforms/nodejs/api_spec/Errors.js.html | 172 + .../platforms/nodejs/api_spec/IgniteClient.html | 2368 +++ .../nodejs/api_spec/IgniteClient.js.html | 343 + .../api_spec/IgniteClientConfiguration.html | 846 + .../api_spec/IgniteClientConfiguration.js.html | 163 + .../nodejs/api_spec/IgniteClientError.html | 168 + .../nodejs/api_spec/IllegalStateError.html | 179 + .../nodejs/api_spec/LostConnectionError.html | 179 + .../nodejs/api_spec/MapObjectType.html | 485 + .../nodejs/api_spec/ObjectArrayType.html | 265 + .../platforms/nodejs/api_spec/ObjectType.html | 1126 ++ .../nodejs/api_spec/ObjectType.js.html | 651 + .../nodejs/api_spec/OperationError.html | 179 + modules/platforms/nodejs/api_spec/Query.html | 481 + modules/platforms/nodejs/api_spec/Query.js.html | 559 + .../platforms/nodejs/api_spec/QueryEntity.html | 2218 +++ .../platforms/nodejs/api_spec/QueryField.html | 2211 +++ .../platforms/nodejs/api_spec/QueryIndex.html | 1480 ++ .../platforms/nodejs/api_spec/ScanQuery.html | 686 + .../nodejs/api_spec/SqlFieldsCursor.html | 915 ++ .../nodejs/api_spec/SqlFieldsQuery.html | 3036 ++++ modules/platforms/nodejs/api_spec/SqlQuery.html | 1755 +++ .../platforms/nodejs/api_spec/Timestamp.html | 566 + .../platforms/nodejs/api_spec/Timestamp.js.html | 127 + modules/platforms/nodejs/api_spec/conf.json | 12 + .../api_spec/fonts/OpenSans-Bold-webfont.eot | Bin 0 -> 19544 bytes .../api_spec/fonts/OpenSans-Bold-webfont.svg | 1830 +++ .../api_spec/fonts/OpenSans-Bold-webfont.woff | Bin 0 -> 22432 bytes .../fonts/OpenSans-BoldItalic-webfont.eot | Bin 0 -> 20133 bytes .../fonts/OpenSans-BoldItalic-webfont.svg | 1830 +++ .../fonts/OpenSans-BoldItalic-webfont.woff | Bin 0 -> 23048 bytes .../api_spec/fonts/OpenSans-Italic-webfont.eot | Bin 0 -> 20265 bytes .../api_spec/fonts/OpenSans-Italic-webfont.svg | 1830 +++ .../api_spec/fonts/OpenSans-Italic-webfont.woff | Bin 0 -> 23188 bytes .../api_spec/fonts/OpenSans-Light-webfont.eot | Bin 0 -> 19514 bytes .../api_spec/fonts/OpenSans-Light-webfont.svg | 1831 +++ .../api_spec/fonts/OpenSans-Light-webfont.woff | Bin 0 -> 22248 bytes .../fonts/OpenSans-LightItalic-webfont.eot | Bin 0 -> 20535 bytes .../fonts/OpenSans-LightItalic-webfont.svg | 1835 +++ .../fonts/OpenSans-LightItalic-webfont.woff | Bin 0 -> 23400 bytes .../api_spec/fonts/OpenSans-Regular-webfont.eot | Bin 0 -> 19836 bytes .../api_spec/fonts/OpenSans-Regular-webfont.svg | 1831 +++ .../fonts/OpenSans-Regular-webfont.woff | Bin 0 -> 22660 bytes modules/platforms/nodejs/api_spec/index.html | 65 + .../nodejs/api_spec/scripts/linenumber.js | 25 + .../scripts/prettify/Apache-License-2.0.txt | 202 + .../api_spec/scripts/prettify/lang-css.js | 2 + .../api_spec/scripts/prettify/prettify.js | 28 + .../nodejs/api_spec/styles/jsdoc-default.css | 358 + .../nodejs/api_spec/styles/prettify-jsdoc.css | 111 + .../api_spec/styles/prettify-tomorrow.css | 132 + .../platforms/nodejs/examples/AuthTlsExample.js | 128 + .../nodejs/examples/CachePutGetExample.js | 186 + .../nodejs/examples/FailoverExample.js | 59 + modules/platforms/nodejs/examples/README.md | 128 + modules/platforms/nodejs/examples/SqlExample.js | 242 + .../nodejs/examples/SqlQueryEntriesExample.js | 136 + modules/platforms/nodejs/examples/certs/ca.crt | 32 + .../platforms/nodejs/examples/certs/client.crt | 30 + .../platforms/nodejs/examples/certs/client.key | 51 + .../nodejs/examples/certs/keystore.jks | Bin 0 -> 3828 bytes .../nodejs/examples/certs/truststore.jks | Bin 0 -> 1477 bytes modules/platforms/nodejs/index.js | 43 + modules/platforms/nodejs/lib/BinaryObject.js | 498 + modules/platforms/nodejs/lib/CacheClient.js | 761 + .../platforms/nodejs/lib/CacheConfiguration.js | 1733 +++ modules/platforms/nodejs/lib/Cursor.js | 309 + modules/platforms/nodejs/lib/EnumItem.js | 204 + modules/platforms/nodejs/lib/Errors.js | 121 + modules/platforms/nodejs/lib/IgniteClient.js | 292 + .../nodejs/lib/IgniteClientConfiguration.js | 112 + modules/platforms/nodejs/lib/ObjectType.js | 600 + modules/platforms/nodejs/lib/Query.js | 508 + modules/platforms/nodejs/lib/Timestamp.js | 76 + .../nodejs/lib/internal/ArgumentChecker.js | 83 + .../nodejs/lib/internal/BinaryReader.js | 197 + .../platforms/nodejs/lib/internal/BinaryType.js | 472 + .../nodejs/lib/internal/BinaryTypeStorage.js | 112 + .../nodejs/lib/internal/BinaryUtils.js | 598 + .../nodejs/lib/internal/BinaryWriter.js | 210 + .../nodejs/lib/internal/ClientFailoverSocket.js | 134 + .../nodejs/lib/internal/ClientSocket.js | 434 + modules/platforms/nodejs/lib/internal/Logger.js | 45 + .../nodejs/lib/internal/MessageBuffer.js | 272 + modules/platforms/nodejs/package-lock.json | 168 + modules/platforms/nodejs/package.json | 25 + .../platforms/nodejs/spec/ExamplesExecutor.js | 11 + modules/platforms/nodejs/spec/README.md | 42 + modules/platforms/nodejs/spec/TestingHelper.js | 384 + .../nodejs/spec/cache/BinaryObject.spec.js | 176 + .../platforms/nodejs/spec/cache/Cache.spec.js | 262 + .../nodejs/spec/cache/CacheKeyValueOps.spec.js | 1022 ++ .../spec/cache/CachePutGetDiffTypes.spec.js | 647 + .../nodejs/spec/cache/ComplexObject.spec.js | 464 + modules/platforms/nodejs/spec/config.js | 27 + .../nodejs/spec/examples/AuthExample.spec.js | 28 + .../nodejs/spec/examples/Examples.spec.js | 40 + .../nodejs/spec/query/ScanQuery.spec.js | 207 + .../nodejs/spec/query/SqlFieldsQuery.spec.js | 247 + .../nodejs/spec/query/SqlQuery.spec.js | 247 + .../platforms/nodejs/spec/support/jasmine.json | 11 + modules/spark-2.10/README.txt | 4 - modules/spark-2.10/licenses/apache-2.0.txt | 202 - modules/spark-2.10/pom.xml | 237 - .../impl/optimization/StringExpressions.scala | 30 +- .../spark/impl/optimization/package.scala | 2 +- .../sql/ignite/IgniteExternalCatalog.scala | 17 +- .../spark/sql/ignite/IgniteOptimization.scala | 14 +- .../spark/sql/ignite/IgniteSparkSession.scala | 10 +- .../ignite/spark/AbstractDataFrameSpec.scala | 2 +- .../ignite/spark/IgniteDataFrameSuite.scala | 3 +- .../IgniteOptimizationAggregationFuncSpec.scala | 4 +- .../spark/IgniteOptimizationJoinSpec.scala | 6 +- .../spark/IgniteOptimizationMathFuncSpec.scala | 46 +- .../ignite/spark/IgniteOptimizationSpec.scala | 8 +- .../IgniteOptimizationStringFuncSpec.scala | 101 +- .../ignite/cache/spring/SpringCacheManager.java | 31 +- .../spring/SpringTransactionManager.java | 28 +- .../spring-transactions-ignite-spring-bean.xml | 67 + .../test/java/config/spring-transactions.xml | 7 +- .../GridSpringCacheManagerAbstractTest.java | 382 + .../spring/GridSpringCacheManagerSelfTest.java | 359 +- ...ridSpringCacheManagerSpringBeanSelfTest.java | 40 + .../spring-caching-ignite-spring-bean.xml | 90 + .../testsuites/IgniteSpringTestSuite.java | 4 + ...ridSpringTransactionManagerAbstractTest.java | 136 + .../GridSpringTransactionManagerSelfTest.java | 127 +- ...ingTransactionManagerSpringBeanSelfTest.java | 52 + .../spring/GridSpringTransactionService.java | 2 - modules/tensorflow/licences/apache-2.0.txt | 202 - modules/tensorflow/licenses/apache-2.0.txt | 202 + modules/tensorflow/pom.xml | 30 +- .../tensorflow/cluster/TensorFlowCluster.java | 62 + .../cluster/TensorFlowClusterGateway.java | 68 + .../TensorFlowClusterGatewayManager.java | 92 + .../cluster/TensorFlowClusterMaintainer.java | 138 + .../cluster/TensorFlowClusterManager.java | 211 + .../ignite/tensorflow/cluster/package-info.java | 33 + .../cluster/spec/TensorFlowClusterSpec.java | 59 + .../spec/TensorFlowServerAddressSpec.java | 59 + .../tensorflow/cluster/spec/package-info.java | 22 + .../cluster/tfrunning/TensorFlowServer.java | 100 + .../tfrunning/TensorFlowServerManager.java | 167 + .../cluster/tfrunning/package-info.java | 23 + .../cluster/util/ClusterPortManager.java | 161 + .../cluster/util/TensorFlowClusterResolver.java | 101 + .../tensorflow/cluster/util/package-info.java | 22 + .../ignite/tensorflow/core/ProcessManager.java | 63 + .../tensorflow/core/ProcessManagerWrapper.java | 83 + .../core/longrunning/LongRunningProcess.java | 61 + .../longrunning/LongRunningProcessManager.java | 168 + .../core/longrunning/package-info.java | 25 + .../task/LongRunningProcessClearTask.java | 98 + .../task/LongRunningProcessPingTask.java | 85 + .../task/LongRunningProcessStartTask.java | 114 + .../task/LongRunningProcessStopTask.java | 102 + .../task/LongRunningProcessTask.java | 53 + .../core/longrunning/task/package-info.java | 23 + .../task/util/LongRunningProcessState.java | 27 + .../task/util/LongRunningProcessStatus.java | 66 + .../longrunning/task/util/package-info.java | 22 + .../core/nativerunning/NativeProcess.java | 71 + .../nativerunning/NativeProcessManager.java | 59 + .../core/nativerunning/package-info.java | 25 + .../task/NativeProcessStartTask.java | 116 + .../core/nativerunning/task/package-info.java | 22 + .../ignite/tensorflow/core/package-info.java | 26 + .../core/pythonrunning/PythonProcess.java | 58 + .../pythonrunning/PythonProcessManager.java | 83 + .../core/pythonrunning/package-info.java | 25 + .../core/util/CustomizableThreadFactory.java | 54 + .../tensorflow/core/util/package-info.java | 22 + .../apache/ignite/tensorflow/package-info.java | 37 + .../ignite/tensorflow/TensorFlowTestSuite.java | 33 + .../ignite/tensorflow/core/CoreTestSuite.java | 42 + .../core/ProcessManagerWrapperTest.java | 108 + .../LongRunningProcessManagerTest.java | 169 + .../task/LongRunningProcessClearTaskTest.java | 144 + .../task/LongRunningProcessPingTaskTest.java | 152 + .../task/LongRunningProcessStartTaskTest.java | 101 + .../task/LongRunningProcessStopTaskTest.java | 157 + modules/web-console/.dockerignore | 8 +- modules/web-console/.gitignore | 4 +- modules/web-console/DEVNOTES.txt | 86 +- modules/web-console/assembly/README.txt | 11 +- .../web-console/backend/agent_dists/README.txt | 5 +- modules/web-console/backend/app/agentSocket.js | 117 +- .../web-console/backend/app/agentsHandler.js | 4 +- .../web-console/backend/app/browsersHandler.js | 38 +- modules/web-console/backend/app/mongo.js | 5 +- .../ignite_modules/migrations/README.txt | 4 - modules/web-console/backend/index.js | 122 +- modules/web-console/backend/injector.js | 3 +- modules/web-console/backend/launch-tools.js | 109 + modules/web-console/backend/middlewares/api.js | 7 +- modules/web-console/backend/package-lock.json | 6888 +++++++++ modules/web-console/backend/package.json | 42 +- .../web-console/backend/services/clusters.js | 15 +- .../web-console/backend/services/downloads.js | 2 + modules/web-console/backend/test/app/db.js | 6 +- .../web-console/backend/test/app/httpAgent.js | 2 +- .../web-console/backend/test/data/caches.json | 60 +- .../web-console/backend/test/data/clusters.json | 6 +- .../web-console/backend/test/data/domains.json | 21 +- modules/web-console/backend/test/index.js | 4 - modules/web-console/backend/test/injector.js | 41 +- .../web-console/backend/test/routes/clusters.js | 13 +- .../web-console/backend/test/routes/public.js | 4 +- .../backend/test/unit/AuthService.test.js | 11 - .../backend/test/unit/CacheService.test.js | 4 +- .../backend/test/unit/ClusterService.test.js | 22 +- .../web-console/backend/test/unit/Utils.test.js | 48 + .../docker/compose/backend/.dockerignore | 3 - .../docker/compose/backend/Dockerfile | 15 +- .../web-console/docker/compose/backend/build.sh | 57 - .../docker/compose/docker-compose.yml | 70 +- .../docker/compose/frontend/.dockerignore | 3 - .../docker/compose/frontend/Dockerfile | 23 +- .../docker/compose/frontend/DockerfileBuild | 30 - .../docker/compose/frontend/build.sh | 59 - .../compose/frontend/nginx/web-console.conf | 5 - .../web-console/docker/standalone/.dockerignore | 2 - .../web-console/docker/standalone/Dockerfile | 73 +- .../web-console/docker/standalone/README.txt | 24 - .../docker/standalone/docker-entrypoint.sh | 23 + .../web-console/docker/standalone/entrypoint.sh | 23 - .../docker/standalone/nginx/web-console.conf | 2 +- modules/web-console/e2e/docker-compose.yml | 2 +- modules/web-console/e2e/testcafe/Dockerfile | 10 +- .../e2e/testcafe/components/FormField.js | 3 + .../e2e/testcafe/components/Table.js | 23 +- .../e2e/testcafe/environment/envtools.js | 196 + .../e2e/testcafe/environment/launch-env.js | 26 + modules/web-console/e2e/testcafe/envtools.js | 192 - .../e2e/testcafe/fixtures/admin-panel.js | 2 +- .../testcafe/fixtures/auth/forgot-password.js | 2 +- .../e2e/testcafe/fixtures/auth/logout.js | 2 +- .../fixtures/auth/signup-validation-local.js | 2 +- .../e2e/testcafe/fixtures/auth/signup.js | 2 +- .../testcafe/fixtures/configuration/basic.js | 5 +- .../testcafe/fixtures/configuration/overview.js | 2 +- .../e2e/testcafe/fixtures/menu-smoke.js | 4 +- .../testcafe/fixtures/queries/notebooks-list.js | 2 +- .../fixtures/user-profile/credentials.js | 11 +- .../testcafe/fixtures/user-profile/profile.js | 2 +- modules/web-console/e2e/testcafe/index.js | 38 + .../web-console/e2e/testcafe/package-lock.json | 2486 +++ modules/web-console/e2e/testcafe/package.json | 16 +- .../e2e/testcafe/page-models/pageProfile.js | 4 +- modules/web-console/e2e/testcafe/roles.js | 6 +- .../web-console/e2e/testcafe/testcafe-runner.js | 62 + modules/web-console/e2e/testcafe/testcafe.js | 86 - modules/web-console/e2e/testenv/Dockerfile | 71 +- modules/web-console/e2e/testenv/entrypoint.sh | 21 - .../web-console/e2e/testenv/nginx/nginx.conf | 58 +- modules/web-console/frontend/.gitignore | 7 +- modules/web-console/frontend/app/app.js | 13 +- .../cluster-security-icon/component.js | 25 + .../components/cluster-security-icon/index.js | 24 + .../cluster-security-icon/template.pug | 30 + .../app/components/cluster-selector/style.scss | 11 +- .../components/cluster-selector/template.pug | 43 +- .../connected-clusters-badge/controller.js | 51 + .../connected-clusters-badge/index.js | 33 + .../connected-clusters-badge/style.scss | 43 + .../connected-clusters-badge/template.pug | 19 + .../components/cell-logout/index.js | 43 + .../components/cell-logout/template.pug | 23 + .../components/cell-status/index.js | 26 + .../components/cell-status/style.scss | 46 + .../components/cell-status/template.pug | 18 + .../components/list/column-defs.js | 59 + .../components/list/controller.js | 59 + .../components/list/index.js | 29 + .../components/list/style.scss | 49 + .../components/list/template.tpl.pug | 19 + .../connected-clusters-dialog/controller.js | 24 + .../connected-clusters-dialog/index.js | 35 + .../connected-clusters-dialog/service.js | 44 + .../connected-clusters-dialog/style.scss | 23 + .../connected-clusters-dialog/template.tpl.pug | 34 + .../components/connected-clusters/controller.js | 36 - .../app/components/connected-clusters/index.js | 29 - .../components/connected-clusters/style.scss | 40 - .../components/connected-clusters/template.pug | 18 - .../copyInputValueButton.directive.js | 86 + .../frontend/app/components/form-field/index.js | 5 +- .../app/components/form-field/style.scss | 29 + .../app/components/grid-export/template.pug | 4 +- .../list-editable-cols/cols.style.scss | 4 +- .../list-of-registered-users/template.tpl.pug | 2 +- .../components/pc-items-table/template.pug | 2 +- .../app/components/page-profile/controller.js | 2 +- .../app/components/page-profile/template.pug | 22 +- .../queries-notebooks-list/template.tpl.pug | 2 +- .../components/user-notifications/service.js | 5 + .../components/user-notifications/style.scss | 2 +- .../components/web-console-header/style.scss | 11 + .../app/modules/agent/AgentManager.service.js | 286 +- .../app/modules/agent/AgentModal.service.js | 9 +- .../frontend/app/modules/agent/agent.module.js | 8 +- .../agent/components/cluster-login/component.js | 40 + .../agent/components/cluster-login/index.js | 26 + .../agent/components/cluster-login/service.js | 66 + .../agent/components/cluster-login/template.pug | 56 + .../frontend/app/modules/agent/types/Cluster.js | 37 + .../app/modules/agent/types/ClusterSecrets.js | 61 + .../agent/types/ClusterSecretsManager.js | 70 + .../app/primitives/datepicker/index.scss | 6 +- .../frontend/app/primitives/panel/index.scss | 2 +- .../frontend/app/primitives/switcher/index.scss | 2 +- .../app/primitives/timepicker/index.scss | 6 +- .../app/primitives/ui-grid-settings/index.scss | 6 +- .../frontend/app/primitives/ui-grid/index.scss | 8 + .../frontend/app/utils/SimpleWorkerPool.js | 2 + .../frontend/ignite_modules/README.txt | 6 - .../frontend/ignite_modules/index.js | 22 - modules/web-console/frontend/index.js | 22 + modules/web-console/frontend/package-lock.json | 13704 ++++++++++------- modules/web-console/frontend/package.json | 95 +- .../frontend/public/images/icons/copy.svg | 3 + .../frontend/public/images/icons/exit.svg | 3 + .../frontend/public/images/icons/index.js | 38 +- .../frontend/public/images/icons/lockClosed.svg | 3 + .../frontend/public/images/icons/lockOpened.svg | 3 + .../stylesheets/_bootstrap-variables.scss | 2 +- .../frontend/public/stylesheets/style.scss | 4 +- .../frontend/test/check-doc-links/Dockerfile | 2 +- modules/web-console/frontend/test/ci/Dockerfile | 15 +- .../frontend/test/karma.conf.babel.js | 8 +- modules/web-console/frontend/views/index.pug | 2 +- .../views/templates/agent-download.tpl.pug | 17 +- .../frontend/webpack/webpack.common.js | 46 +- .../frontend/webpack/webpack.dev.babel.js | 4 +- .../frontend/webpack/webpack.prod.babel.js | 10 +- modules/web-console/pom.xml | 565 +- modules/web-console/web-agent/README.txt | 6 + .../console/agent/AgentConfiguration.java | 115 +- .../ignite/console/agent/AgentLauncher.java | 334 +- .../apache/ignite/console/agent/AgentUtils.java | 24 + .../agent/handlers/AbstractListener.java | 50 +- .../console/agent/handlers/ClusterListener.java | 227 +- .../agent/handlers/DatabaseListener.java | 2 +- .../console/agent/handlers/DemoListener.java | 131 - .../console/agent/handlers/RestListener.java | 41 +- .../ignite/console/agent/rest/RestExecutor.java | 308 +- .../ignite/console/agent/rest/RestResult.java | 18 +- .../ignite/console/demo/AgentClusterDemo.java | 7 +- .../zk/internal/ZookeeperClusterNode.java | 4 +- .../zk/internal/ZookeeperDiscoveryImpl.java | 20 +- .../zk/internal/ZookeeperDiscoverySpiTest.java | 33 +- packaging/deb/changelog | 6 + packaging/rpm/apache-ignite.spec | 31 +- packaging/rpm/name.service | 2 +- parent/pom.xml | 26 +- pom.xml | 9 +- 600 files changed, 107000 insertions(+), 11103 deletions(-) ----------------------------------------------------------------------
