You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by vk...@apache.org on 2018/03/20 02:17:13 UTC
[2/4] ignite git commit: Merge branch 'master' of
https://git-wip-us.apache.org/repos/asf/ignite
Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/ignite
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/5eb54e2e
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/5eb54e2e
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/5eb54e2e
Branch: refs/heads/master
Commit: 5eb54e2eb96f5dc1c117d3b0a94f7c5cb04adbcf
Parents: 7b2c34a 0a92af5
Author: Valentin Kulichenko <va...@gmail.com>
Authored: Mon Mar 19 19:14:22 2018 -0700
Committer: Valentin Kulichenko <va...@gmail.com>
Committed: Mon Mar 19 19:14:22 2018 -0700
----------------------------------------------------------------------
.../change/OptimizeMakeChangeGAExample.java | 15 +-
.../genetic/helloworld/HelloWorldGAExample.java | 6 +-
.../ml/genetic/movie/MovieGAExample.java | 15 +-
...nWithLSQRTrainerAndNormalizationExample.java | 184 +++
.../ml/svm/SVMBinaryClassificationExample.java | 131 --
.../ml/svm/SVMMultiClassificationExample.java | 130 --
.../binary/SVMBinaryClassificationExample.java | 233 ++++
.../examples/ml/svm/binary/package-info.java | 22 +
.../ignite/examples/ml/svm/package-info.java | 22 +
.../src/main/resources/datasets/titanic.txt | 1309 ------------------
.../spark/IgniteDataFrameWriteExample.scala | 4 +-
.../spark/examples/IgniteDataFrameSelfTest.java | 3 +-
.../examples/SharedRDDExampleSelfTest.java | 3 +-
.../IgniteExamplesSparkSelfTestSuite.java | 2 +-
.../client/impl/ClientCacheFlagsCodecTest.java | 35 +-
.../jdbc2/JdbcNoCacheStreamingSelfTest.java | 182 +++
.../internal/jdbc2/JdbcStreamingSelfTest.java | 220 ++-
.../jdbc/suite/IgniteJdbcDriverTestSuite.java | 13 +-
...JdbcThinConnectionMultipleAddressesTest.java | 424 ++++++
.../jdbc/thin/JdbcThinConnectionSelfTest.java | 20 +-
.../jdbc/thin/JdbcThinErrorsSelfTest.java | 2 +-
.../jdbc/thin/JdbcThinStreamingSelfTest.java | 486 +++++++
.../ignite/jdbc/thin/JdbcThinTcpIoTest.java | 8 +-
.../thin/JdbcThinWalModeChangeSelfTest.java | 2 +-
.../IgniteUuidCompatibilityTest.java | 189 +++
.../junits/IgniteCompatibilityNodeRunner.java | 1 +
.../IgniteCompatibilityBasicTestSuite.java | 3 +
modules/core/pom.xml | 7 +
.../org/apache/ignite/IgniteJdbcThinDriver.java | 91 +-
.../apache/ignite/IgniteSystemProperties.java | 18 +-
.../org/apache/ignite/cache/CacheMetrics.java | 5 +
.../configuration/DataStorageConfiguration.java | 8 +-
.../internal/binary/BinaryClassDescriptor.java | 382 ++---
.../ignite/internal/binary/BinaryContext.java | 1 +
.../internal/binary/BinaryFieldAccessor.java | 61 +-
.../internal/client/GridClientCacheFlag.java | 48 +
.../impl/connection/GridClientConnection.java | 18 +-
.../connection/GridClientNioTcpConnection.java | 6 +-
.../ignite/internal/igfs/common/IgfsLogger.java | 8 +-
.../jdbc/thin/ConnectionProperties.java | 29 +-
.../jdbc/thin/ConnectionPropertiesImpl.java | 224 ++-
.../internal/jdbc/thin/JdbcThinConnection.java | 186 ++-
.../jdbc/thin/JdbcThinPreparedStatement.java | 22 +-
.../internal/jdbc/thin/JdbcThinResultSet.java | 14 +-
.../internal/jdbc/thin/JdbcThinSSLUtil.java | 10 +-
.../internal/jdbc/thin/JdbcThinStatement.java | 178 ++-
.../internal/jdbc/thin/JdbcThinTcpIo.java | 102 +-
.../ignite/internal/jdbc2/JdbcConnection.java | 10 +-
.../jdbc2/JdbcStreamedPreparedStatement.java | 2 +-
.../managers/communication/GridIoManager.java | 18 +-
.../communication/GridIoMessageFactory.java | 6 +
.../deployment/GridDeploymentLocalStore.java | 27 +-
.../optimized/OptimizedObjectInputStream.java | 103 +-
.../optimized/OptimizedObjectOutputStream.java | 94 +-
.../internal/pagemem/PageIdAllocator.java | 4 +-
.../pagemem/impl/PageMemoryNoStoreImpl.java | 2 +-
.../cache/CacheClusterMetricsMXBeanImpl.java | 5 +
.../processors/cache/CacheGroupContext.java | 13 +
.../cache/CacheLocalMetricsMXBeanImpl.java | 5 +
.../processors/cache/CacheMetricsImpl.java | 16 +
.../processors/cache/CacheMetricsSnapshot.java | 9 +
.../cache/DynamicCacheDescriptor.java | 17 +-
.../processors/cache/GridCacheIoManager.java | 6 -
.../processors/cache/GridCacheMvccManager.java | 7 +-
.../GridCachePartitionExchangeManager.java | 11 +-
.../processors/cache/GridCachePreloader.java | 16 +-
.../cache/GridCachePreloaderAdapter.java | 12 +-
.../processors/cache/GridCacheProcessor.java | 139 +-
.../cache/GridDeferredAckMessageSender.java | 10 +-
.../cache/IgniteCacheOffheapManager.java | 14 +-
.../cache/IgniteCacheOffheapManagerImpl.java | 110 +-
.../processors/cache/IgniteCacheProxyImpl.java | 4 +-
.../cache/IgniteRebalanceIterator.java | 23 +-
.../processors/cache/StoredCacheData.java | 9 +-
.../dht/GridClientPartitionTopology.java | 15 +-
.../distributed/dht/GridDhtLocalPartition.java | 483 +++++--
.../dht/GridDhtPartitionTopologyImpl.java | 190 +--
.../dht/GridDhtPartitionsEvictor.java | 140 ++
.../dht/GridDhtPartitionsReservation.java | 6 +-
.../CachePartitionFullCountersMap.java | 22 +
.../CachePartitionPartialCountersMap.java | 44 +-
.../GridDhtPartitionDemandLegacyMessage.java | 435 ++++++
.../GridDhtPartitionDemandMessage.java | 201 ++-
.../dht/preloader/GridDhtPartitionDemander.java | 445 +++---
.../preloader/GridDhtPartitionExchangeId.java | 3 +
.../dht/preloader/GridDhtPartitionSupplier.java | 548 +++-----
.../GridDhtPartitionSupplyMessage.java | 22 +-
.../GridDhtPartitionsExchangeFuture.java | 3 +-
.../dht/preloader/GridDhtPreloader.java | 198 +--
.../IgniteDhtDemandedPartitionsMap.java | 218 +++
.../IgniteDhtPartitionCountersMap.java | 6 +
.../IgniteDhtPartitionHistorySuppliersMap.java | 6 +
.../IgniteDhtPartitionsToReloadMap.java | 6 +
.../dht/preloader/IgniteHistoricalIterator.java | 39 +
.../preloader/IgniteRebalanceIteratorImpl.java | 201 +++
.../GridCacheDatabaseSharedManager.java | 61 +-
.../persistence/GridCacheOffheapManager.java | 186 ++-
.../persistence/metastorage/MetaStorage.java | 57 +-
.../pagemem/CheckpointMetricsTracker.java | 2 +-
.../persistence/pagemem/EvictCandidate.java | 77 --
.../persistence/pagemem/FullPageIdTable.java | 358 +++--
.../persistence/pagemem/LoadedPagesMap.java | 137 ++
.../cache/persistence/pagemem/PageMemoryEx.java | 8 +-
.../persistence/pagemem/PageMemoryImpl.java | 347 ++---
.../pagemem/PagesWriteSpeedBasedThrottle.java | 16 +-
.../persistence/pagemem/PagesWriteThrottle.java | 42 +-
.../persistence/pagemem/ReplaceCandidate.java | 78 ++
.../pagemem/RobinHoodBackwardShiftHashMap.java | 657 +++++++++
.../CacheContinuousQueryEventBuffer.java | 5 +-
.../cache/store/GridCacheWriteBehindStore.java | 11 +-
.../cache/transactions/IgniteTxManager.java | 3 +-
.../continuous/GridContinuousBatchAdapter.java | 5 +-
.../odbc/jdbc/JdbcBatchExecuteRequest.java | 40 +-
.../odbc/jdbc/JdbcConnectionContext.java | 13 +-
.../odbc/jdbc/JdbcRequestHandler.java | 84 +-
.../platform/cache/PlatformCache.java | 1 +
.../processors/query/GridQueryIndexing.java | 32 +-
.../processors/query/GridQueryProcessor.java | 50 +-
.../processors/query/SqlClientContext.java | 223 +++
.../handlers/cache/GridCacheCommandHandler.java | 96 +-
.../processors/task/GridTaskWorker.java | 4 +-
.../apache/ignite/internal/sql/SqlKeyword.java | 29 +-
.../apache/ignite/internal/sql/SqlParser.java | 26 +-
.../ignite/internal/sql/SqlParserUtils.java | 22 +
.../sql/command/SqlSetStreamingCommand.java | 191 +++
.../ignite/internal/util/HostAndPortRange.java | 15 +-
.../ignite/internal/util/lang/GridFunc.java | 18 -
.../ConcurrentDequeFactoryCallable.java | 40 -
.../util/nio/GridSelectorNioSessionImpl.java | 5 +-
.../internal/visor/query/VisorQueryUtils.java | 9 +
.../jobstealing/JobStealingCollisionSpi.java | 4 +-
.../communication/tcp/TcpCommunicationSpi.java | 4 +-
.../apache/ignite/util/deque/FastSizeDeque.java | 372 +++++
.../resources/META-INF/classnames.properties | 39 +-
.../binary/BinaryObjectExceptionSelfTest.java | 41 +
.../internal/binary/BinaryTreeSelfTest.java | 273 +++-
.../OptimizedObjectStreamSelfTest.java | 94 +-
.../DataStorageConfigurationValidationTest.java | 46 +
...ridCacheReplicatedSynchronousCommitTest.java | 4 +-
...IgniteClientCacheInitializationFailTest.java | 15 +-
.../IgniteClientDataStructuresAbstractTest.java | 40 +-
.../IgniteCachePartitionLossPolicySelfTest.java | 31 +-
...achePartitionPartialCountersMapSelfTest.java | 57 +
.../GridCacheRebalancingSyncSelfTest.java | 3 +-
...idCacheRebalancingWithAsyncClearingTest.java | 240 ++++
.../IgnitePdsCacheRebalancingAbstractTest.java | 77 +-
.../IgnitePdsCorruptedStoreTest.java | 154 +++
.../checkpoint/IgniteMassLoadSandboxTest.java | 2 +-
.../file/IgnitePdsDiskErrorsRecoveringTest.java | 15 -
.../wal/IgniteWalHistoryReservationsTest.java | 21 -
.../db/wal/WalRecoveryTxLogicalRecordsTest.java | 103 +-
.../metastorage/IgniteMetaStorageBasicTest.java | 147 ++
.../pagemem/BPlusTreePageMemoryImplTest.java | 2 +-
.../BPlusTreeReuseListPageMemoryImplTest.java | 3 +-
.../pagemem/FullPageIdTableTest.java | 195 ++-
...gnitePageMemReplaceDelayedWriteUnitTest.java | 5 +-
.../pagemem/IgniteThrottlingUnitTest.java | 1 -
.../pagemem/IndexStoragePageMemoryImplTest.java | 3 +-
.../pagemem/PageMemoryImplNoLoadTest.java | 3 +-
.../persistence/pagemem/PageMemoryImplTest.java | 211 ++-
.../RobinHoodBackwardShiftHashMapTest.java | 442 ++++++
.../cache/GridCacheCommandHandlerSelfTest.java | 9 +-
.../sql/SqlParserSetStreamingSelfTest.java | 134 ++
.../util/future/GridCompoundFutureSelfTest.java | 8 +-
.../future/GridFutureListenPerformanceTest.java | 4 +-
.../util/future/GridFutureQueueTest.java | 5 +-
.../lang/GridFutureListenPerformanceTest.java | 4 +-
.../GridCircularBufferPerformanceTest.java | 5 +-
.../lang/utils/GridCircularBufferSelfTest.java | 9 +-
.../platform/PlatformCacheWriteMetricsTask.java | 5 +
.../tcp/GridTcpCommunicationSpiLanTest.java | 13 +-
...cpCommunicationSpiMultithreadedSelfTest.java | 30 +-
.../ignite/testframework/GridTestUtils.java | 2 +-
.../junits/common/GridCommonAbstractTest.java | 38 +
.../ignite/testsuites/IgniteCacheTestSuite.java | 2 +
.../testsuites/IgniteCacheTestSuite2.java | 3 +
.../testsuites/IgniteCacheTestSuite3.java | 2 +
.../ignite/testsuites/IgnitePdsTestSuite.java | 4 +
.../ignite/testsuites/IgnitePdsTestSuite2.java | 3 +
.../testsuites/IgnitePdsUnitTestSuite.java | 7 +-
.../external/HadoopExternalTaskExecutor.java | 4 +-
.../HadoopExternalCommunication.java | 4 +-
.../query/h2/DmlStatementsProcessor.java | 104 +-
.../internal/processors/query/h2/H2Utils.java | 28 +-
.../processors/query/h2/IgniteH2Indexing.java | 134 +-
.../query/h2/ddl/DdlStatementsProcessor.java | 10 +-
.../processors/query/h2/dml/UpdatePlan.java | 2 +-
.../query/h2/dml/UpdatePlanBuilder.java | 13 +-
.../query/h2/sql/GridSqlQueryParser.java | 12 +
.../query/h2/sql/GridSqlQuerySplitter.java | 3 +-
.../cache/GridCacheCrossCacheQuerySelfTest.java | 18 +-
...GridCacheLazyQueryPartitionsReleaseTest.java | 9 +-
...lientQueryReplicatedNodeRestartSelfTest.java | 1 +
.../client/IgniteDataStreamerTest.java | 118 ++
.../query/SqlPushDownFunctionTest.java | 78 ++
.../IgniteCacheQuerySelfTestSuite.java | 4 +
.../IgniteCacheWithIndexingTestSuite.java | 3 +
.../apache/ignite/ml/structures/Dataset.java | 10 +
.../ignite/ml/structures/LabeledDataset.java | 16 +-
.../svm/SVMLinearBinaryClassificationModel.java | 4 +-
.../SVMLinearBinaryClassificationTrainer.java | 87 +-
.../SVMLinearMultiClassClassificationModel.java | 89 --
...VMLinearMultiClassClassificationTrainer.java | 160 ---
.../ignite/ml/svm/SVMPartitionContext.java | 28 +
.../ml/svm/SVMPartitionDataBuilderOnHeap.java | 86 ++
.../org/apache/ignite/ml/LocalModelsTest.java | 28 -
.../impl/cache/CacheBasedDatasetTest.java | 2 -
.../org/apache/ignite/ml/svm/BaseSVMTest.java | 58 -
.../ignite/ml/svm/SVMBinaryTrainerTest.java | 74 +
.../org/apache/ignite/ml/svm/SVMModelTest.java | 15 -
.../org/apache/ignite/ml/svm/SVMTestSuite.java | 13 +-
...inearSVMBinaryClassificationTrainerTest.java | 35 -
...inearSVMBinaryClassificationTrainerTest.java | 141 --
...inearSVMBinaryClassificationTrainerTest.java | 38 -
...rSVMMultiClassClassificationTrainerTest.java | 35 -
...rSVMMultiClassClassificationTrainerTest.java | 76 -
...rSVMMultiClassClassificationTrainerTest.java | 38 -
.../include/ignite/common/platform_utils.h | 7 +
.../os/linux/src/common/platform_utils.cpp | 15 +
.../common/os/win/src/common/platform_utils.cpp | 5 +
modules/platforms/cpp/odbc-test/Makefile.am | 8 +-
.../cpp/odbc-test/include/odbc_test_suite.h | 29 +
.../cpp/odbc-test/project/vs/odbc-test.vcxproj | 6 +
.../project/vs/odbc-test.vcxproj.filters | 20 +-
.../cpp/odbc-test/src/api_robustness_test.cpp | 25 -
.../cpp/odbc-test/src/attributes_test.cpp | 165 +--
.../cpp/odbc-test/src/configuration_test.cpp | 223 ++-
.../cpp/odbc-test/src/odbc_test_suite.cpp | 25 +
.../cpp/odbc-test/src/queries_test.cpp | 40 -
.../cpp/odbc-test/src/sql_get_info_test.cpp | 3 +-
modules/platforms/cpp/odbc/Makefile.am | 2 +
.../include/ignite/odbc/config/config_tools.h | 92 ++
.../include/ignite/odbc/config/configuration.h | 527 ++++---
.../odbc/config/connection_string_parser.h | 188 +++
.../include/ignite/odbc/config/settable_value.h | 101 ++
.../cpp/odbc/include/ignite/odbc/connection.h | 61 +-
.../odbc/diagnostic/diagnosable_adapter.h | 26 +-
.../odbc/diagnostic/diagnostic_record_storage.h | 13 +-
.../cpp/odbc/include/ignite/odbc/end_point.h | 72 +
.../cpp/odbc/include/ignite/odbc/ssl/ssl_mode.h | 13 +-
.../cpp/odbc/include/ignite/odbc/utility.h | 3 +-
.../src/system/ui/dsn_configuration_window.cpp | 127 +-
.../cpp/odbc/os/win/src/system_dsn.cpp | 24 +-
.../platforms/cpp/odbc/project/vs/odbc.vcxproj | 6 +
.../cpp/odbc/project/vs/odbc.vcxproj.filters | 18 +
.../cpp/odbc/src/config/config_tools.cpp | 250 ++++
.../cpp/odbc/src/config/configuration.cpp | 507 ++++---
.../src/config/connection_string_parser.cpp | 452 ++++++
modules/platforms/cpp/odbc/src/connection.cpp | 150 +-
.../diagnostic/diagnostic_record_storage.cpp | 5 +
modules/platforms/cpp/odbc/src/dsn_config.cpp | 183 ++-
modules/platforms/cpp/odbc/src/environment.cpp | 7 +-
modules/platforms/cpp/odbc/src/odbc.cpp | 12 +-
modules/platforms/cpp/odbc/src/ssl/ssl_mode.cpp | 18 +-
.../Query/CacheQueriesCodeConfigurationTest.cs | 2 +-
.../Cache/Query/CacheQueriesTest.cs | 6 +-
.../Cache/Query/Linq/CacheLinqTest.Base.cs | 4 +
.../Cache/Query/Linq/CacheLinqTest.Custom.cs | 195 +++
.../Cache/Query/Linq/CacheLinqTest.Functions.cs | 48 +
.../Cache/Query/Linq/CacheLinqTest.Misc.cs | 4 +-
.../Cache/Query/Linq/CacheLinqTest.Numerics.cs | 4 +-
.../Client/Cache/CacheTestNoMeta.cs | 2 +-
.../IgniteStartStopTest.cs | 1 -
.../Cache/Configuration/CacheConfiguration.cs | 2 +
.../Apache.Ignite.Core/Cache/ICacheMetrics.cs | 9 +
.../Apache.Ignite.Core/Compute/IComputeTask.cs | 2 +
.../Impl/Binary/BinaryTypeId.cs | 4 +-
.../Impl/Cache/CacheMetricsImpl.cs | 7 +
.../Query/Continuous/ContinuousQueryFilter.cs | 2 +
.../Impl/Common/DelegateTypeDescriptor.cs | 1 +
.../Impl/Common/IgniteArgumentCheck.cs | 1 +
.../Impl/Handle/HandleRegistry.cs | 1 +
.../Impl/Unmanaged/Jni/Jvm.cs | 1 +
.../Apache.Ignite.Core/Ssl/SslContextFactory.cs | 8 +-
.../Apache.Ignite.Linq.csproj | 4 +
.../Apache.Ignite.Linq/CacheLinqExtensions.cs | 28 +
.../Apache.Ignite.Linq/IUpdateDescriptor.cs | 51 +
.../Apache.Ignite.Linq/Impl/AliasDictionary.cs | 8 +-
.../Impl/CacheFieldsQueryProvider.cs | 23 +-
.../Impl/CacheQueryExpressionVisitor.cs | 43 +-
.../Impl/CacheQueryModelVisitor.cs | 147 +-
.../Apache.Ignite.Linq/Impl/CacheQueryParser.cs | 3 +
.../Impl/Dml/MemberUpdateContainer.cs | 38 +
.../Impl/Dml/UpdateAllExpressionNode.cs | 138 ++
.../Impl/Dml/UpdateAllResultOperator.cs | 75 +
.../Apache.Ignite.Linq/Impl/ExpressionWalker.cs | 1 +
modules/platforms/dotnet/DEVNOTES.txt | 4 +-
modules/platforms/dotnet/build-mono.sh | 5 +
modules/platforms/dotnet/build.ps1 | 6 +-
modules/platforms/dotnet/build.sh | 5 +
.../Datagrid/QueryExample.cs | 2 +-
.../Apache.Ignite.Examples/Sql/LinqExample.cs | 5 +-
.../Apache.Ignite.Examples/Sql/SqlExample.cs | 5 +-
.../http/jetty/GridJettyRestHandler.java | 4 +-
modules/spark-2.10/pom.xml | 119 --
modules/spark/pom.xml | 152 +-
.../org/apache/ignite/spark/IgniteRDDSpec.scala | 4 -
.../e2e/testcafe/fixtures/admin-panel.js | 4 +-
.../components/cluster-selector/controller.js | 4 +-
.../app/components/page-queries/controller.js | 3 +-
.../components/page-queries/template.tpl.pug | 2 +-
.../app/directives/on-focus-out.directive.js | 8 +-
.../states/configuration/caches/query.pug | 2 +-
modules/web-console/frontend/package.json | 19 +-
.../stylesheets/_bootstrap-variables.scss | 2 +-
.../frontend/public/stylesheets/style.scss | 4 +-
.../web-console/frontend/test/ci/.dockerignore | 4 +
modules/web-console/frontend/test/ci/Dockerfile | 36 +
.../frontend/test/ci/docker-compose.yml | 25 +
.../frontend/test/karma.conf.babel.js | 12 +-
.../frontend/test/protractor.conf.js | 50 -
.../ignite-localhost-persistence-config.xml | 71 +
.../benchmark-jdbc-thin-inmemory.properties | 108 ++
.../benchmark-jdbc-thin-persistence.properties | 113 ++
.../yardstick/IgniteBenchmarkArguments.java | 9 +-
.../yardstick/jdbc/AbstractJdbcBenchmark.java | 23 +-
.../upload/AbstractNativeBenchmark.java | 114 ++
.../upload/AbstractUploadBenchmark.java | 187 +++
.../upload/BatchedInsertBenchmark.java | 65 +
.../ignite/yardstick/upload/CopyBenchmark.java | 125 ++
.../yardstick/upload/InsertBenchmark.java | 52 +
.../yardstick/upload/NativePutBenchmark.java | 39 +
.../upload/NativeStreamerBenchmark.java | 66 +
.../upload/UploadBenchmarkArguments.java | 158 +++
.../yardstick/upload/model/QueryFactory.java | 181 +++
.../ignite/yardstick/upload/model/Values10.java | 76 +
.../org/yardstickframework/package-info.java | 25 +
.../probes/TotalTimeProbe.java | 137 ++
parent/pom.xml | 2 +-
329 files changed, 16177 insertions(+), 6616 deletions(-)
----------------------------------------------------------------------