Package org.apache.ignite.examples.datagrid

Class CacheDataStreamerExample

  • public class CacheDataStreamerExample
extends java.lang.Object
    Demonstrates how cache can be populated with data utilizing IgniteDataStreamer API. IgniteDataStreamer is a lot more efficient to use than standard put(...) operation as it properly buffers cache requests together and properly manages load on remote nodes.

    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.

    • Field Summary

      Fields 
      Modifier and Type Field Description
      static int MIN_MEMORY
      Heap size required to run this example.

    • 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

    • Field Detail

      • MIN_MEMORY

        public static final int MIN_MEMORY
        Heap size required to run this example.
        See Also:
        Constant Field Values

    • Constructor Detail

      • CacheDataStreamerExample

        public CacheDataStreamerExample()

    • 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.