Merge branches 'ignite-gg-9933' and 'sprint-2' of https://git-wip-us.apache.org/repos/asf/incubator-ignite into ignite-gg-9933
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/eb335a9d Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/eb335a9d Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/eb335a9d Branch: refs/heads/ignite-496 Commit: eb335a9d8ba256f182fac3e9322bd7ed8779d182 Parents: f16eade 38fadda Author: S.Vladykin <svlady...@gridgain.com> Authored: Fri Mar 20 20:44:13 2015 +0300 Committer: S.Vladykin <svlady...@gridgain.com> Committed: Fri Mar 20 20:44:13 2015 +0300 ---------------------------------------------------------------------- LICENSE.txt | 26 - NOTICE.txt | 11 - .../apache/ignite/examples/ExamplesUtils.java | 18 - .../streaming/StreamingCheckInExample.java | 580 ------ .../streaming/StreamingNodeStartup.java | 35 - .../StreamingPopularNumbersExample.java | 250 --- .../streaming/StreamingPriceBarsExample.java | 451 ----- .../StreamingRunningAverageExample.java | 247 --- .../ignite/examples/streaming/package-info.java | 22 - modules/core/pom.xml | 2 +- .../src/main/java/com/romix/scala/None.java | 27 - .../src/main/java/com/romix/scala/Option.java | 42 - .../src/main/java/com/romix/scala/Some.java | 38 - .../scala/collection/concurrent/BasicNode.java | 32 - .../scala/collection/concurrent/CNodeBase.java | 49 - .../romix/scala/collection/concurrent/Gen.java | 29 - .../scala/collection/concurrent/INodeBase.java | 47 - .../scala/collection/concurrent/ListMap.java | 247 --- .../scala/collection/concurrent/MainNode.java | 51 - .../romix/scala/collection/concurrent/Pair.java | 54 - .../scala/collection/concurrent/TrieMap.java | 1826 ------------------ .../src/main/java/org/apache/ignite/Ignite.java | 17 - .../java/org/apache/ignite/IgniteStreamer.java | 154 -- .../org/apache/ignite/cluster/ClusterGroup.java | 9 - .../configuration/IgniteConfiguration.java | 23 - .../ignite/internal/GridKernalContext.java | 8 - .../ignite/internal/GridKernalContextImpl.java | 12 - .../apache/ignite/internal/IgniteKernal.java | 26 - .../org/apache/ignite/internal/IgnitionEx.java | 12 - .../internal/cluster/ClusterGroupAdapter.java | 40 - .../cluster/IgniteClusterAsyncImpl.java | 5 - .../communication/GridIoMessageFactory.java | 16 - .../GridDeploymentPerLoaderStore.java | 1 - .../GridDeploymentPerVersionStore.java | 1 - .../discovery/GridDiscoveryManager.java | 6 +- .../processors/cache/GridCacheAdapter.java | 2 +- .../processors/cache/GridCacheContext.java | 13 +- .../cache/GridCacheEvictionManager.java | 2 +- .../processors/cache/GridCacheMapEntry.java | 23 +- .../GridCachePartitionExchangeManager.java | 2 +- .../continuous/CacheContinuousQueryHandler.java | 3 + .../processors/clock/GridClockServer.java | 2 +- .../clock/GridClockSyncProcessor.java | 2 +- .../internal/processors/igfs/IgfsServer.java | 4 +- .../processors/igfs/IgfsServerManager.java | 4 +- .../streamer/GridStreamProcessor.java | 347 ---- .../streamer/GridStreamerAttributes.java | 127 -- .../streamer/GridStreamerCancelRequest.java | 110 -- .../streamer/GridStreamerContextDelegate.java | 102 - .../streamer/GridStreamerContextImpl.java | 201 -- .../streamer/GridStreamerExecutionBatch.java | 175 -- .../streamer/GridStreamerExecutionRequest.java | 293 --- .../streamer/GridStreamerResponse.java | 144 -- .../GridStreamerRouteFailedException.java | 36 - .../GridStreamerStageExecutionFuture.java | 340 ---- .../streamer/GridStreamerWindowIterator.java | 40 - .../processors/streamer/IgniteStreamerEx.java | 94 - .../processors/streamer/IgniteStreamerImpl.java | 1375 ------------- .../streamer/StreamerMBeanAdapter.java | 116 -- .../streamer/StreamerMetricsAdapter.java | 272 --- .../streamer/StreamerMetricsHolder.java | 424 ---- .../streamer/StreamerStageMBeanAdapter.java | 101 - .../streamer/StreamerStageMetricsAdapter.java | 135 -- .../streamer/StreamerStageMetricsHolder.java | 167 -- .../streamer/StreamerStageWrapper.java | 90 - .../streamer/StreamerWindowMetricsAdapter.java | 65 - .../streamer/StreamerWindowMetricsHolder.java | 50 - .../processors/streamer/package-info.java | 22 - .../task/GridStreamerBroadcastTask.java | 137 -- .../streamer/task/GridStreamerQueryTask.java | 140 -- .../streamer/task/GridStreamerReduceTask.java | 144 -- .../timeout/GridTimeoutProcessor.java | 2 +- .../ignite/internal/util/IgniteUtils.java | 23 - .../ignite/internal/util/worker/GridWorker.java | 14 +- .../visor/node/VisorGridConfiguration.java | 12 - .../visor/node/VisorNodeDataCollectorJob.java | 37 +- .../node/VisorNodeDataCollectorJobResult.java | 28 - .../visor/node/VisorNodeDataCollectorTask.java | 6 - .../node/VisorNodeDataCollectorTaskResult.java | 43 +- .../internal/visor/streamer/VisorStreamer.java | 104 - .../streamer/VisorStreamerConfiguration.java | 177 -- .../visor/streamer/VisorStreamerMetrics.java | 350 ---- .../streamer/VisorStreamerMetricsResetTask.java | 75 - .../visor/streamer/VisorStreamerResetTask.java | 75 - .../streamer/VisorStreamerStageMetrics.java | 277 --- .../optimized/OptimizedClassDescriptor.java | 268 ++- .../optimized/OptimizedObjectInputStream.java | 93 +- .../optimized/OptimizedObjectOutputStream.java | 64 +- .../ignite/streamer/StreamerConfiguration.java | 249 --- .../apache/ignite/streamer/StreamerContext.java | 142 -- .../ignite/streamer/StreamerEventRouter.java | 55 - .../streamer/StreamerEventRouterAdapter.java | 60 - .../streamer/StreamerFailureListener.java | 44 - .../apache/ignite/streamer/StreamerMBean.java | 169 -- .../apache/ignite/streamer/StreamerMetrics.java | 209 -- .../apache/ignite/streamer/StreamerStage.java | 61 - .../ignite/streamer/StreamerStageMBean.java | 114 -- .../ignite/streamer/StreamerStageMetrics.java | 93 - .../apache/ignite/streamer/StreamerWindow.java | 206 -- .../ignite/streamer/StreamerWindowMBean.java | 58 - .../ignite/streamer/StreamerWindowMetrics.java | 44 - .../ignite/streamer/index/StreamerIndex.java | 305 --- .../streamer/index/StreamerIndexEntry.java | 57 - .../streamer/index/StreamerIndexPolicy.java | 50 - .../streamer/index/StreamerIndexProvider.java | 107 - .../index/StreamerIndexProviderAdapter.java | 796 -------- .../index/StreamerIndexProviderMBean.java | 74 - .../streamer/index/StreamerIndexUpdateSync.java | 77 - .../streamer/index/StreamerIndexUpdater.java | 88 - .../index/hash/StreamerHashIndexProvider.java | 500 ----- .../streamer/index/hash/package-info.java | 21 - .../ignite/streamer/index/package-info.java | 21 - .../index/tree/StreamerTreeIndexProvider.java | 953 --------- .../streamer/index/tree/package-info.java | 21 - .../apache/ignite/streamer/package-info.java | 21 - .../router/StreamerAffinityEventRouter.java | 150 -- .../StreamerCacheAffinityEventRouter.java | 70 - .../router/StreamerLocalEventRouter.java | 46 - .../router/StreamerRandomEventRouter.java | 89 - .../router/StreamerRoundRobinEventRouter.java | 53 - .../ignite/streamer/router/package-info.java | 21 - .../window/StreamerBoundedSizeBatchWindow.java | 804 -------- .../window/StreamerBoundedSizeSortedWindow.java | 218 --- .../window/StreamerBoundedSizeWindow.java | 144 -- .../StreamerBoundedSizeWindowAdapter.java | 357 ---- .../window/StreamerBoundedTimeBatchWindow.java | 906 --------- .../window/StreamerBoundedTimeWindow.java | 462 ----- .../window/StreamerUnboundedWindow.java | 111 -- .../streamer/window/StreamerWindowAdapter.java | 537 ----- .../ignite/streamer/window/package-info.java | 21 - .../java/org/pcollections/AmortizedPQueue.java | 156 -- .../main/java/org/pcollections/ConsPStack.java | 225 --- .../src/main/java/org/pcollections/Empty.java | 47 - .../main/java/org/pcollections/HashPMap.java | 175 -- .../java/org/pcollections/HashTreePBag.java | 47 - .../java/org/pcollections/HashTreePMap.java | 52 - .../java/org/pcollections/HashTreePSet.java | 46 - .../src/main/java/org/pcollections/IntTree.java | 320 --- .../main/java/org/pcollections/IntTreePMap.java | 165 -- .../src/main/java/org/pcollections/MapPBag.java | 143 -- .../src/main/java/org/pcollections/MapPSet.java | 101 - .../main/java/org/pcollections/OrderedPSet.java | 85 - .../src/main/java/org/pcollections/PBag.java | 23 - .../main/java/org/pcollections/PCollection.java | 56 - .../src/main/java/org/pcollections/PMap.java | 49 - .../main/java/org/pcollections/POrderedSet.java | 25 - .../src/main/java/org/pcollections/PQueue.java | 38 - .../main/java/org/pcollections/PSequence.java | 73 - .../src/main/java/org/pcollections/PSet.java | 23 - .../src/main/java/org/pcollections/PStack.java | 51 - .../src/main/java/org/pcollections/PVector.java | 45 - .../org/pcollections/SimpleImmutableEntry.java | 146 -- .../main/java/org/pcollections/TreePVector.java | 155 -- .../resources/META-INF/classnames.properties | 53 +- .../IgniteCacheExpiryPolicyAbstractTest.java | 64 +- ...ridCacheContinuousQueryAbstractSelfTest.java | 29 +- .../streamer/GridStreamerEvictionSelfTest.java | 163 -- .../streamer/GridStreamerFailoverSelfTest.java | 267 --- .../GridStreamerLifecycleAwareSelfTest.java | 212 -- .../streamer/GridStreamerSelfTest.java | 796 -------- .../processors/streamer/GridTestStage.java | 52 - .../streamer/GridTestStreamerEventRouter.java | 49 - .../ignite/internal/processors/streamer/SC.java | 31 - .../GridImmutableCollectionsPerfomanceTest.java | 120 -- .../ignite/lang/utils/GridPCollectionsTest.java | 54 - .../ignite/lang/utils/GridTrieMapSelfTest.java | 242 --- .../ignite/loadtests/streamer/EventClosure.java | 60 - .../streamer/GridStreamerBenchmark.java | 140 -- .../streamer/GridStreamerIndexLoadTest.java | 179 -- .../loadtests/streamer/GridStreamerLoad.java | 62 - .../ignite/loadtests/streamer/IndexUpdater.java | 46 - .../ignite/loadtests/streamer/QueryClosure.java | 107 - .../loadtests/streamer/average/TestAverage.java | 70 - .../loadtests/streamer/average/TestStage.java | 63 - .../marshaller/GridMarshallerAbstractTest.java | 56 - ...arshallerSerialPersistentFieldsSelfTest.java | 110 ++ .../index/GridStreamerIndexSelfTest.java | 686 ------- .../window/GridStreamerWindowSelfTest.java | 911 --------- .../ignite/testframework/junits/IgniteMock.java | 10 - .../ignite/testsuites/IgniteBasicTestSuite.java | 3 - .../IgniteMarshallerSelfTestSuite.java | 1 + .../testsuites/IgniteStreamerSelfTestSuite.java | 46 - .../HadoopExternalCommunication.java | 4 +- .../org/apache/ignite/schema/ui/Controls.java | 42 +- .../ignite/schema/ui/SchemaImportApp.java | 14 +- .../org/apache/ignite/IgniteSpringBean.java | 14 - .../commands/cache/VisorCacheCommand.scala | 4 +- pom.xml | 4 +- 188 files changed, 550 insertions(+), 26410 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/eb335a9d/modules/core/src/main/java/org/apache/ignite/internal/util/IgniteUtils.java ----------------------------------------------------------------------
