Merge branch 'master' of https://git-wip-us.apache.org/repos/asf/ignite into ignite-9720
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/0063fb1d Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/0063fb1d Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/0063fb1d Branch: refs/heads/ignite-9720 Commit: 0063fb1d7addad2407598ee56bcb92a473dde9dc Parents: ceacab0 c3fd4a9 Author: Alexey Goncharuk <[email protected]> Authored: Wed Nov 28 10:31:37 2018 +0300 Committer: Alexey Goncharuk <[email protected]> Committed: Wed Nov 28 10:31:37 2018 +0300 ---------------------------------------------------------------------- ...niteFunctionDistributedInferenceExample.java | 100 + .../TensorFlowDistributedInferenceExample.java | 99 + .../TensorFlowLocalInferenceExample.java | 85 + .../TensorFlowThreadedInferenceExample.java | 95 + .../examples/ml/inference/package-info.java | 22 + .../ml/preprocessing/StandardScalerExample.java | 84 + .../examples/ml/util/MLSandboxDatasets.java | 16 +- .../ignite/examples/ml/util/SandboxMLCache.java | 11 +- .../ignite/examples/ml/util/datasets/README.md | 2 - .../ml/util/datasets/boston_housing_dataset.txt | 505 ---- .../ml/util/datasets/cleared_machines.csv | 209 -- .../ml/util/datasets/glass_identification.csv | 116 - .../ignite/examples/ml/util/datasets/iris.txt | 150 -- .../examples/ml/util/datasets/mortalitydata.csv | 53 - .../examples/ml/util/datasets/titanic.csv | 1310 --------- .../ml/util/datasets/titanic_10_rows.csv | 11 - .../ml/util/datasets/two_classed_iris.csv | 100 - .../ignite/examples/ml/util/datasets/wine.txt | 178 -- examples/src/main/resources/datasets/README.md | 2 + .../datasets/boston_housing_dataset.txt | 505 ++++ .../resources/datasets/cleared_machines.csv | 209 ++ .../resources/datasets/glass_identification.csv | 116 + examples/src/main/resources/datasets/iris.txt | 150 ++ .../main/resources/datasets/mortalitydata.csv | 53 + .../resources/datasets/t10k-images-idx3-ubyte | Bin 0 -> 9876027 bytes .../resources/datasets/t10k-labels-idx1-ubyte | Bin 0 -> 10008 bytes .../src/main/resources/datasets/titanic.csv | 1310 +++++++++ .../main/resources/datasets/titanic_10_rows.csv | 11 + .../resources/datasets/two_classed_iris.csv | 100 + examples/src/main/resources/datasets/wine.txt | 178 ++ .../resources/ml/mnist_tf_model/saved_model.pb | Bin 0 -> 37185 bytes .../variables/variables.data-00000-of-00001 | Bin 0 -> 13098544 bytes .../ml/mnist_tf_model/variables/variables.index | Bin 0 -> 410 bytes .../ignite/examples/BasicExamplesSelfTest.java | 6 + .../examples/CacheClientBinaryExampleTest.java | 3 + .../CacheContinuousQueryExamplesSelfTest.java | 4 + .../ignite/examples/CacheExamplesSelfTest.java | 4 + .../ComputeClientBinaryExampleTest.java | 2 + .../examples/EncryptedCacheExampleSelfTest.java | 3 + .../ignite/examples/EventsExamplesSelfTest.java | 2 + .../examples/MessagingExamplesSelfTest.java | 3 + .../examples/SpringDataExampleSelfTest.java | 2 + .../ignite/examples/SqlExamplesSelfTest.java | 4 + .../IgniteExamplesJ8SelfTestSuite.java | 53 +- .../testsuites/IgniteExamplesSelfTestSuite.java | 59 +- idea/ignite_inspections.xml | 2 +- .../jdbc2/JdbcDistributedJoinsQueryTest.java | 4 - .../JettyRestProcessorAbstractSelfTest.java | 90 +- ...RestProcessorAuthenticationAbstractTest.java | 6 +- ...tingToWalV2SerializerWithCompactionTest.java | 5 - .../PersistenceBasicCompatibilityTest.java | 5 - modules/compress/licenses/Snappy-LICENSE.txt | 29 + .../compress/licenses/Snappy-java-LICENSE.txt | 202 ++ modules/compress/licenses/Zstd-LICENSE.txt | 30 + modules/compress/licenses/Zstd-jni-LICENSE.txt | 26 + modules/compress/licenses/jnr-ffi-LICENSE.txt | 25 + modules/compress/licenses/jnr-posix-LICENSE.txt | 2486 ++++++++++++++++++ modules/compress/licenses/lz4-LICENSE.txt | 11 + modules/compress/licenses/lz4-java-LICENSE.txt | 202 ++ modules/compress/pom.xml | 113 + .../compress/CompressionProcessorImpl.java | 403 +++ .../compress/NativeFileSystemLinux.java | 142 + .../compress/NativeFileSystemPosix.java | 54 + .../compress/CompressionProcessorTest.java | 1021 +++++++ ...DiskPageCompressionIntegrationAsyncTest.java | 30 + .../DiskPageCompressionIntegrationTest.java | 468 ++++ .../compress/FileSystemUtilsTest.java | 193 ++ .../IgnitePdsCompressionTestSuite.java | 56 + .../IgnitePdsCompressionTestSuite2.java | 38 + .../org/apache/ignite/DataStorageMetrics.java | 18 + .../apache/ignite/IgniteSystemProperties.java | 62 +- .../cache/affinity/AffinityKeyMapped.java | 4 +- .../configuration/CacheConfiguration.java | 60 + .../configuration/DataStorageConfiguration.java | 16 +- .../configuration/DiskPageCompression.java | 38 + .../ignite/internal/GridKernalContext.java | 6 + .../ignite/internal/GridKernalContextImpl.java | 12 + .../ignite/internal/IgniteComponentType.java | 7 + .../apache/ignite/internal/IgniteKernal.java | 2 + .../ignite/internal/IgniteNodeAttributes.java | 3 - .../internal/commandline/CommandHandler.java | 50 +- .../internal/managers/discovery/DiscoCache.java | 15 - .../discovery/GridDiscoveryManager.java | 38 +- .../internal/pagemem/store/PageStore.java | 34 +- .../processors/affinity/AffinityAssignment.java | 6 - .../affinity/GridAffinityAssignment.java | 15 +- .../affinity/GridAffinityAssignmentCache.java | 22 +- .../affinity/GridAffinityProcessor.java | 2 +- .../processors/affinity/GridAffinityUtils.java | 2 +- .../affinity/HistoryAffinityAssignment.java | 19 +- .../cache/CacheAffinitySharedManager.java | 13 +- .../cache/CacheCompressionManager.java | 95 + .../cache/CacheEntryPredicateContainsValue.java | 4 + .../cache/CacheGroupMetricsMXBeanImpl.java | 23 +- .../processors/cache/ExchangeContext.java | 43 +- .../processors/cache/GridCacheAdapter.java | 20 +- .../cache/GridCacheAffinityManager.java | 5 - .../processors/cache/GridCacheContext.java | 13 + .../processors/cache/GridCacheMapEntry.java | 8 +- .../GridCachePartitionExchangeManager.java | 12 +- .../processors/cache/GridCacheProcessor.java | 3 + .../cache/IgniteCacheOffheapManager.java | 5 + .../cache/IgniteCacheOffheapManagerImpl.java | 18 + .../processors/cache/WalStateManager.java | 24 + .../CacheDataStructuresManager.java | 15 +- .../distributed/dht/GridDhtCacheEntry.java | 8 +- .../dht/GridDhtTxAbstractEnlistFuture.java | 169 +- .../distributed/dht/GridDhtTxEnlistFuture.java | 13 +- .../distributed/dht/GridDhtTxPrepareFuture.java | 23 - .../dht/atomic/GridDhtAtomicCache.java | 30 +- .../GridNearAtomicAbstractUpdateFuture.java | 43 +- .../dht/colocated/GridDhtColocatedCache.java | 6 +- .../GridDhtPartitionsExchangeFuture.java | 79 +- .../GridDhtPartitionsSingleMessage.java | 68 +- .../topology/GridClientPartitionTopology.java | 7 - .../dht/topology/GridDhtLocalPartition.java | 33 +- .../dht/topology/GridDhtPartitionTopology.java | 4 - .../topology/GridDhtPartitionTopologyImpl.java | 17 +- ...arOptimisticSerializableTxPrepareFuture.java | 35 +- .../near/GridNearOptimisticTxPrepareFuture.java | 39 +- ...ridNearOptimisticTxPrepareFutureAdapter.java | 114 - .../GridNearPessimisticTxPrepareFuture.java | 78 +- .../near/GridNearTxEnlistFuture.java | 22 +- .../cache/distributed/near/GridNearTxLocal.java | 30 +- .../near/GridNearTxPrepareRequest.java | 17 - .../near/GridNearTxPrepareResponse.java | 52 +- .../GridNearTxQueryResultsEnlistFuture.java | 21 +- .../mvcc/MvccPreviousCoordinatorQueries.java | 13 +- .../processors/cache/mvcc/MvccProcessor.java | 45 +- .../cache/mvcc/MvccProcessorImpl.java | 383 +-- .../cache/mvcc/MvccQueryTrackerImpl.java | 12 +- .../processors/cache/mvcc/MvccUtils.java | 48 +- .../persistence/DataStorageMetricsImpl.java | 22 +- .../persistence/DataStorageMetricsSnapshot.java | 18 + .../GridCacheDatabaseSharedManager.java | 91 +- .../persistence/GridCacheOffheapManager.java | 14 +- .../cache/persistence/file/AbstractFileIO.java | 2 +- .../cache/persistence/file/AsyncFileIO.java | 38 +- .../cache/persistence/file/EncryptedFileIO.java | 16 +- .../cache/persistence/file/FileIO.java | 19 + .../cache/persistence/file/FileIODecorator.java | 17 +- .../cache/persistence/file/FilePageStore.java | 72 +- .../persistence/file/FilePageStoreManager.java | 65 +- .../cache/persistence/file/FilePageStoreV2.java | 21 + .../persistence/file/RandomAccessFileIO.java | 35 + .../cache/persistence/file/UnzipFileIO.java | 15 + .../persistence/pagemem/PageMemoryImpl.java | 29 +- .../cache/persistence/tree/BPlusTree.java | 36 + .../persistence/tree/io/AbstractDataPageIO.java | 79 +- .../cache/persistence/tree/io/BPlusIO.java | 32 +- .../persistence/tree/io/CompactablePageIO.java | 43 + .../persistence/tree/io/DataPagePayload.java | 16 + .../cache/persistence/tree/io/PageIO.java | 103 +- .../wal/reader/StandaloneGridKernalContext.java | 6 + .../wal/serializer/RecordDataV1Serializer.java | 17 +- .../cache/transactions/IgniteTxAdapter.java | 46 +- .../cache/transactions/IgniteTxHandler.java | 239 +- .../cache/transactions/IgniteTxManager.java | 4 +- .../cache/tree/mvcc/data/MvccUpdateDataRow.java | 11 +- .../cluster/GridClusterStateProcessor.java | 3 +- .../compress/CompressionProcessor.java | 173 ++ .../processors/compress/FileSystemUtils.java | 129 + .../processors/compress/NativeFileSystem.java | 50 + .../datastructures/GridCacheSetImpl.java | 4 +- .../processors/query/GridQueryProcessor.java | 1 - .../service/GridServiceProcessor.java | 12 - .../apache/ignite/internal/util/GridUnsafe.java | 1 + .../ignite/internal/util/IgniteUtils.java | 213 +- .../verify/VisorValidateIndexesJobResult.java | 9 + .../verify/VisorValidateIndexesTaskArg.java | 23 +- .../ignite/mxbean/CacheGroupMetricsMXBean.java | 12 + .../ignite/mxbean/DataStorageMetricsMXBean.java | 8 + .../ignite/spi/discovery/tcp/ServerImpl.java | 41 - ...ndezvousAffinityFunctionSimpleBenchmark.java | 26 +- .../cache/store/CacheStoreWriteErrorTest.java | 127 + .../GridMultithreadedJobStealingSelfTest.java | 6 +- .../BinaryArrayIdentityResolverSelfTest.java | 4 +- .../binary/BinaryFieldsOffheapSelfTest.java | 4 +- .../BinaryFooterOffsetsOffheapSelfTest.java | 4 +- .../BinarySerialiedFieldComparatorSelfTest.java | 4 +- .../GridDiscoveryManagerAttributesSelfTest.java | 37 - .../cache/CacheConcurrentReadThroughTest.java | 8 + .../cache/CacheEnumOperationsAbstractTest.java | 18 +- .../CacheSerializableTransactionsTest.java | 32 +- .../cache/CrossCacheTxRandomOperationsTest.java | 23 +- .../cache/GridCacheAbstractMetricsSelfTest.java | 6 - .../cache/GridCacheBasicApiAbstractTest.java | 27 + .../cache/GridCacheBasicStoreAbstractTest.java | 8 + .../GridCacheEvictionEventAbstractTest.java | 9 + .../GridCacheFinishPartitionsSelfTest.java | 8 + ...idCacheGetAndTransformStoreAbstractTest.java | 8 + .../cache/GridCacheOffheapUpdateSelfTest.java | 17 +- .../cache/GridCachePartitionedGetSelfTest.java | 6 + .../GridCacheVariableTopologySelfTest.java | 9 + .../IgniteCacheEntryProcessorNodeJoinTest.java | 111 +- .../cache/IgniteCacheIncrementTxTest.java | 7 + .../cache/IgniteCacheNoSyncForGetTest.java | 8 + .../IgniteClientCacheStartFailoverTest.java | 37 + .../IgniteClusterActivateDeactivateTest.java | 2 +- ...erActivateDeactivateTestWithPersistence.java | 37 + ...ynamicCacheStartFailWithPersistenceTest.java | 1 + .../IgniteMvccTxMultiThreadedAbstractTest.java | 121 + .../IgniteMvccTxSingleThreadedAbstractTest.java | 50 + .../cache/IgniteNearClientCacheCloseTest.java | 22 + .../processors/cache/IgniteTxAbstractTest.java | 16 +- .../IgniteTxMultiThreadedAbstractTest.java | 1 - .../cache/WalModeChangeAbstractSelfTest.java | 45 +- .../GridCacheBinaryObjectsAbstractSelfTest.java | 58 + ...ntNodeBinaryObjectMetadataMultinodeTest.java | 4 +- .../GridCacheSetAbstractSelfTest.java | 31 +- ...idCachePartitionedSetWithClientSelfTest.java | 52 + ...chePartitionedSetWithNodeFilterSelfTest.java | 37 + ...IgnitePartitionedCountDownLatchSelfTest.java | 5 - ...ridCacheReplicatedSetWithClientSelfTest.java | 52 + ...acheReplicatedSetWithNodeFilterSelfTest.java | 37 + .../distributed/CacheExchangeMergeTest.java | 4 +- ...CacheLoadingConcurrentGridStartSelfTest.java | 8 + .../CacheLockReleaseNodeLeaveTest.java | 8 + .../GridCacheAbstractPrimarySyncSelfTest.java | 4 + .../GridCacheBasicOpAbstractTest.java | 8 + .../distributed/GridCacheLockAbstractTest.java | 8 + .../GridCacheMultiNodeAbstractTest.java | 5 + .../GridCacheMultiNodeLockAbstractTest.java | 9 + .../GridCacheNodeFailureAbstractTest.java | 8 + ...ridCachePartitionNotLoadedEventSelfTest.java | 17 +- ...NearDisabledMvccTxMultiThreadedSelfTest.java | 31 + ...GridCachePreloadRestartAbstractSelfTest.java | 12 + .../GridCacheTransformEventSelfTest.java | 70 +- ...niteCacheClientNodeChangingTopologyTest.java | 12 +- .../distributed/IgniteCacheGetRestartTest.java | 29 +- .../IgniteCacheTxIteratorSelfTest.java | 27 +- .../IgniteMvccTxTimeoutAbstractTest.java | 146 + .../IgniteTxTimeoutAbstractTest.java | 39 +- ...heColocatedMvccTxSingleThreadedSelfTest.java | 85 + .../dht/GridCacheDhtEntrySelfTest.java | 5 + .../dht/GridCacheDhtMappingSelfTest.java | 8 + .../GridCacheDhtPreloadDisabledSelfTest.java | 8 + ...ridCacheDhtPreloadMultiThreadedSelfTest.java | 3 + .../dht/GridCacheDhtPreloadPutGetSelfTest.java | 7 + .../dht/GridCacheDhtPreloadSelfTest.java | 2 - .../IgniteCacheClearDuringRebalanceTest.java | 9 + ...artitionedBackupNodeFailureRecoveryTest.java | 2 +- .../near/GridCacheNearClientHitTest.java | 5 +- .../near/GridCacheNearMultiGetSelfTest.java | 73 +- .../near/GridCacheNearMultiNodeSelfTest.java | 10 + .../near/GridCacheNearOneNodeSelfTest.java | 11 +- .../GridCacheNearPartitionedClearSelfTest.java | 8 + .../GridCacheNearReaderPreloadSelfTest.java | 8 + .../near/GridCacheNearReadersSelfTest.java | 10 +- ...ePartitionedBasicStoreMultiNodeSelfTest.java | 6 + .../near/GridCachePartitionedEventSelfTest.java | 8 + ...titionedExplicitLockNodeFailureSelfTest.java | 8 + .../GridCachePartitionedLoadCacheSelfTest.java | 8 + ...ePartitionedMvccTxMultiThreadedSelfTest.java | 101 + ...PartitionedMvccTxSingleThreadedSelfTest.java | 84 + ...idCachePartitionedMvccTxTimeoutSelfTest.java | 47 + ...achePartitionedPreloadLifecycleSelfTest.java | 1 - .../GridCachePartitionedTxTimeoutSelfTest.java | 21 - .../near/GridNearCacheStoreUpdateTest.java | 9 + .../near/NearCacheSyncUpdateTest.java | 17 + .../near/NoneRebalanceModeSelfTest.java | 9 + .../GridCacheReplicatedTxTimeoutSelfTest.java | 18 - .../local/GridCacheLocalBasicApiSelfTest.java | 8 + .../local/GridCacheLocalBasicStoreSelfTest.java | 8 + .../local/GridCacheLocalEventSelfTest.java | 9 + .../GridCacheLocalEvictionEventSelfTest.java | 8 + ...dCacheLocalGetAndTransformStoreSelfTest.java | 8 + .../GridCacheLocalIsolatedNodesSelfTest.java | 8 + .../local/GridCacheLocalLoadAllSelfTest.java | 8 + .../cache/local/GridCacheLocalLockSelfTest.java | 8 + .../GridCacheLocalMultithreadedSelfTest.java | 8 + .../GridCacheLocalTxMultiThreadedSelfTest.java | 9 + .../GridCacheLocalTxSingleThreadedSelfTest.java | 8 + .../local/GridCacheLocalTxTimeoutSelfTest.java | 8 + ...vccAbstractBasicCoordinatorFailoverTest.java | 184 ++ .../cache/mvcc/CacheMvccAbstractTest.java | 19 +- ...eMvccPartitionedCoordinatorFailoverTest.java | 35 + .../cache/mvcc/CacheMvccTransactionsTest.java | 28 + .../cache/mvcc/MvccUnsupportedTxModesTest.java | 316 +++ .../cache/persistence/DummyPageIO.java | 21 +- ...eBaselineAffinityTopologyActivationTest.java | 59 - .../IgniteDataStorageMetricsSelfTest.java | 17 +- ...tePdsBinaryMetadataOnClusterRestartTest.java | 4 +- .../persistence/IgnitePdsDynamicCacheTest.java | 3 +- .../IgnitePdsExchangeDuringCheckpointTest.java | 1 + .../persistence/IgnitePdsPageSizesTest.java | 8 + .../IgnitePdsPartitionsStateRecoveryTest.java | 170 ++ ...lWalModeChangeDuringRebalancingSelfTest.java | 15 + .../db/IgnitePdsCacheRestoreTest.java | 8 +- .../db/IgnitePdsDataRegionMetricsTest.java | 10 +- .../db/IgnitePdsReserveWalSegmentsTest.java | 2 - ...gniteCheckpointDirtyPagesForLowLoadTest.java | 1 - ...faultPageSizeBackwardsCompatibilityTest.java | 19 +- .../IgniteUidAsConsistentIdMigrationTest.java | 26 +- .../persistence/db/wal/WalCompactionTest.java | 26 +- .../db/wal/WalDeletionArchiveAbstractTest.java | 1 - .../db/wal/reader/IgniteWalReaderTest.java | 9 +- ...tinuousQueryAsyncFailoverMvccTxSelfTest.java | 5 + ...heContinuousQueryFailoverMvccTxSelfTest.java | 5 + ...teCacheContinuousQueryNoUnsubscribeTest.java | 5 - .../cache/transactions/TxRollbackAsyncTest.java | 6 +- .../processors/database/BPlusTreeSelfTest.java | 23 + .../database/IgniteDbAbstractTest.java | 2 - ...aStreamProcessorMvccPersistenceSelfTest.java | 28 + .../DataStreamProcessorPersistenceSelfTest.java | 28 + .../DataStreamProcessorSelfTest.java | 63 +- .../internal/util/IgniteUtilsSelfTest.java | 43 - .../loadtests/hashmap/GridCacheTestContext.java | 2 + ...mmunicationSpiConcurrentConnectSelfTest.java | 4 +- ...dTcpCommunicationSpiRecoveryAckSelfTest.java | 4 +- ...GridTcpCommunicationSpiRecoverySelfTest.java | 4 +- ...CommunicationRecoveryAckClosureSelfTest.java | 4 +- .../TcpDiscoveryPendingMessageDeliveryTest.java | 8 +- .../discovery/tcp/TcpDiscoveryRestartTest.java | 8 +- .../spi/discovery/tcp/TcpDiscoverySelfTest.java | 4 +- .../testframework/MvccFeatureChecker.java | 137 + .../testframework/junits/GridAbstractTest.java | 86 +- .../junits/common/GridAbstractExamplesTest.java | 5 +- .../junits/common/GridCommonAbstractTest.java | 4 +- .../junits/spi/GridSpiAbstractTest.java | 6 +- .../testsuites/IgniteBinaryCacheTestSuite.java | 2 + .../IgniteCacheDataStructuresSelfTestSuite.java | 8 + .../testsuites/IgniteCacheMvccTestSuite.java | 5 + .../testsuites/IgniteCacheMvccTestSuite2.java | 197 ++ .../ignite/testsuites/IgniteCacheTestSuite.java | 4 + .../testsuites/IgniteCacheTestSuite2.java | 321 +-- .../testsuites/IgniteCacheTestSuite6.java | 3 - .../ignite/testsuites/IgnitePdsTestSuite2.java | 3 + .../util/mbeans/GridMBeanDisableSelfTest.java | 4 +- modules/direct-io/pom.xml | 17 +- .../file/AlignedBuffersDirectFileIO.java | 112 +- .../file/AlignedBuffersDirectFileIOFactory.java | 16 +- .../persistence/file/IgniteNativeIoLib.java | 2 +- ...kPageCompressionIntegrationDirectIOTest.java | 31 + .../persistence/file/IgniteFileIOTest.java | 15 + .../testsuites/IgnitePdsNativeIoTestSuite2.java | 4 + .../visor/verify/ValidateIndexesClosure.java | 8 +- .../visor/verify/VisorValidateIndexesTask.java | 29 + .../IgniteBinaryObjectFieldsQuerySelfTest.java | 5 - .../cache/IgniteCacheAbstractQuerySelfTest.java | 54 +- .../IgniteCacheQueryMultiThreadedSelfTest.java | 6 +- .../IgniteCacheStarvationOnRebalanceTest.java | 5 +- .../mvcc/CacheMvccBackupsAbstractTest.java | 2 + ...ccPartitionedSqlCoordinatorFailoverTest.java | 49 +- .../mvcc/CacheMvccSqlTxQueriesAbstractTest.java | 2 - .../db/wal/IgniteWalRecoveryTest.java | 3 +- ...IgniteSqlSkipReducerOnUpdateDmlSelfTest.java | 5 - .../processors/query/SqlSchemaSelfTest.java | 25 +- .../util/GridCommandHandlerIndexingTest.java | 2 +- .../kafka/connect/IgniteSinkConnectorTest.java | 2 - modules/ml/pom.xml | 13 + .../apache/ignite/ml/inference/InfModel.java | 37 + .../ignite/ml/inference/ModelDescriptor.java | 86 + .../ignite/ml/inference/ModelSignature.java | 62 + .../inference/builder/AsyncInfModelBuilder.java | 43 + .../IgniteDistributedInfModelBuilder.java | 367 +++ .../builder/SingleInfModelBuilder.java | 34 + .../inference/builder/SyncInfModelBuilder.java | 42 + .../builder/ThreadedInfModelBuilder.java | 86 + .../ml/inference/builder/package-info.java | 22 + .../ignite/ml/inference/package-info.java | 22 + .../parser/IgniteFunctionInfModelParser.java | 76 + .../ml/inference/parser/InfModelParser.java | 38 + .../parser/TensorFlowBaseInfModelParser.java | 216 ++ .../parser/TensorFlowGraphInfModelParser.java | 40 + .../TensorFlowSavedModelInfModelParser.java | 70 + .../ml/inference/parser/package-info.java | 22 + .../reader/FileSystemInfModelReader.java | 61 + .../reader/InMemoryInfModelReader.java | 67 + .../ml/inference/reader/InfModelReader.java | 33 + .../ml/inference/reader/package-info.java | 22 + .../storage/IgniteModelDescriptorStorage.java | 57 + .../storage/LocalModelDescriptorStorage.java | 45 + .../storage/ModelDescriptorStorage.java | 48 + .../ml/inference/storage/package-info.java | 22 + .../ml/inference/util/DirectorySerializer.java | 133 + .../ignite/ml/inference/util/package-info.java | 22 + .../ignite/ml/multiclass/MultiClassModel.java | 115 + .../ignite/ml/multiclass/OneVsRestTrainer.java | 147 ++ .../encoding/EncoderSortingStrategy.java | 31 + .../preprocessing/encoding/EncoderTrainer.java | 25 +- .../standardscaling/StandardScalerData.java | 56 + .../StandardScalerPreprocessor.java | 91 + .../standardscaling/StandardScalerTrainer.java | 101 + .../standardscaling/package-info.java | 22 + .../org/apache/ignite/ml/util/MnistUtils.java | 79 +- .../org/apache/ignite/ml/IgniteMLTestSuite.java | 6 +- .../ignite/ml/inference/InferenceTestSuite.java | 38 + .../IgniteDistributedInfModelBuilderTest.java | 71 + .../builder/InfModelBuilderTestUtil.java | 53 + .../builder/SingleInfModelBuilderTest.java | 42 + .../builder/ThreadedInfModelBuilderTest.java | 44 + .../inference/util/DirectorySerializerTest.java | 126 + .../ml/multiclass/MultiClassTestSuite.java | 32 + .../ml/multiclass/OneVsRestTrainerTest.java | 126 + .../encoding/EncoderTrainerTest.java | 27 + .../StandardScalerPreprocessorTest.java | 59 + .../StandardScalerTrainerTest.java | 85 + .../include/ignite/binary/binary_object.h | 1 + .../include/ignite/binary/binary_raw_reader.h | 20 + .../include/ignite/binary/binary_raw_writer.h | 38 +- .../include/ignite/binary/binary_reader.h | 26 +- .../include/ignite/binary/binary_writer.h | 42 +- .../docs/source/pyignite.datatypes.base.rst | 7 + .../python/docs/source/pyignite.datatypes.rst | 1 + .../platforms/python/pyignite/datatypes/base.py | 24 + .../python/pyignite/datatypes/complex.py | 23 +- .../python/pyignite/datatypes/internal.py | 19 +- .../python/pyignite/datatypes/null_object.py | 3 +- .../python/pyignite/datatypes/primitive.py | 3 +- .../pyignite/datatypes/primitive_arrays.py | 3 +- .../pyignite/datatypes/primitive_objects.py | 3 +- .../python/pyignite/datatypes/standard.py | 9 +- modules/platforms/python/pyignite/utils.py | 6 +- modules/platforms/python/setup.py | 2 +- .../platforms/python/tests/test_key_value.py | 75 +- .../zk/internal/ZookeeperDiscoverySpiTest.java | 4 +- parent/pom.xml | 9 +- pom.xml | 1 + 419 files changed, 18474 insertions(+), 5165 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/ignite/blob/0063fb1d/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/persistence/GridCacheOffheapManager.java ----------------------------------------------------------------------
