Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/ignite into 
ignite-7485-2


Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/234488ed
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/234488ed
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/234488ed

Branch: refs/heads/ignite-7485-2
Commit: 234488ede466fa1f19fcd7577386bace6d529867
Parents: 138ff50 2f330a1
Author: Alexey Kuznetsov <akuznet...@apache.org>
Authored: Fri Feb 9 20:01:55 2018 +0700
Committer: Alexey Kuznetsov <akuznet...@apache.org>
Committed: Fri Feb 9 20:01:55 2018 +0700

----------------------------------------------------------------------
 bin/control.bat                                 |    4 +-
 bin/ignite.bat                                  |    4 +-
 bin/ignitevisorcmd.bat                          |    4 +-
 bin/include/functions.sh                        |    2 +-
 config/ignite-log4j2.xml                        |    2 +-
 .../cluster/ClusterGroupExample.java            |   99 --
 .../computegrid/cluster/package-info.java       |   22 -
 .../examples/ml/MLExamplesCommonArgs.java       |   31 +
 .../AlgorithmSpecificDatasetExample.java        |  197 +++
 .../ml/dataset/CacheBasedDatasetExample.java    |   90 ++
 .../ml/dataset/LocalDatasetExample.java         |   84 ++
 .../examples/ml/dataset/model/Person.java       |   58 +
 .../examples/ml/dataset/model/package-info.java |   22 +
 .../examples/ml/dataset/package-info.java       |   22 +
 .../KNNClassificationExample.java               |   17 +-
 .../ignite/examples/ml/knn/datasets/README.md   |    2 -
 .../ml/knn/datasets/cleared_machines.txt        |  209 ---
 .../ignite/examples/ml/knn/datasets/iris.txt    |  150 --
 .../ml/knn/regression/KNNRegressionExample.java |   18 +-
 .../ml/preprocessing/NormalizationExample.java  |  109 ++
 .../examples/ml/preprocessing/package-info.java |   22 +
 ...tedLinearRegressionExampleWithQRTrainer.java |  136 --
 ...edLinearRegressionExampleWithSGDTrainer.java |  137 --
 ...dLinearRegressionWithLSQRTrainerExample.java |  170 +++
 ...tedLinearRegressionWithQRTrainerExample.java |  136 ++
 ...edLinearRegressionWithSGDTrainerExample.java |  137 ++
 .../ml/svm/SVMBinaryClassificationExample.java  |  134 ++
 .../examples/ml/trees/DecisionTreesExample.java |  354 +++++
 .../ignite/examples/ml/trees/MNISTExample.java  |  261 ----
 .../ignite/examples/sql/SqlJdbcCopyExample.java |  107 ++
 examples/src/main/resources/cityBulkLoad.csv    |    3 +
 examples/src/main/resources/datasets/README.md  |    2 +
 .../resources/datasets/cleared_machines.txt     |  209 +++
 examples/src/main/resources/datasets/iris.txt   |  150 ++
 .../src/main/resources/datasets/titanic.txt     | 1309 ++++++++++++++++++
 examples/src/main/resources/person.json         |   10 +
 examples/src/main/resources/personBulkLoad.csv  |    4 +
 .../examples/ScalarSnowflakeSchemaExample.scala |    4 +-
 .../spark/IgniteDataFrameWriteExample.scala     |  179 +++
 .../testsuites/IgniteExamplesMLTestSuite.java   |    5 +-
 .../spark/examples/IgniteDataFrameSelfTest.java |    9 +
 .../jmh/notify/JmhWaitStategyBenchmark.java     |    7 +-
 .../store/cassandra/CassandraCacheStore.java    |    3 +-
 .../cassandra/common/PropertyMappingHelper.java |    7 +-
 .../cassandra/session/CassandraSessionImpl.java |    3 +-
 .../ignite/tests/load/PersonGenerator.java      |    2 +-
 .../org/apache/ignite/tests/pojos/Person.java   |   12 +-
 .../apache/ignite/tests/pojos/SimplePerson.java |    8 +-
 .../apache/ignite/tests/utils/TestsHelper.java  |    4 +-
 .../internal/jdbc2/JdbcBulkLoadSelfTest.java    |  185 +++
 .../ignite/jdbc/JdbcErrorsAbstractSelfTest.java |    2 +-
 .../jdbc/suite/IgniteJdbcDriverTestSuite.java   |   16 +
 .../thin/JdbcThinBulkLoadAbstractSelfTest.java  |  601 ++++++++
 ...inBulkLoadAtomicPartitionedNearSelfTest.java |   39 +
 ...bcThinBulkLoadAtomicPartitionedSelfTest.java |   39 +
 ...dbcThinBulkLoadAtomicReplicatedSelfTest.java |   39 +
 ...oadTransactionalPartitionedNearSelfTest.java |   39 +
 ...ulkLoadTransactionalPartitionedSelfTest.java |   39 +
 ...BulkLoadTransactionalReplicatedSelfTest.java |   39 +
 .../jdbc/thin/JdbcThinConnectionSSLTest.java    |  479 +++++++
 .../jdbc/thin/JdbcThinConnectionSelfTest.java   |   36 +-
 .../JdbcThinDynamicIndexAbstractSelfTest.java   |    1 -
 .../jdbc/thin/JdbcThinErrorsSelfTest.java       |    2 +-
 .../clients/src/test/resources/bulkload0.csv    |    0
 .../clients/src/test/resources/bulkload1.csv    |    1 +
 .../clients/src/test/resources/bulkload2.csv    |    2 +
 .../src/test/resources/bulkload2_utf.csv        |    2 +
 .../apache/ignite/IgniteSystemProperties.java   |   18 +
 .../cache/eviction/AbstractEvictionPolicy.java  |    4 +-
 .../igfs/IgfsPerBlockLruEvictionPolicy.java     |    4 +-
 .../eviction/sorted/SortedEvictionPolicy.java   |    4 +-
 .../cache/query/AbstractContinuousQuery.java    |  202 +++
 .../cache/query/BulkLoadContextCursor.java      |   97 ++
 .../ignite/cache/query/ContinuousQuery.java     |  172 +--
 .../query/ContinuousQueryWithTransformer.java   |  192 +++
 .../cache/store/jdbc/CacheJdbcBlobStore.java    |    6 +-
 .../configuration/CacheConfiguration.java       |   28 +
 .../ClientConnectorConfiguration.java           |  116 ++
 .../configuration/DataRegionConfiguration.java  |    2 +-
 .../ignite/internal/GridKernalContextImpl.java  |   31 +-
 .../apache/ignite/internal/IgniteKernal.java    |   23 +-
 .../ignite/internal/LongJVMPauseDetector.java   |  167 +++
 .../internal/events/DiscoveryCustomEvent.java   |   34 +
 .../jdbc/thin/ConnectionProperties.java         |  206 +++
 .../jdbc/thin/ConnectionPropertiesImpl.java     |  232 +++-
 .../internal/jdbc/thin/JdbcThinConnection.java  |    5 +
 .../internal/jdbc/thin/JdbcThinSSLUtil.java     |  332 +++++
 .../internal/jdbc/thin/JdbcThinStatement.java   |   68 +-
 .../internal/jdbc/thin/JdbcThinTcpIo.java       |   43 +-
 .../ignite/internal/jdbc2/JdbcQueryTask.java    |   12 +-
 .../managers/communication/GridIoManager.java   |    4 +-
 .../internal/pagemem/PageIdAllocator.java       |    3 +-
 .../bulkload/BulkLoadAckClientParameters.java   |   92 ++
 .../bulkload/BulkLoadCacheWriter.java           |   31 +
 .../processors/bulkload/BulkLoadCsvFormat.java  |  159 +++
 .../processors/bulkload/BulkLoadCsvParser.java  |   65 +
 .../processors/bulkload/BulkLoadFormat.java     |   33 +
 .../processors/bulkload/BulkLoadParser.java     |   61 +
 .../processors/bulkload/BulkLoadProcessor.java  |  104 ++
 .../bulkload/BulkLoadStreamerWriter.java        |   65 +
 .../bulkload/pipeline/CharsetDecoderBlock.java  |  132 ++
 .../pipeline/CsvLineProcessorBlock.java         |   70 +
 .../bulkload/pipeline/LineSplitterBlock.java    |   72 +
 .../bulkload/pipeline/PipelineBlock.java        |   66 +
 .../bulkload/pipeline/StrListAppenderBlock.java |   52 +
 .../cache/CacheAffinitySharedManager.java       |   86 +-
 .../processors/cache/CacheGroupContext.java     |   48 +-
 .../processors/cache/ClusterCachesInfo.java     |    1 +
 .../cache/DynamicCacheDescriptor.java           |    2 +-
 .../processors/cache/GridCacheAdapter.java      |    6 +-
 .../processors/cache/GridCacheEventManager.java |    3 +-
 .../GridCachePartitionExchangeManager.java      |    2 +-
 .../processors/cache/GridCacheTtlManager.java   |    4 +-
 .../processors/cache/IgniteCacheProxyImpl.java  |   82 +-
 .../dht/GridClientPartitionTopology.java        |    9 +-
 .../distributed/dht/GridDhtLocalPartition.java  |    5 +-
 .../dht/GridDhtPartitionTopology.java           |   10 +-
 .../dht/GridDhtPartitionTopologyImpl.java       |   47 +-
 .../GridDhtPartitionsExchangeFuture.java        |  173 ++-
 .../CheckpointWriteProgressSupplier.java        |   45 +
 .../persistence/DataRegionMetricsImpl.java      |    8 +-
 .../GridCacheDatabaseSharedManager.java         |  191 ++-
 .../pagemem/DelayedDirtyPageWrite.java          |  105 ++
 .../pagemem/DelayedPageReplacementTracker.java  |  198 +++
 .../pagemem/IntervalBasedMeasurement.java       |  304 ++++
 .../persistence/pagemem/PageMemoryImpl.java     |  234 +++-
 .../pagemem/PagesWriteSpeedBasedThrottle.java   |  527 +++++++
 .../persistence/pagemem/PagesWriteThrottle.java |   45 +-
 .../pagemem/PagesWriteThrottlePolicy.java       |   39 +
 .../persistence/pagemem/ReplacedPageWriter.java |   35 +
 .../wal/FileWriteAheadLogManager.java           |  225 ++-
 .../persistence/wal/SegmentArchivedMonitor.java |   64 +
 .../wal/SegmentReservationStorage.java          |   61 +
 .../cache/query/GridCacheQueryManager.java      |   18 +-
 .../query/GridCacheQueryMetricsAdapter.java     |   10 +-
 .../continuous/CacheContinuousQueryEntry.java   |    9 +-
 .../continuous/CacheContinuousQueryHandler.java |  153 +-
 .../CacheContinuousQueryHandlerV2.java          |    9 +-
 .../CacheContinuousQueryHandlerV3.java          |  185 +++
 .../continuous/CacheContinuousQueryManager.java |   48 +-
 .../verify/VerifyBackupPartitionsTask.java      |  157 ++-
 .../cluster/DiscoveryDataClusterState.java      |   48 +-
 .../cluster/GridClusterStateProcessor.java      |   33 +-
 .../datastreamer/DataStreamerImpl.java          |   47 +-
 .../processors/igfs/IgfsLocalMetrics.java       |   30 +-
 .../processors/job/GridJobProcessor.java        |   12 +-
 .../jobmetrics/GridJobMetricsProcessor.java     |    4 +-
 .../odbc/ClientListenerBufferedParser.java      |    6 +-
 .../odbc/ClientListenerNioListener.java         |    8 +
 .../odbc/ClientListenerNioServerBuffer.java     |   12 +-
 .../odbc/ClientListenerProcessor.java           |   71 +-
 .../odbc/jdbc/JdbcBulkLoadAckResult.java        |  111 ++
 .../odbc/jdbc/JdbcBulkLoadBatchRequest.java     |  183 +++
 .../odbc/jdbc/JdbcBulkLoadProcessor.java        |  144 ++
 .../processors/odbc/jdbc/JdbcRequest.java       |    7 +
 .../odbc/jdbc/JdbcRequestHandler.java           |   90 +-
 .../processors/odbc/jdbc/JdbcResult.java        |    8 +
 .../processors/query/GridQueryProcessor.java    |   10 +-
 .../processors/rest/GridRestProcessor.java      |    6 +-
 .../processors/service/GridServiceProxy.java    |    6 +-
 .../processors/task/GridTaskProcessor.java      |    4 +-
 .../apache/ignite/internal/sql/SqlKeyword.java  |   15 +
 .../apache/ignite/internal/sql/SqlParser.java   |   18 +-
 .../sql/command/SqlBulkLoadCommand.java         |  273 ++++
 .../ignite/internal/util/IgniteUtils.java       |   28 +
 .../ignite/internal/util/lang/GridFunc.java     |    8 +-
 .../util/offheap/unsafe/GridUnsafeMap.java      |    8 +-
 .../unsafe/GridUnsafePartitionedMap.java        |    4 +-
 .../apache/ignite/logger/java/JavaLogger.java   |    2 +-
 .../org/apache/ignite/mxbean/IgniteMXBean.java  |   25 +
 .../tcp/TcpCommunicationMetricsListener.java    |   36 +-
 .../ignite/spi/discovery/tcp/ClientImpl.java    |   21 +-
 .../ignite/spi/discovery/tcp/ServerImpl.java    |    4 +-
 .../spi/discovery/tcp/TcpDiscoveryImpl.java     |    7 +-
 .../spi/discovery/tcp/TcpDiscoverySpi.java      |   36 +-
 .../java/org/jsr166/ConcurrentHashMap8.java     |   18 +-
 .../java/org/jsr166/ConcurrentLinkedDeque8.java |    3 +-
 .../org/jsr166/ConcurrentLinkedHashMap.java     |    5 +-
 .../src/main/java/org/jsr166/LongAdder8.java    |  211 ---
 .../src/main/java/org/jsr166/Striped64_8.java   |  350 -----
 .../java/org/jsr166/ThreadLocalRandom8.java     |  207 ---
 ...CacheJdbcBlobStoreMultithreadedSelfTest.java |    6 +-
 .../internal/TestDelayingCommunicationSpi.java  |    4 +-
 .../cache/GridCacheAbstractFullApiSelfTest.java |   11 +-
 .../IgniteClusterActivateDeactivateTest.java    |  222 ++-
 .../cache/IgniteDynamicCacheStartSelfTest.java  |    8 +
 ...naryObjectsAbstractDataStreamerSelfTest.java |   14 +-
 ...aryObjectsAbstractMultiThreadedSelfTest.java |   18 +-
 .../distributed/CacheBaselineTopologyTest.java  |  271 +++-
 .../distributed/GridCacheEventAbstractTest.java |   82 +-
 .../distributed/IgniteCache150ClientsTest.java  |    4 +-
 ...ridCachePartitionedUnloadEventsSelfTest.java |   25 +-
 .../dht/IgniteCrossCacheTxSelfTest.java         |    8 +-
 ...idCacheRebalancingPartitionCountersTest.java |   32 +-
 ...ridCacheReplicatedEventDisabledSelfTest.java |   75 +
 .../GridCacheReplicatedPreloadSelfTest.java     |    7 +
 .../PageEvictionMultinodeMixedRegionsTest.java  |    5 +-
 .../SortedEvictionPolicyPerformanceTest.java    |    8 +-
 .../IgniteBaselineAbstractFullApiSelfTest.java  |    4 +-
 .../db/IgnitePdsTransactionsHangTest.java       |    4 +-
 ...gniteCheckpointDirtyPagesForLowLoadTest.java |   21 +-
 .../checkpoint/IgniteMassLoadSandboxTest.java   |  517 +++++++
 .../db/checkpoint/ProgressWatchdog.java         |  495 +++++++
 .../file/IgnitePdsThreadInterruptionTest.java   |    6 +-
 .../wal/IgniteWalHistoryReservationsTest.java   |   24 +-
 .../db/wal/reader/IgniteWalReaderTest.java      |   27 +-
 .../pagemem/BPlusTreePageMemoryImplTest.java    |   19 +-
 .../BPlusTreeReuseListPageMemoryImplTest.java   |   18 +-
 ...gnitePageMemReplaceDelayedWriteUnitTest.java |  307 ++++
 .../pagemem/IgniteThrottlingUnitTest.java       |  274 ++++
 .../pagemem/IndexStoragePageMemoryImplTest.java |   18 +-
 .../pagemem/PageMemoryImplNoLoadTest.java       |   12 +-
 .../persistence/pagemem/PageMemoryImplTest.java |   13 +-
 ...acheContinuousQueryRandomOperationsTest.java |  156 ++-
 ...ContinuousWithTransformerClientSelfTest.java |   40 +
 ...heContinuousWithTransformerFailoverTest.java |  309 +++++
 ...eContinuousWithTransformerLocalSelfTest.java |   29 +
 ...nuousWithTransformerPartitionedSelfTest.java |   29 +
 ...uousWithTransformerRandomOperationsTest.java |   31 +
 ...inuousWithTransformerReplicatedSelfTest.java |  511 +++++++
 .../TxDeadlockDetectionNoHangsTest.java         |    2 +
 .../TxPessimisticDeadlockDetectionTest.java     |    2 +
 .../transactions/TxRollbackOnTimeoutTest.java   |   10 +-
 .../datastreamer/DataStreamerImplSelfTest.java  |   22 +-
 .../IgniteDataStreamerPerformanceTest.java      |   12 +-
 .../processors/igfs/IgfsSizeSelfTest.java       |   19 +-
 .../internal/sql/SqlParserBulkLoadSelfTest.java |   70 +
 .../future/GridFutureListenPerformanceTest.java |    4 +-
 .../ipc/shmem/IpcSharedMemorySpaceSelfTest.java |    6 +-
 .../ignite/jvmtest/BlockingQueueTest.java       |    4 +-
 .../ignite/jvmtest/ConcurrentMapTest.java       |    4 +-
 .../ignite/lang/GridBasicPerformanceTest.java   |   14 +-
 .../lang/GridFutureListenPerformanceTest.java   |    4 +-
 .../GridCircularBufferPerformanceTest.java      |   10 +-
 .../utils/GridConcurrentHashMapSelfTest.java    |    4 +-
 .../colocation/GridTestCacheStore.java          |    4 +-
 .../communication/GridIoManagerBenchmark.java   |   10 +-
 .../communication/GridIoManagerBenchmark0.java  |    8 +-
 .../GridContinuousOperationsLoadTest.java       |    4 +-
 ...dBoundedConcurrentLinkedHashSetLoadTest.java |    4 +-
 .../job/GridJobExecutionLoadTestClient.java     |    4 +-
 ...GridJobExecutionLoadTestClientSemaphore.java |    4 +-
 ...JobExecutionSingleNodeSemaphoreLoadTest.java |    6 +-
 .../messaging/IgniteMessagingSendAsyncTest.java |    4 +-
 .../tcp/TcpDiscoverySpiReconnectDelayTest.java  |  446 ++++++
 .../testsuites/IgniteCacheTestSuite3.java       |    2 +
 .../ignite/testsuites/IgnitePdsTestSuite.java   |    1 -
 .../ignite/testsuites/IgnitePdsTestSuite2.java  |   27 +-
 .../testsuites/IgnitePdsUnitTestSuite.java      |   33 +
 .../testsuites/IgniteReproducingSuite.java      |    6 +-
 .../IgniteSpiDiscoverySelfTestSuite.java        |    3 +
 modules/direct-io/licenses/apache-2.0.txt       |  202 +++
 .../HadoopIgfs20FileSystemAbstractSelfTest.java |    4 +-
 .../IgniteHadoopFileSystemAbstractSelfTest.java |    4 +-
 .../taskexecutor/HadoopExecutorServiceTest.java |    6 +-
 modules/ignored-tests/pom.xml                   |    2 +-
 .../query/h2/DmlStatementsProcessor.java        |   99 ++
 .../processors/query/h2/IgniteH2Indexing.java   |   35 +-
 .../query/h2/ddl/DdlStatementsProcessor.java    |    2 +
 .../processors/query/h2/dml/UpdateMode.java     |   11 +-
 .../processors/query/h2/dml/UpdatePlan.java     |   20 +-
 .../query/h2/dml/UpdatePlanBuilder.java         |   86 ++
 .../processors/query/h2/opt/GridH2Table.java    |    4 +-
 .../query/h2/twostep/GridMapQueryExecutor.java  |    9 +-
 .../query/h2/twostep/MapQueryLazyWorker.java    |   11 +-
 .../query/h2/twostep/MapQueryResult.java        |   24 +-
 .../query/h2/twostep/MapQueryResults.java       |   18 +-
 .../cache/GridCacheQuerySimpleBenchmark.java    |    6 +-
 .../cache/IgniteCacheAbstractQuerySelfTest.java |   54 +-
 ...stributedPartitionQueryAbstractSelfTest.java |    4 +-
 ...chePartitionedQueryEvtsDisabledSelfTest.java |   30 +
 ...acheReplicatedQueryEvtsDisabledSelfTest.java |   30 +
 .../IgniteCacheReplicatedQuerySelfTest.java     |   25 +-
 ...onnectorConfigurationValidationSelfTest.java |    2 +-
 ...IgniteSqlSkipReducerOnUpdateDmlSelfTest.java |    4 +-
 .../IgniteCacheQuerySelfTestSuite.java          |   20 +-
 .../IgniteCacheQuerySelfTestSuite3.java         |   13 +
 .../apache/ignite/logger/log4j/Log4JLogger.java |  100 +-
 modules/log4j/src/test/config/log4j-debug.xml   |   50 +
 modules/log4j/src/test/config/log4j-info.xml    |   50 +
 .../logger/log4j/GridLog4jConfigUpdateTest.java |  163 +++
 .../logger/log4j/GridLog4jWatchDelayTest.java   |   49 +
 .../ignite/testsuites/IgniteLog4jTestSuite.java |   35 +-
 modules/log4j2/src/test/config/log4j2-debug.xml |   37 +
 modules/log4j2/src/test/config/log4j2-info.xml  |   37 +
 .../logger/log4j2/Log4j2ConfigUpdateTest.java   |  152 ++
 .../testsuites/IgniteLog4j2TestSuite.java       |    2 +
 modules/ml/README.txt                           |   16 +-
 modules/ml/pom.xml                              |    7 +
 .../org/apache/ignite/ml/DatasetTrainer.java    |   42 +
 .../main/java/org/apache/ignite/ml/Trainer.java |    2 +
 .../org/apache/ignite/ml/dataset/Dataset.java   |  213 +++
 .../ignite/ml/dataset/DatasetBuilder.java       |   49 +
 .../ignite/ml/dataset/DatasetFactory.java       |  387 ++++++
 .../ml/dataset/PartitionContextBuilder.java     |   58 +
 .../ignite/ml/dataset/PartitionDataBuilder.java |   63 +
 .../apache/ignite/ml/dataset/UpstreamEntry.java |   53 +
 .../dataset/impl/cache/CacheBasedDataset.java   |  168 +++
 .../impl/cache/CacheBasedDatasetBuilder.java    |   95 ++
 .../ml/dataset/impl/cache/package-info.java     |   22 +
 .../dataset/impl/cache/util/ComputeUtils.java   |  251 ++++
 .../util/DatasetAffinityFunctionWrapper.java    |   75 +
 .../impl/cache/util/PartitionDataStorage.java   |   65 +
 .../impl/cache/util/UpstreamCursorAdapter.java  |   68 +
 .../dataset/impl/cache/util/package-info.java   |   22 +
 .../ml/dataset/impl/local/LocalDataset.java     |   88 ++
 .../dataset/impl/local/LocalDatasetBuilder.java |  137 ++
 .../ml/dataset/impl/local/package-info.java     |   22 +
 .../ignite/ml/dataset/impl/package-info.java    |   22 +
 .../apache/ignite/ml/dataset/package-info.java  |   22 +
 .../ml/dataset/primitive/DatasetWrapper.java    |   63 +
 .../ml/dataset/primitive/SimpleDataset.java     |  216 +++
 .../dataset/primitive/SimpleLabeledDataset.java |   39 +
 .../builder/context/EmptyContextBuilder.java    |   39 +
 .../primitive/builder/context/package-info.java |   22 +
 .../builder/data/SimpleDatasetDataBuilder.java  |   76 +
 .../data/SimpleLabeledDatasetDataBuilder.java   |   86 ++
 .../primitive/builder/data/package-info.java    |   22 +
 .../dataset/primitive/builder/package-info.java |   22 +
 .../dataset/primitive/context/EmptyContext.java |   28 +
 .../dataset/primitive/context/package-info.java |   22 +
 .../primitive/data/SimpleDatasetData.java       |   69 +
 .../data/SimpleLabeledDatasetData.java          |   79 ++
 .../ml/dataset/primitive/data/package-info.java |   22 +
 .../ml/dataset/primitive/package-info.java      |   28 +
 .../ml/math/isolve/IterativeSolverResult.java   |   64 +
 .../LinSysPartitionDataBuilderOnHeap.java       |   85 ++
 .../math/isolve/LinSysPartitionDataOnHeap.java  |   75 +
 .../ml/math/isolve/lsqr/AbstractLSQR.java       |  333 +++++
 .../ignite/ml/math/isolve/lsqr/LSQROnHeap.java  |  102 ++
 .../math/isolve/lsqr/LSQRPartitionContext.java  |   41 +
 .../ignite/ml/math/isolve/lsqr/LSQRResult.java  |  140 ++
 .../ml/math/isolve/lsqr/package-info.java       |   22 +
 .../ignite/ml/math/isolve/package-info.java     |   22 +
 .../distributed/MLPGroupUpdateTrainer.java      |    6 +-
 .../ml/preprocessing/PreprocessingTrainer.java  |   42 +
 .../NormalizationPartitionData.java             |   58 +
 .../NormalizationPreprocessor.java              |   88 ++
 .../normalization/NormalizationTrainer.java     |   90 ++
 .../normalization/package-info.java             |   22 +
 .../ignite/ml/preprocessing/package-info.java   |   22 +
 .../linear/LinearRegressionLSQRTrainer.java     |   70 +
 .../org/apache/ignite/ml/trainers/Trainer.java  |    2 +
 .../org/apache/ignite/ml/IgniteMLTestSuite.java |    6 +-
 .../ignite/ml/dataset/DatasetTestSuite.java     |   45 +
 .../cache/CacheBasedDatasetBuilderTest.java     |  107 ++
 .../impl/cache/CacheBasedDatasetTest.java       |  353 +++++
 .../impl/cache/util/ComputeUtilsTest.java       |  309 +++++
 .../DatasetAffinityFunctionWrapperTest.java     |  110 ++
 .../cache/util/PartitionDataStorageTest.java    |   49 +
 .../impl/local/LocalDatasetBuilderTest.java     |   91 ++
 .../dataset/primitive/DatasetWrapperTest.java   |   87 ++
 .../ignite/ml/math/MathImplLocalTestSuite.java  |    4 +-
 .../ml/math/isolve/lsqr/LSQROnHeapTest.java     |  134 ++
 .../preprocessing/PreprocessingTestSuite.java   |   35 +
 .../NormalizationPreprocessorTest.java          |   54 +
 .../normalization/NormalizationTrainerTest.java |   76 +
 .../ml/regressions/RegressionsTestSuite.java    |    4 +-
 .../linear/LinearRegressionLSQRTrainerTest.java |  124 ++
 modules/platforms/cpp/common/configure.ac       |    2 +-
 .../include/ignite/common/platform_utils.h      |   17 +
 .../cpp/common/include/ignite/common/utils.h    |    7 +
 .../os/linux/src/common/platform_utils.cpp      |   15 +
 .../os/win/src/common/dynamic_load_os.cpp       |    4 +
 .../common/os/win/src/common/platform_utils.cpp |   15 +
 .../platforms/cpp/common/src/common/utils.cpp   |    9 +
 modules/platforms/cpp/configure.ac              |    2 +-
 modules/platforms/cpp/configure.acrel           |    2 +-
 modules/platforms/cpp/core-test/configure.ac    |    2 +-
 .../cpp/core-test/src/cache_query_test.cpp      |   15 +-
 modules/platforms/cpp/core/configure.ac         |    2 +-
 modules/platforms/cpp/examples/configure.ac     |    2 +-
 modules/platforms/cpp/ignite/configure.ac       |    2 +-
 modules/platforms/cpp/odbc-test/Makefile.am     |    1 +
 .../cpp/odbc-test/config/queries-default.xml    |   10 +-
 .../cpp/odbc-test/config/queries-ssl-32.xml     |   77 ++
 .../cpp/odbc-test/config/queries-ssl.xml        |   59 +
 .../cpp/odbc-test/config/queries-test-32.xml    |    3 +-
 .../odbc-test/config/queries-test-default.xml   |   39 -
 .../odbc-test/config/queries-test-noodbc-32.xml |   53 -
 .../odbc-test/config/queries-test-noodbc.xml    |   35 -
 .../cpp/odbc-test/config/queries-test.xml       |    3 +-
 .../platforms/cpp/odbc-test/config/ssl/ca.pem   |   24 +
 .../cpp/odbc-test/config/ssl/client_full.pem    |   84 ++
 .../cpp/odbc-test/config/ssl/client_unknown.pem |   50 +
 .../cpp/odbc-test/config/ssl/server.jks         |  Bin 0 -> 4256 bytes
 .../cpp/odbc-test/config/ssl/trust.jks          |  Bin 0 -> 1089 bytes
 .../cpp/odbc-test/include/odbc_test_suite.h     |    8 +-
 .../cpp/odbc-test/include/test_utils.h          |    5 +
 .../cpp/odbc-test/project/vs/odbc-test.vcxproj  |   15 +-
 .../project/vs/odbc-test.vcxproj.filters        |   14 +-
 .../cpp/odbc-test/src/api_robustness_test.cpp   |  101 +-
 .../platforms/cpp/odbc-test/src/errors_test.cpp |   90 +-
 .../cpp/odbc-test/src/meta_queries_test.cpp     |   96 +-
 .../cpp/odbc-test/src/odbc_test_suite.cpp       |   40 +-
 .../cpp/odbc-test/src/queries_ssl_test.cpp      |  283 ++++
 .../cpp/odbc-test/src/queries_test.cpp          |   14 +-
 .../odbc-test/src/sql_test_suite_fixture.cpp    |    4 +
 .../platforms/cpp/odbc-test/src/test_utils.cpp  |    9 +
 modules/platforms/cpp/odbc/Makefile.am          |    5 +-
 modules/platforms/cpp/odbc/include/Makefile.am  |    6 +-
 .../include/ignite/odbc/config/configuration.h  |  110 +-
 .../cpp/odbc/include/ignite/odbc/connection.h   |    9 +-
 .../odbc/include/ignite/odbc/socket_client.h    |  109 ++
 .../ignite/odbc/ssl/secure_socket_client.h      |  148 ++
 .../odbc/include/ignite/odbc/ssl/ssl_bindings.h |  303 ++++
 .../odbc/include/ignite/odbc/ssl/ssl_gateway.h  |  151 ++
 .../cpp/odbc/include/ignite/odbc/ssl/ssl_mode.h |   55 +
 .../include/ignite/odbc/system/socket_client.h  |  151 --
 .../ignite/odbc/system/tcp_socket_client.h      |  151 ++
 .../odbc/system/ui/dsn_configuration_window.h   |  113 +-
 .../cpp/odbc/install/ignite-odbc-amd64.wxs      |    2 +-
 .../cpp/odbc/install/ignite-odbc-x86.wxs        |    2 +-
 .../odbc/os/linux/src/system/socket_client.cpp  |  360 -----
 .../os/linux/src/system/tcp_socket_client.cpp   |  384 +++++
 .../odbc/os/win/src/system/socket_client.cpp    |  432 ------
 .../os/win/src/system/tcp_socket_client.cpp     |  462 +++++++
 .../src/system/ui/dsn_configuration_window.cpp  |  315 +++--
 .../cpp/odbc/os/win/src/system/ui/window.cpp    |    9 +-
 .../platforms/cpp/odbc/project/vs/odbc.vcxproj  |   36 +-
 .../cpp/odbc/project/vs/odbc.vcxproj.filters    |   39 +-
 .../cpp/odbc/src/config/configuration.cpp       |    8 +
 modules/platforms/cpp/odbc/src/connection.cpp   |   66 +-
 modules/platforms/cpp/odbc/src/dsn_config.cpp   |   24 +-
 modules/platforms/cpp/odbc/src/odbc.cpp         |    2 +-
 .../cpp/odbc/src/ssl/secure_socket_client.cpp   |  419 ++++++
 .../platforms/cpp/odbc/src/ssl/ssl_gateway.cpp  |  210 +++
 modules/platforms/cpp/odbc/src/ssl/ssl_mode.cpp |   43 +
 .../Properties/AssemblyInfo.cs                  |    6 +-
 .../Properties/AssemblyInfo.cs                  |    6 +-
 .../Properties/AssemblyInfo.cs                  |    6 +-
 .../Properties/AssemblyInfo.cs                  |    6 +-
 .../Properties/AssemblyInfo.cs                  |    6 +-
 .../ApiParity/CacheConfigurationParityTest.cs   |    3 +-
 .../ClientConnectorConfigurationParityTest.cs   |   11 +-
 .../Properties/AssemblyInfo.cs                  |    6 +-
 .../Services/ServiceProxyTest.cs                |    3 +-
 .../Services/ServicesAsyncWrapper.cs            |   18 +-
 .../Services/ServicesTest.cs                    |  148 +-
 .../Apache.Ignite.Core.csproj                   |    1 +
 .../dotnet/Apache.Ignite.Core/Ignition.cs       |    2 +-
 .../Impl/Services/DynamicServiceProxy.cs        |  108 ++
 .../Impl/Services/ServiceProxyInvoker.cs        |   14 +-
 .../Impl/Services/ServiceProxySerializer.cs     |   37 +-
 .../Impl/Services/Services.cs                   |   43 +-
 .../Properties/AssemblyInfo.cs                  |    6 +-
 .../Apache.Ignite.Core/Services/IServices.cs    |   26 +
 .../Properties/AssemblyInfo.cs                  |    6 +-
 .../Properties/AssemblyInfo.cs                  |    6 +-
 .../Properties/AssemblyInfo.cs                  |    6 +-
 .../Properties/AssemblyInfo.cs                  |    6 +-
 .../Properties/AssemblyInfo.cs                  |    6 +-
 .../Apache.Ignite/Properties/AssemblyInfo.cs    |    6 +-
 modules/platforms/dotnet/README.md              |    6 +-
 .../ignite/spark/IgniteDataFrameSettings.scala  |  100 ++
 .../spark/impl/IgniteRelationProvider.scala     |  175 ++-
 .../ignite/spark/impl/IgniteSQLRelation.scala   |   93 +-
 .../apache/ignite/spark/impl/QueryHelper.scala  |  186 +++
 .../apache/ignite/spark/impl/QueryUtils.scala   |  225 +++
 .../org/apache/ignite/spark/impl/package.scala  |    2 +-
 .../sql/ignite/IgniteExternalCatalog.scala      |   61 +-
 .../src/test/resources/cities_non_unique.json   |    6 +
 .../ignite/spark/AbstractDataFrameSpec.scala    |   41 +-
 .../apache/ignite/spark/IgniteCatalogSpec.scala |   10 +-
 .../ignite/spark/IgniteDataFrameSuite.scala     |    2 +
 .../spark/IgniteDataFrameWrongConfigSpec.scala  |    4 +-
 ...niteSQLDataFrameIgniteSessionWriteSpec.scala |  106 ++
 .../spark/IgniteSQLDataFrameWriteSpec.scala     |  371 +++++
 modules/storm/pom.xml                           |    4 -
 modules/web-console/backend/app/mongo.js        | 1127 +--------------
 modules/web-console/backend/app/schemas.js      | 1147 +++++++++++++++
 modules/web-console/backend/services/users.js   |    1 +
 modules/web-console/frontend/app/app.js         |    7 +-
 .../app/components/page-profile/component.js    |   24 +
 .../app/components/page-profile/controller.js   |   79 ++
 .../app/components/page-profile/index.js        |   36 +
 .../app/components/page-profile/template.pug    |   83 ++
 .../frontend/app/data/countries.json            |    4 +
 .../app/modules/states/profile.state.js         |   36 -
 .../frontend/app/services/Version.service.js    |    2 +-
 .../frontend/controllers/profile-controller.js  |   94 --
 .../frontend/views/settings/profile.tpl.pug     |   83 --
 modules/yardstick/DEVNOTES-standalone.txt       |   10 -
 modules/yardstick/DEVNOTES.txt                  |   11 -
 ...benchmark-jdbc-thin-insert-delete.properties |   87 ++
 .../benchmark-jdbc-thin-select.properties       |   86 ++
 .../benchmark-jdbc-thin-update.properties       |   86 ++
 .../benchmark-jdbcv2-insert-delete.properties   |   87 ++
 .../config/benchmark-jdbcv2-select.properties   |   86 ++
 .../config/benchmark-jdbcv2-update.properties   |   88 ++
 ...enchmark-native-sql-insert-delete.properties |   87 ++
 .../benchmark-native-sql-select.properties      |   86 ++
 .../benchmark-native-sql-update.properties      |   86 ++
 modules/yardstick/config/ignite-jdbc-config.xml |    4 +-
 .../yardstick/IgniteBenchmarkArguments.java     |   26 +-
 .../org/apache/ignite/yardstick/IgniteNode.java |   12 +-
 .../yardstick/cache/IntMaxValueEntriesTest.java |    4 +-
 .../yardstick/jdbc/AbstractJdbcBenchmark.java   |  158 +++
 .../yardstick/jdbc/AbstractNativeBenchmark.java |   37 +
 .../yardstick/jdbc/DisjointRangeGenerator.java  |  101 ++
 .../jdbc/JdbcSqlInsertDeleteBenchmark.java      |   66 +
 .../jdbc/JdbcSqlQueryRangeBenchmark.java        |   78 ++
 .../yardstick/jdbc/JdbcSqlUpdateBenchmark.java  |   81 ++
 .../apache/ignite/yardstick/jdbc/JdbcUtils.java |   55 +
 .../jdbc/NativeSqlInsertDeleteBenchmark.java    |   61 +
 .../jdbc/NativeSqlQueryRangeBenchmark.java      |   77 ++
 .../jdbc/NativeSqlUpdateRangeBenchmark.java     |   83 ++
 parent/pom.xml                                  |   15 +-
 pom.xml                                         |    4 +-
 scripts/update-versions.sh                      |   35 +
 510 files changed, 31183 insertions(+), 6432 deletions(-)
----------------------------------------------------------------------


Reply via email to