You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@ignite.apache.org by sb...@apache.org on 2018/11/29 12:16:23 UTC
[27/50] [abbrv] ignite git commit: Merge remote-tracking branch
'remotes/origin/master' into ignite-10044
Merge remote-tracking branch 'remotes/origin/master' into ignite-10044
Project: http://git-wip-us.apache.org/repos/asf/ignite/repo
Commit: http://git-wip-us.apache.org/repos/asf/ignite/commit/5f94fca8
Tree: http://git-wip-us.apache.org/repos/asf/ignite/tree/5f94fca8
Diff: http://git-wip-us.apache.org/repos/asf/ignite/diff/5f94fca8
Branch: refs/heads/ignite-10044
Commit: 5f94fca8ddc3671677871f83b59d89dda8a4dd10
Parents: ca660d3 41f4225
Author: sboikov <sb...@apache.org>
Authored: Tue Nov 27 16:39:10 2018 +0300
Committer: sboikov <sb...@apache.org>
Committed: Tue Nov 27 16:39:10 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 -
...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 | 47 +
.../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 +
.../internal/commandline/CommandHandler.java | 50 +-
.../internal/managers/discovery/DiscoCache.java | 15 -
.../discovery/GridDiscoveryManager.java | 21 +-
.../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/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 | 31 +
.../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 -
.../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 +
...ndezvousAffinityFunctionSimpleBenchmark.java | 26 +-
.../cache/store/CacheStoreWriteErrorTest.java | 127 +
.../GridMultithreadedJobStealingSelfTest.java | 6 +-
.../BinaryArrayIdentityResolverSelfTest.java | 4 +-
.../binary/BinaryFieldsOffheapSelfTest.java | 4 +-
.../BinaryFooterOffsetsOffheapSelfTest.java | 4 +-
.../BinarySerialiedFieldComparatorSelfTest.java | 4 +-
.../cache/CacheConcurrentReadThroughTest.java | 8 +
.../cache/CacheEnumOperationsAbstractTest.java | 18 +-
.../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 +-
...ntNodeBinaryObjectMetadataMultinodeTest.java | 4 +-
.../GridCacheSetAbstractSelfTest.java | 31 +-
...idCachePartitionedSetWithClientSelfTest.java | 52 +
...chePartitionedSetWithNodeFilterSelfTest.java | 37 +
...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 +-
.../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 +-
.../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 -
.../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 +
.../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 | 2 +
.../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 | 124 +
.../encoding/EncoderTrainerTest.java | 27 +
.../StandardScalerPreprocessorTest.java | 59 +
.../StandardScalerTrainerTest.java | 85 +
.../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 | 8 +-
pom.xml | 1 +
395 files changed, 17764 insertions(+), 4849 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/5f94fca8/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/CacheAffinitySharedManager.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/5f94fca8/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/preloader/GridDhtPartitionsExchangeFuture.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/5f94fca8/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridClientPartitionTopology.java
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/ignite/blob/5f94fca8/modules/core/src/main/java/org/apache/ignite/internal/processors/cache/distributed/dht/topology/GridDhtPartitionTopologyImpl.java
----------------------------------------------------------------------