Merge remote-tracking branch 'origin/ignite-45' into ignite-45
Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/4b84c2fe Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/4b84c2fe Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/4b84c2fe Branch: refs/heads/ignite-45 Commit: 4b84c2fe07a5135b8b7a67a5ea00c3eb2c6a9e1c Parents: 38fdc24 94ea692 Author: Alexey Goncharuk <agoncha...@gridgain.com> Authored: Sat Mar 21 21:59:00 2015 -0700 Committer: Alexey Goncharuk <agoncha...@gridgain.com> Committed: Sat Mar 21 21:59:00 2015 -0700 ---------------------------------------------------------------------- examples/config/example-cache.xml | 110 +---- examples/rest/http-rest-example.php | 9 +- examples/rest/memcache-rest-example.php | 4 +- .../ignite/examples/ExampleNodeStartup.java | 35 ++ .../apache/ignite/examples/ExamplesUtils.java | 132 ++++++ .../computegrid/ComputeBroadcastExample.java | 114 ++++++ .../computegrid/ComputeCallableExample.java | 79 ++++ .../computegrid/ComputeClosureExample.java | 77 ++++ .../ComputeClusterGroupsExample.java | 93 +++++ .../ComputeContinuousMapperExample.java | 158 +++++++ .../ComputeExecutorServiceExample.java | 71 ++++ .../ComputeFibonacciContinuationExample.java | 194 +++++++++ .../computegrid/ComputeReducerExample.java | 89 ++++ .../computegrid/ComputeRunnableExample.java | 74 ++++ .../computegrid/ComputeScheduleExample.java | 81 ++++ .../computegrid/ComputeTaskMapExample.java | 113 +++++ .../computegrid/ComputeTaskSplitExample.java | 102 +++++ .../failover/ComputeFailoverExample.java | 137 +++++++ .../failover/ComputeFailoverNodeStartup.java | 77 ++++ .../computegrid/failover/package-info.java | 22 + .../examples/computegrid/montecarlo/Credit.java | 110 +++++ .../montecarlo/CreditRiskExample.java | 153 +++++++ .../montecarlo/CreditRiskManager.java | 143 +++++++ .../computegrid/montecarlo/package-info.java | 22 + .../examples/computegrid/package-info.java | 22 + .../examples/datagrid/CacheAffinityExample.java | 138 +++++++ .../examples/datagrid/CacheApiExample.java | 128 ++++++ .../datagrid/CacheContinuousQueryExample.java | 107 +++++ .../datagrid/CacheDataStreamerExample.java | 91 +++++ .../examples/datagrid/CacheEventsExample.java | 99 +++++ .../datagrid/CachePopularNumbersExample.java | 172 ++++++++ .../examples/datagrid/CachePutGetExample.java | 113 +++++ .../examples/datagrid/CacheQueryExample.java | 407 +++++++++++++++++++ .../datagrid/CacheTransactionExample.java | 148 +++++++ .../hibernate/HibernateL2CacheExample.java | 204 ++++++++++ .../HibernateL2CacheExampleNodeStartup.java | 97 +++++ .../examples/datagrid/hibernate/Post.java | 126 ++++++ .../examples/datagrid/hibernate/User.java | 151 +++++++ .../datagrid/hibernate/package-info.java | 22 + .../ignite/examples/datagrid/package-info.java | 22 + .../starschema/CacheStarSchemaExample.java | 244 +++++++++++ .../datagrid/starschema/DimProduct.java | 101 +++++ .../examples/datagrid/starschema/DimStore.java | 101 +++++ .../datagrid/starschema/FactPurchase.java | 103 +++++ .../datagrid/starschema/package-info.java | 22 + .../store/CacheNodeWithStoreStartup.java | 155 +++++++ .../datagrid/store/CacheStoreExample.java | 107 +++++ .../store/CacheStoreLoadDataExample.java | 67 +++ .../store/dummy/CacheDummyPersonStore.java | 120 ++++++ .../datagrid/store/dummy/package-info.java | 22 + .../hibernate/CacheHibernatePersonStore.java | 291 +++++++++++++ .../datagrid/store/hibernate/Person.hbm.xml | 34 ++ .../datagrid/store/hibernate/hibernate.cfg.xml | 41 ++ .../datagrid/store/hibernate/package-info.java | 22 + .../store/jdbc/CacheJdbcPersonStore.java | 275 +++++++++++++ .../store/jdbc/CacheJdbcPojoPersonStore.java | 82 ++++ .../datagrid/store/jdbc/package-info.java | 22 + .../examples/datagrid/store/model/Person.java | 155 +++++++ .../examples/datagrid/store/package-info.java | 22 + .../datastructures/IgniteAtomicLongExample.java | 74 ++++ .../IgniteAtomicReferenceExample.java | 110 +++++ .../IgniteAtomicSequenceExample.java | 91 +++++ .../IgniteAtomicStampedExample.java | 117 ++++++ .../IgniteCountDownLatchExample.java | 95 +++++ .../datastructures/IgniteQueueExample.java | 215 ++++++++++ .../datastructures/IgniteSetExample.java | 197 +++++++++ .../examples/datastructures/package-info.java | 22 + .../ignite/examples/events/EventsExample.java | 144 +++++++ .../ignite/examples/events/package-info.java | 22 + .../ignite/examples/igfs/IgfsExample.java | 278 +++++++++++++ .../examples/igfs/IgfsMapReduceExample.java | 249 ++++++++++++ .../ignite/examples/igfs/IgfsNodeStartup.java | 41 ++ .../ignite/examples/igfs/package-info.java | 22 + .../examples/java7/ExampleNodeStartup.java | 35 -- .../ignite/examples/java7/ExamplesUtils.java | 135 ------ .../computegrid/ComputeBroadcastExample.java | 114 ------ .../computegrid/ComputeCallableExample.java | 79 ---- .../computegrid/ComputeClosureExample.java | 77 ---- .../ComputeClusterGroupsExample.java | 93 ----- .../ComputeContinuousMapperExample.java | 158 ------- .../ComputeExecutorServiceExample.java | 71 ---- .../ComputeFibonacciContinuationExample.java | 194 --------- .../computegrid/ComputeReducerExample.java | 89 ---- .../computegrid/ComputeRunnableExample.java | 74 ---- .../computegrid/ComputeScheduleExample.java | 81 ---- .../computegrid/ComputeTaskMapExample.java | 113 ----- .../computegrid/ComputeTaskSplitExample.java | 102 ----- .../failover/ComputeFailoverExample.java | 137 ------- .../failover/ComputeFailoverNodeStartup.java | 77 ---- .../computegrid/failover/package-info.java | 22 - .../java7/computegrid/montecarlo/Credit.java | 110 ----- .../montecarlo/CreditRiskExample.java | 153 ------- .../montecarlo/CreditRiskManager.java | 143 ------- .../computegrid/montecarlo/package-info.java | 22 - .../java7/computegrid/package-info.java | 22 - .../java7/datagrid/CacheAffinityExample.java | 138 ------- .../java7/datagrid/CacheApiExample.java | 128 ------ .../datagrid/CacheContinuousQueryExample.java | 107 ----- .../datagrid/CacheDataStreamerExample.java | 91 ----- .../java7/datagrid/CacheEventsExample.java | 99 ----- .../datagrid/CachePopularNumbersExample.java | 172 -------- .../java7/datagrid/CachePutGetExample.java | 113 ----- .../java7/datagrid/CacheQueryExample.java | 407 ------------------- .../java7/datagrid/CacheTransactionExample.java | 148 ------- .../hibernate/HibernateL2CacheExample.java | 204 ---------- .../HibernateL2CacheExampleNodeStartup.java | 97 ----- .../examples/java7/datagrid/hibernate/Post.java | 126 ------ .../examples/java7/datagrid/hibernate/User.java | 151 ------- .../java7/datagrid/hibernate/package-info.java | 22 - .../examples/java7/datagrid/package-info.java | 22 - .../starschema/CacheStarSchemaExample.java | 244 ----------- .../java7/datagrid/starschema/DimProduct.java | 101 ----- .../java7/datagrid/starschema/DimStore.java | 101 ----- .../java7/datagrid/starschema/FactPurchase.java | 103 ----- .../java7/datagrid/starschema/package-info.java | 22 - .../store/CacheNodeWithStoreStartup.java | 155 ------- .../java7/datagrid/store/CacheStoreExample.java | 107 ----- .../store/CacheStoreLoadDataExample.java | 67 --- .../store/dummy/CacheDummyPersonStore.java | 120 ------ .../datagrid/store/dummy/package-info.java | 22 - .../hibernate/CacheHibernatePersonStore.java | 291 ------------- .../datagrid/store/hibernate/Person.hbm.xml | 34 -- .../datagrid/store/hibernate/hibernate.cfg.xml | 41 -- .../datagrid/store/hibernate/package-info.java | 22 - .../store/jdbc/CacheJdbcPersonStore.java | 275 ------------- .../store/jdbc/CacheJdbcPojoPersonStore.java | 82 ---- .../java7/datagrid/store/jdbc/package-info.java | 22 - .../java7/datagrid/store/model/Person.java | 155 ------- .../java7/datagrid/store/package-info.java | 22 - .../datastructures/IgniteAtomicLongExample.java | 74 ---- .../IgniteAtomicReferenceExample.java | 110 ----- .../IgniteAtomicSequenceExample.java | 91 ----- .../IgniteAtomicStampedExample.java | 117 ------ .../IgniteCountDownLatchExample.java | 95 ----- .../datastructures/IgniteQueueExample.java | 215 ---------- .../java7/datastructures/IgniteSetExample.java | 197 --------- .../java7/datastructures/package-info.java | 22 - .../examples/java7/events/EventsExample.java | 144 ------- .../examples/java7/events/package-info.java | 22 - .../ignite/examples/java7/igfs/IgfsExample.java | 278 ------------- .../java7/igfs/IgfsMapReduceExample.java | 249 ------------ .../examples/java7/igfs/IgfsNodeStartup.java | 41 -- .../examples/java7/igfs/package-info.java | 22 - .../java7/messaging/MessagingExample.java | 173 -------- .../messaging/MessagingPingPongExample.java | 133 ------ .../MessagingPingPongListenActorExample.java | 106 ----- .../examples/java7/messaging/package-info.java | 22 - .../client/memcache/MemcacheRestExample.java | 125 ------ .../MemcacheRestExampleNodeStartup.java | 92 ----- .../misc/client/memcache/package-info.java | 22 - .../java7/misc/client/package-info.java | 22 - .../misc/deployment/DeploymentExample.java | 129 ------ .../java7/misc/deployment/package-info.java | 22 - .../java7/misc/lifecycle/LifecycleExample.java | 92 ----- .../java7/misc/lifecycle/package-info.java | 22 - .../examples/java7/misc/package-info.java | 22 - .../misc/springbean/SpringBeanExample.java | 88 ---- .../java7/misc/springbean/package-info.java | 22 - .../java7/misc/springbean/spring-bean.xml | 70 ---- .../ignite/examples/java7/package-info.java | 22 - .../java7/servicegrid/ServicesExample.java | 167 -------- .../java7/servicegrid/SimpleMapService.java | 49 --- .../java7/servicegrid/SimpleMapServiceImpl.java | 71 ---- .../java7/streaming/marketdata/CacheConfig.java | 44 -- .../java7/streaming/marketdata/Instrument.java | 106 ----- .../java7/streaming/marketdata/MarketTick.java | 59 --- .../marketdata/QueryTopInstruments.java | 73 ---- .../streaming/marketdata/StreamMarketData.java | 109 ----- .../java7/streaming/numbers/CacheConfig.java | 46 --- .../streaming/numbers/QueryPopularNumbers.java | 74 ---- .../streaming/numbers/StreamRandomNumbers.java | 79 ---- .../examples/messaging/MessagingExample.java | 173 ++++++++ .../messaging/MessagingPingPongExample.java | 133 ++++++ .../MessagingPingPongListenActorExample.java | 106 +++++ .../ignite/examples/messaging/package-info.java | 22 + .../client/memcache/MemcacheRestExample.java | 125 ++++++ .../MemcacheRestExampleNodeStartup.java | 92 +++++ .../misc/client/memcache/package-info.java | 22 + .../examples/misc/client/package-info.java | 22 + .../misc/deployment/DeploymentExample.java | 129 ++++++ .../examples/misc/deployment/package-info.java | 22 + .../misc/lifecycle/LifecycleExample.java | 92 +++++ .../examples/misc/lifecycle/package-info.java | 22 + .../ignite/examples/misc/package-info.java | 22 + .../misc/springbean/SpringBeanExample.java | 88 ++++ .../examples/misc/springbean/package-info.java | 22 + .../examples/misc/springbean/spring-bean.xml | 70 ++++ .../apache/ignite/examples/package-info.java | 22 + .../examples/servicegrid/ServicesExample.java | 167 ++++++++ .../examples/servicegrid/SimpleMapService.java | 49 +++ .../servicegrid/SimpleMapServiceImpl.java | 71 ++++ .../streaming/marketdata/CacheConfig.java | 44 ++ .../streaming/marketdata/Instrument.java | 106 +++++ .../streaming/marketdata/MarketTick.java | 59 +++ .../marketdata/QueryTopInstruments.java | 73 ++++ .../streaming/marketdata/StreamMarketData.java | 109 +++++ .../examples/streaming/numbers/CacheConfig.java | 46 +++ .../streaming/numbers/QueryPopularNumbers.java | 74 ++++ .../streaming/numbers/StreamRandomNumbers.java | 78 ++++ .../ignite/examples/java8/ComputeExample.java | 56 --- .../examples/java8/ExampleNodeStartup.java | 35 -- .../ignite/examples/java8/ExamplesUtils.java | 132 ------ .../ignite/examples/java8/MessagingExample.java | 162 -------- .../computegrid/ComputeBroadcastExample.java | 2 +- .../computegrid/ComputeCallableExample.java | 2 +- .../computegrid/ComputeClosureExample.java | 2 +- .../ComputeClusterGroupsExample.java | 2 +- .../ComputeContinuousMapperExample.java | 2 +- .../ComputeExecutorServiceExample.java | 5 +- .../ComputeFibonacciContinuationExample.java | 2 +- .../computegrid/ComputeReducerExample.java | 2 +- .../computegrid/ComputeRunnableExample.java | 2 +- .../computegrid/ComputeScheduleExample.java | 2 +- .../computegrid/ComputeTaskMapExample.java | 2 +- .../computegrid/ComputeTaskSplitExample.java | 2 +- .../failover/ComputeFailoverExample.java | 2 +- .../montecarlo/CreditRiskExample.java | 2 +- .../java8/datagrid/CacheAffinityExample.java | 131 ++++++ .../java8/datagrid/CacheApiExample.java | 123 ++++++ .../java8/messaging/MessagingExample.java | 163 ++++++++ .../marketdata/QueryTopInstruments.java | 2 +- .../streaming/marketdata/StreamMarketData.java | 8 +- .../streaming/numbers/QueryPopularNumbers.java | 2 +- .../streaming/numbers/StreamRandomNumbers.java | 4 +- .../ignite/examples/BasicExamplesSelfTest.java | 2 +- .../ignite/examples/CacheExamplesSelfTest.java | 8 +- ...heStoreLoadDataExampleMultiNodeSelfTest.java | 2 +- .../examples/CheckpointExamplesSelfTest.java | 2 +- .../ComputeClusterGroupsExampleSelfTest.java | 2 +- .../examples/ContinuationExamplesSelfTest.java | 2 +- .../ContinuousMapperExamplesSelfTest.java | 2 +- .../examples/DeploymentExamplesSelfTest.java | 2 +- .../ignite/examples/EventsExamplesSelfTest.java | 2 +- ...ibernateL2CacheExampleMultiNodeSelfTest.java | 2 +- .../HibernateL2CacheExampleSelfTest.java | 2 +- .../ignite/examples/IgfsExamplesSelfTest.java | 2 +- .../examples/LifecycleExamplesSelfTest.java | 2 +- .../MemcacheRestExamplesMultiNodeSelfTest.java | 2 +- .../examples/MemcacheRestExamplesSelfTest.java | 2 +- .../examples/MessagingExamplesSelfTest.java | 2 +- .../examples/MonteCarloExamplesSelfTest.java | 2 +- .../examples/SpringBeanExamplesSelfTest.java | 2 +- .../ignite/examples/TaskExamplesSelfTest.java | 2 +- .../apache/ignite/stream/StreamTransformer.java | 26 +- .../org/apache/ignite/stream/StreamVisitor.java | 3 +- 245 files changed, 10330 insertions(+), 10411 deletions(-) ----------------------------------------------------------------------
