Merge remote-tracking branch 'origin/sprint-2' into sprint-2
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/16a4265e Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/16a4265e Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/16a4265e Branch: refs/heads/ignite-443 Commit: 16a4265ea6cd95d7319b0c995653f259fd42e21d Parents: 385f868 4477cdb Author: sboikov <sboi...@gridgain.com> Authored: Fri Mar 20 13:27:44 2015 +0300 Committer: sboikov <sboi...@gridgain.com> Committed: Fri Mar 20 13:27:44 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 - .../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 -- .../ignite/internal/util/IgniteUtils.java | 23 - .../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 --- .../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 | 2 - .../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 - .../index/GridStreamerIndexSelfTest.java | 686 ------- .../window/GridStreamerWindowSelfTest.java | 911 --------- .../ignite/testframework/junits/IgniteMock.java | 10 - .../ignite/testsuites/IgniteBasicTestSuite.java | 3 - .../testsuites/IgniteStreamerSelfTestSuite.java | 46 - .../org/apache/ignite/IgniteSpringBean.java | 14 - pom.xml | 4 +- 164 files changed, 13 insertions(+), 26124 deletions(-) ----------------------------------------------------------------------
