Package org.apache.ignite.examples.computegrid

Class ComputeContinuousMapperExample

  • public class ComputeContinuousMapperExample
extends java.lang.Object
    Demonstrates usage of continuous mapper. With continuous mapper it is possible to continue mapping jobs asynchronously even after initial ComputeTask.map(List, Object) method completes.

    String "Hello Continuous Mapper" is passed as an argument for execution of ComputeContinuousMapperExample.ContinuousMapperTask. As an outcome, participating nodes will print out a single word from the passed in string and return number of characters in that word. However, to demonstrate continuous mapping, next word will be mapped to a node only after the result from previous word has been received.

    Remote nodes should always be started with special configuration file which enables P2P class loading: 'ignite.{sh|bat} examples/config/example-ignite.xml'.

    Alternatively you can run ExampleNodeStartup in another JVM which will start node with examples/config/example-ignite.xml configuration.

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static void main​(java.lang.String[] args)
      Executes example.

      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

    • Constructor Detail

      • ComputeContinuousMapperExample

        public ComputeContinuousMapperExample()

    • Method Detail

      • main

        public static void main​(java.lang.String[] args)
                 throws IgniteException
        Executes example.
        Parameters:
        args - Command line arguments, none required.
        Throws:
        IgniteException - If example execution failed.