Repository: incubator-ignite Updated Branches: refs/heads/ignite-45 19350779a -> 56ae536b7
# ignite-45 - fixing configs. Project: http://git-wip-us.apache.org/repos/asf/incubator-ignite/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-ignite/commit/7535b142 Tree: http://git-wip-us.apache.org/repos/asf/incubator-ignite/tree/7535b142 Diff: http://git-wip-us.apache.org/repos/asf/incubator-ignite/diff/7535b142 Branch: refs/heads/ignite-45 Commit: 7535b142800ffe5de065b58389c80341008e6be6 Parents: dea1175 Author: Dmitiry Setrakyan <dsetrak...@gridgain.com> Authored: Sat Mar 21 02:02:55 2015 -0700 Committer: Dmitiry Setrakyan <dsetrak...@gridgain.com> Committed: Sat Mar 21 02:02:55 2015 -0700 ---------------------------------------------------------------------- examples/config/example-streamer.xml | 293 ------------------------------ 1 file changed, 293 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/7535b142/examples/config/example-streamer.xml ---------------------------------------------------------------------- diff --git a/examples/config/example-streamer.xml b/examples/config/example-streamer.xml deleted file mode 100644 index 0d996a8..0000000 --- a/examples/config/example-streamer.xml +++ /dev/null @@ -1,293 +0,0 @@ -<?xml version="1.0" encoding="UTF-8"?> - -<!-- - Licensed to the Apache Software Foundation (ASF) under one or more - contributor license agreements. See the NOTICE file distributed with - this work for additional information regarding copyright ownership. - The ASF licenses this file to You under the Apache License, Version 2.0 - (the "License"); you may not use this file except in compliance with - the License. You may obtain a copy of the License at - - http://www.apache.org/licenses/LICENSE-2.0 - - Unless required by applicable law or agreed to in writing, software - distributed under the License is distributed on an "AS IS" BASIS, - WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. - See the License for the specific language governing permissions and - limitations under the License. ---> - -<!-- - Ignite Spring configuration file to startup ignite with streamers. - - When starting a standalone node, you need to execute the following command: - {IGNITE_HOME}/bin/ignite.{bat|sh} examples/config/example-streamer.xml - When starting nodes this way JAR file containing the examples code - should be placed to {IGNITE_HOME}/libs folder. You can build - ignite-examples.jar by running "mvn package" in {IGNITE_HOME}/examples folder. - After that ignite-examples.jar will be generated by Maven in - {IGNITE_HOME}/examples/target folder. - - When starting Ignite from Java IDE, pass path to this file to Ignition: - Ignition.start("examples/config/example-cache.xml"); ---> -<beans xmlns="http://www.springframework.org/schema/beans"; - xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; - xsi:schemaLocation=" - http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd";> - <!-- - Optional description. - --> - <description> - Spring file for ignite configuration with benchmark. - </description> - - <!-- - Configuration below demonstrates how to setup caches within cluster nodes. - --> - <bean id="ignite.cfg" class="org.apache.ignite.configuration.IgniteConfiguration"> - <property name="marshaller"> - <bean class="org.apache.ignite.marshaller.optimized.OptimizedMarshaller"> - <!-- Set to false to allow non-serializable objects in examples, default is true. --> - <property name="requireSerializable" value="false"/> - </bean> - </property> - - <!-- Streamer configurations. --> - <property name="streamerConfiguration"> - <!-- - Specify list of streamer configurations here. - --> - <list> - <!-- - Streamer for StreamingRunningAverageExample. - --> - <bean class="org.apache.ignite.streamer.StreamerConfiguration"> - <property name="name" value="running-average"/> - - <property name="windows"> - <!-- - Window size is 500, which means that we will be - computing running average over the last 500 events. - --> - <bean class="org.apache.ignite.streamer.window.StreamerBoundedSizeWindow"> - <property name="maximumSize" value="500"/> - </bean> - </property> - - <property name="stages"> - <list> - <bean class="org.apache.ignite.examples.java8.streaming.StreamingRunningAverageExample$StreamerStage"/> - </list> - </property> - - <property name="router"> - <!-- - Use random event router to execute streamer stages on random nodes - just for demonstration purposes. - --> - <bean class="org.apache.ignite.streamer.router.StreamerRandomEventRouter"/> - <!-- - <bean class="org.apache.ignite.streamer.router.StreamerLocalEventRouter"/> - --> - </property> - - <!-- - If at-least-once is set, then we may wish to configure maximum - amount of concurrent sessions to prevent overloading the system. - --> - <!-- - <property name="maximumConcurrentSessions" value="200"/> - <property name="atLeastOnce" value="true"/> - --> - </bean> - - <!-- - Streamer for StreamingPopularNumbersExample. - --> - <bean class="org.apache.ignite.streamer.StreamerConfiguration"> - <property name="name" value="popular-numbers"/> - - <property name="windows"> - <!-- - For this example we use a running window with upper bound of 10,000 events. - This means that streamer will find most popular numbers among last 10,000 events. - --> - <bean class="org.apache.ignite.streamer.window.StreamerBoundedSizeWindow"> - <property name="maximumSize" value="10000"/> - - <property name="indexes"> - <list> - <bean class="org.apache.ignite.streamer.index.tree.StreamerTreeIndexProvider"> - <property name="updater"> - <bean class="org.apache.ignite.examples.java8.streaming.numbers.QueryPopularNumbers$IndexUpdater"/> - </property> - </bean> - </list> - </property> - </bean> - </property> - - <property name="stages"> - <list> - <bean class="org.apache.ignite.examples.java8.streaming.numbers.QueryPopularNumbers$StreamerStage"/> - </list> - </property> - - <property name="maximumConcurrentSessions" value="200"/> - - <property name="router"> - <!-- - For this example we use affinity event router to make sure that - identical numbers are routed to the same node. This is important - because we keep counters for all numbers in the stream and if - numbers are pushed to wrong nodes, the counters will become - inaccurate. - --> - <bean class="org.apache.ignite.streamer.router.StreamerAffinityEventRouter"/> - </property> - - <!-- - If at-least-once is set, then we may wish to configure maximum - amount of concurrent sessions to prevent overloading the system. - --> - <!-- - <property name="maximumConcurrentSessions" value="200"/> - <property name="atLeastOnce" value="true"/> - --> - </bean> - - <!-- - Streamer for StreamingOpenHighLowCloseExample. - --> - <bean class="org.apache.ignite.streamer.StreamerConfiguration"> - <property name="name" value="priceBars"/> - - <property name="windows"> - <list> - <!-- - For this example we use a running batch window with upper bound of 1 second. - This means that streamer composes a batch with events within 1 second time interval. - --> - <bean class="org.apache.ignite.streamer.window.StreamerBoundedTimeBatchWindow"> - <property name="name" value="stage1"/> - <property name="batchTimeInterval" value="1000"/> - <property name="batchSize" value="2147483647"/> - <property name="maximumBatches" value="2147483647"/> - </bean> - - <!-- - For this example we use a running batch window with upper bound of 2 seconds. - This means that streamer composes a batch with events within 2 seconds time interval. - --> - <bean class="org.apache.ignite.streamer.window.StreamerBoundedTimeBatchWindow"> - <property name="name" value="stage2"/> - <property name="batchTimeInterval" value="2000"/> - <property name="batchSize" value="2147483647"/> - <property name="maximumBatches" value="2147483647"/> - </bean> - </list> - </property> - - <property name="stages"> - <list> - <bean class="org.apache.ignite.examples.java8.streaming.StreamingPriceBarsExample$FirstStage"/> - <bean class="org.apache.ignite.examples.java8.streaming.StreamingPriceBarsExample$SecondStage"/> - </list> - </property> - - <property name="router"> - <!-- - For this example we use affinity event router to make sure that - quotes for identical instruments are routed to the same node. - --> - <bean class="org.apache.ignite.streamer.router.StreamerAffinityEventRouter"/> - </property> - </bean> - - <!-- - Streamer for StreamingCheckInExample. - --> - <bean class="org.apache.ignite.streamer.StreamerConfiguration"> - <property name="name" value="check-in"/> - - <property name="windows"> - <list> - <!-- - For this example we use windows with 10 seconds time interval. - This means that only events for last 10 seconds will be present in - these windows (other events are marked for eviction). - --> - <bean class="org.apache.ignite.streamer.window.StreamerBoundedTimeWindow"> - <property name="name" value="AddToWindowStage"/> - <property name="timeInterval" value="10000"/> - - <!-- - We use a unique index to avoid repetitive check-ins in a specified period - of time. - --> - <property name="indexes"> - <list> - <bean class="org.apache.ignite.streamer.index.hash.StreamerHashIndexProvider"> - <property name="unique" value="true"/> - - <property name="updater"> - <bean class="org.apache.ignite.examples.java8.streaming.StreamingCheckInExample$CheckInEventIndexUpdater"/> - </property> - </bean> - </list> - </property> - </bean> - <bean class="org.apache.ignite.streamer.window.StreamerBoundedTimeWindow"> - <property name="name" value="DetectPlacesStage"/> - <property name="timeInterval" value="10000"/> - - <property name="indexes"> - <list> - <bean class="org.apache.ignite.streamer.index.hash.StreamerHashIndexProvider"> - <property name="unique" value="true"/> - - <property name="updater"> - <bean class="org.apache.ignite.examples.java8.streaming.StreamingCheckInExample$PlacesIndexUpdater"/> - </property> - </bean> - </list> - </property> - </bean> - </list> - </property> - - <property name="stages"> - <list> - <bean class="org.apache.ignite.examples.java8.streaming.StreamingCheckInExample$AddToWindowStage"/> - <bean class="org.apache.ignite.examples.java8.streaming.StreamingCheckInExample$DetectPlacesStage"/> - </list> - </property> - </bean> - </list> - </property> - - <!-- Explicitly configure TCP discovery SPI to provide list of initial nodes. --> - <property name="discoverySpi"> - <bean class="org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi"> - <property name="ipFinder"> - <!-- - Ignite provides several options for automatic discovery that can be used - instead os static IP based discovery. For information on all options refer - to our documentation: http://apacheignite.readme.io/docs/cluster-config - --> - <!-- Uncomment static IP finder to enable static-based discovery of initial nodes. --> - <!--<bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder">--> - <bean class="org.apache.ignite.spi.discovery.tcp.ipfinder.multicast.TcpDiscoveryMulticastIpFinder"> - <property name="addresses"> - <list> - <!-- In distributed environment, replace with actual host IP address. --> - <value>127.0.0.1:47500..47509</value> - </list> - </property> - </bean> - </property> - </bean> - </property> - </bean> -</beans>
