http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/schema-import/src/main/java/org/apache/ignite/schema/CacheConfig.java ---------------------------------------------------------------------- diff --git a/examples/schema-import/src/main/java/org/apache/ignite/schema/CacheConfig.java b/examples/schema-import/src/main/java/org/apache/ignite/schema/CacheConfig.java index 9062d24..cb316c5 100644 --- a/examples/schema-import/src/main/java/org/apache/ignite/schema/CacheConfig.java +++ b/examples/schema-import/src/main/java/org/apache/ignite/schema/CacheConfig.java @@ -17,10 +17,9 @@ package org.apache.ignite.schema; -import org.apache.ignite.cache.store.*; -import org.apache.ignite.configuration.*; - -import javax.cache.configuration.*; +import javax.cache.configuration.Factory; +import org.apache.ignite.cache.store.CacheStore; +import org.apache.ignite.configuration.CacheConfiguration; /** * CacheConfig stub. Will be generated by Ignite Schema Import Utility. @@ -35,4 +34,4 @@ public class CacheConfig { public static <K, V> CacheConfiguration<K, V> cache(String name, Factory<CacheStore<K, V>> storeFactory) { throw new IllegalStateException("Please run Ignite Schema Import Utility as described in README.txt"); } -} +} \ No newline at end of file
http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/schema-import/src/main/java/org/apache/ignite/schema/Demo.java ---------------------------------------------------------------------- diff --git a/examples/schema-import/src/main/java/org/apache/ignite/schema/Demo.java b/examples/schema-import/src/main/java/org/apache/ignite/schema/Demo.java index 9497543..cade7f1 100644 --- a/examples/schema-import/src/main/java/org/apache/ignite/schema/Demo.java +++ b/examples/schema-import/src/main/java/org/apache/ignite/schema/Demo.java @@ -17,15 +17,17 @@ package org.apache.ignite.schema; -import org.apache.ignite.*; -import org.apache.ignite.cache.store.*; -import org.apache.ignite.cache.store.jdbc.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.transactions.*; -import org.h2.jdbcx.*; - -import javax.cache.*; -import javax.cache.configuration.*; +import javax.cache.Cache; +import javax.cache.configuration.Factory; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.cache.store.CacheStore; +import org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStore; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.transactions.Transaction; +import org.h2.jdbcx.JdbcConnectionPool; /** * This demo demonstrates the use of cache with {@link CacheJdbcPojoStore} @@ -142,4 +144,4 @@ public class Demo { System.out.println(">>> Updated person: " + cache.get(key)); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/schema-import/src/main/java/org/apache/ignite/schema/DemoNode.java ---------------------------------------------------------------------- diff --git a/examples/schema-import/src/main/java/org/apache/ignite/schema/DemoNode.java b/examples/schema-import/src/main/java/org/apache/ignite/schema/DemoNode.java index 7b8f832..0f8c192 100644 --- a/examples/schema-import/src/main/java/org/apache/ignite/schema/DemoNode.java +++ b/examples/schema-import/src/main/java/org/apache/ignite/schema/DemoNode.java @@ -17,7 +17,8 @@ package org.apache.ignite.schema; -import org.apache.ignite.*; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; /** * Starts demo node. You can start as many demo nodes as you like for the demo. @@ -34,4 +35,4 @@ public class DemoNode { Ignition.start("examples/config/example-ignite.xml"); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/schema-import/src/main/java/org/apache/ignite/schema/Person.java ---------------------------------------------------------------------- diff --git a/examples/schema-import/src/main/java/org/apache/ignite/schema/Person.java b/examples/schema-import/src/main/java/org/apache/ignite/schema/Person.java index 36f287f..799c876 100644 --- a/examples/schema-import/src/main/java/org/apache/ignite/schema/Person.java +++ b/examples/schema-import/src/main/java/org/apache/ignite/schema/Person.java @@ -42,4 +42,3 @@ public class Person { throw new IllegalStateException("Please run Ignite Schema Import Utility as described in README.txt"); } } - http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/schema-import/src/main/java/org/apache/ignite/schema/PersonKey.java ---------------------------------------------------------------------- diff --git a/examples/schema-import/src/main/java/org/apache/ignite/schema/PersonKey.java b/examples/schema-import/src/main/java/org/apache/ignite/schema/PersonKey.java index 16386d3..dd241ad 100644 --- a/examples/schema-import/src/main/java/org/apache/ignite/schema/PersonKey.java +++ b/examples/schema-import/src/main/java/org/apache/ignite/schema/PersonKey.java @@ -35,4 +35,3 @@ public class PersonKey { throw new IllegalStateException("Please run Ignite Schema Import Utility as described in README.txt"); } } - http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/ExampleNodeStartup.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/ExampleNodeStartup.java b/examples/src/main/java/org/apache/ignite/examples/ExampleNodeStartup.java index f972b53..ad12297 100644 --- a/examples/src/main/java/org/apache/ignite/examples/ExampleNodeStartup.java +++ b/examples/src/main/java/org/apache/ignite/examples/ExampleNodeStartup.java @@ -17,7 +17,8 @@ package org.apache.ignite.examples; -import org.apache.ignite.*; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; /** * Starts up an empty node with example compute configuration. @@ -32,4 +33,4 @@ public class ExampleNodeStartup { public static void main(String[] args) throws IgniteException { Ignition.start("examples/config/example-ignite.xml"); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/ExamplesUtils.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/ExamplesUtils.java b/examples/src/main/java/org/apache/ignite/examples/ExamplesUtils.java index abc2578..69cd43f 100644 --- a/examples/src/main/java/org/apache/ignite/examples/ExamplesUtils.java +++ b/examples/src/main/java/org/apache/ignite/examples/ExamplesUtils.java @@ -17,11 +17,10 @@ package org.apache.ignite.examples; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; - -import java.net.*; -import java.util.*; +import java.net.URL; +import java.util.List; +import org.apache.ignite.Ignite; +import org.apache.ignite.cluster.ClusterGroup; /** * @@ -129,4 +128,4 @@ public class ExamplesUtils { } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeAsyncExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeAsyncExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeAsyncExample.java index 63ae110..e8321a5 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeAsyncExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeAsyncExample.java @@ -17,11 +17,15 @@ package org.apache.ignite.examples.computegrid; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import java.util.*; +import java.util.ArrayList; +import java.util.Collection; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCompute; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteFuture; +import org.apache.ignite.lang.IgniteRunnable; /** * Demonstrates a simple use of {@link IgniteRunnable}. @@ -71,4 +75,4 @@ public class ComputeAsyncExample { System.out.println(">>> Check all nodes for output (this node is also part of the cluster)."); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeBroadcastExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeBroadcastExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeBroadcastExample.java index 2ea878c..783b102 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeBroadcastExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeBroadcastExample.java @@ -17,12 +17,14 @@ package org.apache.ignite.examples.computegrid; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.resources.*; - -import java.util.*; +import java.util.Collection; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteCallable; +import org.apache.ignite.lang.IgniteRunnable; +import org.apache.ignite.resources.IgniteInstanceResource; /** * Demonstrates broadcasting computations within cluster. @@ -111,4 +113,4 @@ public class ComputeBroadcastExample { System.out.println(); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeCallableExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeCallableExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeCallableExample.java index f9a2939..aceca17 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeCallableExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeCallableExample.java @@ -17,11 +17,13 @@ package org.apache.ignite.examples.computegrid; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import java.util.*; +import java.util.ArrayList; +import java.util.Collection; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteCallable; /** * Demonstrates using of {@link IgniteCallable} job execution on the cluster. @@ -76,4 +78,4 @@ public class ComputeCallableExample { System.out.println(">>> Check all nodes for output (this node is also part of the cluster)."); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeClosureExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeClosureExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeClosureExample.java index 0efb4cc..eaa54a4 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeClosureExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeClosureExample.java @@ -17,11 +17,13 @@ package org.apache.ignite.examples.computegrid; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import java.util.*; +import java.util.Arrays; +import java.util.Collection; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteClosure; /** * Demonstrates a simple use of Ignite with reduce closure. @@ -74,4 +76,4 @@ public class ComputeClosureExample { System.out.println(">>> Check all nodes for output (this node is also part of the cluster)."); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeContinuousMapperExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeContinuousMapperExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeContinuousMapperExample.java index 715001e..8b77bbe 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeContinuousMapperExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeContinuousMapperExample.java @@ -17,15 +17,27 @@ package org.apache.ignite.examples.computegrid; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.compute.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.resources.*; - -import java.util.*; -import java.util.concurrent.*; -import java.util.concurrent.atomic.*; +import java.util.Collections; +import java.util.Date; +import java.util.List; +import java.util.Map; +import java.util.Queue; +import java.util.concurrent.ConcurrentLinkedQueue; +import java.util.concurrent.atomic.AtomicInteger; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.compute.ComputeJob; +import org.apache.ignite.compute.ComputeJobAdapter; +import org.apache.ignite.compute.ComputeJobResult; +import org.apache.ignite.compute.ComputeJobResultPolicy; +import org.apache.ignite.compute.ComputeTask; +import org.apache.ignite.compute.ComputeTaskAdapter; +import org.apache.ignite.compute.ComputeTaskContinuousMapper; +import org.apache.ignite.compute.ComputeTaskNoResultCache; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.resources.TaskContinuousMapperResource; /** * Demonstrates usage of continuous mapper. With continuous mapper @@ -155,4 +167,4 @@ public class ComputeContinuousMapperExample { } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeFibonacciContinuationExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeFibonacciContinuationExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeFibonacciContinuationExample.java index ff2fae9..706ec18 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeFibonacciContinuationExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeFibonacciContinuationExample.java @@ -17,17 +17,25 @@ package org.apache.ignite.examples.computegrid; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.compute.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.resources.*; -import org.jetbrains.annotations.*; - -import java.math.*; -import java.util.*; -import java.util.concurrent.*; +import java.math.BigInteger; +import java.util.UUID; +import java.util.concurrent.ConcurrentMap; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCompute; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.cluster.ClusterGroup; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.compute.ComputeJobContext; +import org.apache.ignite.compute.ComputeTaskFuture; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteClosure; +import org.apache.ignite.lang.IgniteFuture; +import org.apache.ignite.lang.IgniteInClosure; +import org.apache.ignite.lang.IgnitePredicate; +import org.apache.ignite.resources.IgniteInstanceResource; +import org.apache.ignite.resources.JobContextResource; +import org.jetbrains.annotations.Nullable; /** * This example demonstrates how to use continuation feature of Ignite by @@ -191,4 +199,4 @@ public final class ComputeFibonacciContinuationExample { return fut1.get().add(fut2.get()); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeReducerExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeReducerExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeReducerExample.java index b678d45..a4147d7 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeReducerExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeReducerExample.java @@ -17,12 +17,14 @@ package org.apache.ignite.examples.computegrid; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import java.util.*; -import java.util.concurrent.atomic.*; +import java.util.Arrays; +import java.util.concurrent.atomic.AtomicInteger; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteClosure; +import org.apache.ignite.lang.IgniteReducer; /** * Demonstrates a simple use of Ignite with reduce closure. @@ -86,4 +88,4 @@ public class ComputeReducerExample { System.out.println(">>> Check all nodes for output (this node is also part of the cluster)."); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeRunnableExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeRunnableExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeRunnableExample.java index 4763bba..5a6f9e8 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeRunnableExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeRunnableExample.java @@ -17,9 +17,12 @@ package org.apache.ignite.examples.computegrid; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCompute; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteRunnable; /** * Demonstrates a simple use of {@link IgniteRunnable}. @@ -60,4 +63,4 @@ public class ComputeRunnableExample { System.out.println(">>> Check all nodes for output (this node is also part of the cluster)."); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskMapExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskMapExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskMapExample.java index a06299f..1c880e8 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskMapExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskMapExample.java @@ -17,13 +17,20 @@ package org.apache.ignite.examples.computegrid; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.compute.*; -import org.apache.ignite.examples.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.HashMap; +import java.util.Iterator; +import java.util.List; +import java.util.Map; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.compute.ComputeJob; +import org.apache.ignite.compute.ComputeJobAdapter; +import org.apache.ignite.compute.ComputeJobResult; +import org.apache.ignite.compute.ComputeTaskAdapter; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.jetbrains.annotations.Nullable; /** * Demonstrates a simple use of Ignite with @@ -110,4 +117,4 @@ public class ComputeTaskMapExample { return sum; } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskSplitExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskSplitExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskSplitExample.java index 3dd3f63..a1358e0 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskSplitExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/ComputeTaskSplitExample.java @@ -17,12 +17,18 @@ package org.apache.ignite.examples.computegrid; -import org.apache.ignite.*; -import org.apache.ignite.compute.*; -import org.apache.ignite.examples.*; -import org.jetbrains.annotations.*; - -import java.util.*; +import java.util.Collection; +import java.util.LinkedList; +import java.util.List; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.compute.ComputeJob; +import org.apache.ignite.compute.ComputeJobAdapter; +import org.apache.ignite.compute.ComputeJobResult; +import org.apache.ignite.compute.ComputeTaskSplitAdapter; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.jetbrains.annotations.Nullable; /** * Demonstrates a simple use of Ignite with {@link ComputeTaskSplitAdapter}. @@ -99,4 +105,4 @@ public class ComputeTaskSplitExample { return sum; } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/cluster/ClusterGroupExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/cluster/ClusterGroupExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/cluster/ClusterGroupExample.java index 1982b17..d2b75df 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/cluster/ClusterGroupExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/cluster/ClusterGroupExample.java @@ -17,10 +17,16 @@ package org.apache.ignite.examples.computegrid.cluster; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCluster; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.cluster.ClusterGroup; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; +import org.apache.ignite.lang.IgnitePredicate; +import org.apache.ignite.lang.IgniteRunnable; /** * Demonstrates new functional APIs. @@ -90,4 +96,4 @@ public class ClusterGroupExample { } ); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/cluster/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/cluster/package-info.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/cluster/package-info.java index b837f73..cf144d1 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/cluster/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/cluster/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Cluster group example. */ -package org.apache.ignite.examples.computegrid.cluster; +package org.apache.ignite.examples.computegrid.cluster; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverExample.java index 9b87c70..ebe9151 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverExample.java @@ -17,13 +17,20 @@ package org.apache.ignite.examples.computegrid.failover; -import org.apache.ignite.*; -import org.apache.ignite.compute.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.resources.*; - -import java.util.*; +import java.util.Arrays; +import java.util.List; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.IgniteLogger; +import org.apache.ignite.Ignition; +import org.apache.ignite.compute.ComputeJobFailoverException; +import org.apache.ignite.compute.ComputeTaskSession; +import org.apache.ignite.compute.ComputeTaskSessionFullSupport; +import org.apache.ignite.examples.ExamplesUtils; +import org.apache.ignite.lang.IgniteBiTuple; +import org.apache.ignite.lang.IgniteClosure; +import org.apache.ignite.resources.LoggerResource; +import org.apache.ignite.resources.TaskSessionResource; /** * Demonstrates the usage of checkpoints in Ignite. @@ -134,4 +141,4 @@ public class ComputeFailoverExample { return getClass().getName() + '-' + phrase; } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverNodeStartup.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverNodeStartup.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverNodeStartup.java index bcd7db1..ca6dfe8 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverNodeStartup.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/ComputeFailoverNodeStartup.java @@ -17,13 +17,14 @@ package org.apache.ignite.examples.computegrid.failover; -import org.apache.ignite.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.spi.checkpoint.sharedfs.*; -import org.apache.ignite.spi.discovery.tcp.*; -import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*; - -import java.util.*; +import java.util.Arrays; +import java.util.Collections; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.spi.checkpoint.sharedfs.SharedFsCheckpointSpi; +import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; +import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder; /** * Starts up an empty node with checkpoint-enabled configuration. @@ -74,4 +75,4 @@ public class ComputeFailoverNodeStartup { return cfg; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/package-info.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/package-info.java index d065d52..506a2a2 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/failover/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Compute failover example. */ -package org.apache.ignite.examples.computegrid.failover; +package org.apache.ignite.examples.computegrid.failover; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/Credit.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/Credit.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/Credit.java index 81ebbee..0a0caf1 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/Credit.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/Credit.java @@ -17,7 +17,7 @@ package org.apache.ignite.examples.computegrid.montecarlo; -import java.io.*; +import java.io.Serializable; /** * This class provides a simple model for a credit contract (or a loan). It is basically @@ -107,4 +107,4 @@ public class Credit implements Serializable { return buf.toString(); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/CreditRiskExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/CreditRiskExample.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/CreditRiskExample.java index 5ab69e7..a7624b3 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/CreditRiskExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/CreditRiskExample.java @@ -17,11 +17,15 @@ package org.apache.ignite.examples.computegrid.montecarlo; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import java.util.*; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Random; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteCallable; +import org.apache.ignite.lang.IgniteReducer; /** * Monte-Carlo example. Demonstrates distributed credit risk calculation. @@ -150,4 +154,4 @@ public final class CreditRiskExample { return clos; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/CreditRiskManager.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/CreditRiskManager.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/CreditRiskManager.java index 051b782..255c15a 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/CreditRiskManager.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/CreditRiskManager.java @@ -17,7 +17,8 @@ package org.apache.ignite.examples.computegrid.montecarlo; -import java.util.*; +import java.util.Arrays; +import java.util.Random; /** * This class abstracts out the calculation of risk for a credit portfolio. @@ -140,4 +141,4 @@ public class CreditRiskManager { return cnt / losses.length; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/package-info.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/package-info.java index 5ea49f5..2e4a018 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/montecarlo/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Monte-Carlo simulation example. */ -package org.apache.ignite.examples.computegrid.montecarlo; +package org.apache.ignite.examples.computegrid.montecarlo; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/computegrid/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/computegrid/package-info.java b/examples/src/main/java/org/apache/ignite/examples/computegrid/package-info.java index a0ef33a..c072222 100644 --- a/examples/src/main/java/org/apache/ignite/examples/computegrid/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/computegrid/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Basic examples for computational ignite functionality. */ -package org.apache.ignite.examples.computegrid; +package org.apache.ignite.examples.computegrid; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheAffinityExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheAffinityExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheAffinityExample.java index a389dcb..f295ea7 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheAffinityExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheAffinityExample.java @@ -17,12 +17,18 @@ package org.apache.ignite.examples.datagrid; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import java.util.*; +import java.util.ArrayList; +import java.util.Collection; +import java.util.Map; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteCluster; +import org.apache.ignite.IgniteCompute; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.cluster.ClusterNode; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteRunnable; /** * This example demonstrates the simplest code that populates the distributed cache @@ -128,4 +134,4 @@ public final class CacheAffinityExample { } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheApiExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheApiExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheApiExample.java index 3d06b2e..78221d4 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheApiExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheApiExample.java @@ -17,11 +17,14 @@ package org.apache.ignite.examples.datagrid; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; - -import javax.cache.processor.*; -import java.util.concurrent.*; +import java.util.concurrent.ConcurrentMap; +import javax.cache.processor.EntryProcessor; +import javax.cache.processor.MutableEntry; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; /** * This example demonstrates some of the cache rich API capabilities. @@ -95,4 +98,4 @@ public class CacheApiExample { b2 = cache.replace(7, "7", "777"); assert b1 & !b2; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheAsyncApiExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheAsyncApiExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheAsyncApiExample.java index e9d6e04..a38c133 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheAsyncApiExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheAsyncApiExample.java @@ -17,11 +17,15 @@ package org.apache.ignite.examples.datagrid; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import java.util.*; +import java.util.ArrayList; +import java.util.Collection; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteFuture; +import org.apache.ignite.lang.IgniteInClosure; /** * This example demonstrates some of the cache rich API capabilities. @@ -76,4 +80,4 @@ public class CacheAsyncApiExample { } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java index a209d42..0ce6e89 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheContinuousQueryExample.java @@ -17,14 +17,18 @@ package org.apache.ignite.examples.datagrid; -import org.apache.ignite.*; -import org.apache.ignite.cache.*; -import org.apache.ignite.cache.query.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import javax.cache.*; -import javax.cache.event.*; +import javax.cache.Cache; +import javax.cache.event.CacheEntryEvent; +import javax.cache.event.CacheEntryUpdatedListener; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.Ignition; +import org.apache.ignite.cache.CacheEntryEventSerializableFilter; +import org.apache.ignite.cache.query.ContinuousQuery; +import org.apache.ignite.cache.query.QueryCursor; +import org.apache.ignite.cache.query.ScanQuery; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteBiPredicate; /** * This examples demonstrates continuous query API. @@ -98,4 +102,4 @@ public class CacheContinuousQueryExample { } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataStreamerExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataStreamerExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataStreamerExample.java index 4994388..2357c28 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataStreamerExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheDataStreamerExample.java @@ -17,8 +17,13 @@ package org.apache.ignite.examples.datagrid; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteDataStreamer; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; /** * Demonstrates how cache can be populated with data utilizing {@link IgniteDataStreamer} API. @@ -78,4 +83,4 @@ public class CacheDataStreamerExample { } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheEventsExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheEventsExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheEventsExample.java index 32fab75..b2fdc8c 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheEventsExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheEventsExample.java @@ -17,14 +17,19 @@ package org.apache.ignite.examples.datagrid; -import org.apache.ignite.*; -import org.apache.ignite.events.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; +import java.util.UUID; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.events.CacheEvent; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteBiPredicate; +import org.apache.ignite.lang.IgnitePredicate; -import java.util.*; - -import static org.apache.ignite.events.EventType.*; +import static org.apache.ignite.events.EventType.EVT_CACHE_OBJECT_PUT; +import static org.apache.ignite.events.EventType.EVT_CACHE_OBJECT_READ; +import static org.apache.ignite.events.EventType.EVT_CACHE_OBJECT_REMOVED; /** * This examples demonstrates events API. Note that ignite events are disabled by default and @@ -89,4 +94,4 @@ public class CacheEventsExample { } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePutGetExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePutGetExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePutGetExample.java index 8fd5376..82a76b8 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePutGetExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CachePutGetExample.java @@ -17,10 +17,13 @@ package org.apache.ignite.examples.datagrid; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; - -import java.util.*; +import java.util.HashMap; +import java.util.Map; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; /** * This example demonstrates very basic operations on cache, such as 'put' and 'get'. @@ -102,4 +105,4 @@ public class CachePutGetExample { for (Map.Entry<Integer, String> e : vals.entrySet()) System.out.println("Got entry [key=" + e.getKey() + ", val=" + e.getValue() + ']'); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheQueryExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheQueryExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheQueryExample.java index 6d6126d..1b2e02a 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheQueryExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheQueryExample.java @@ -17,18 +17,25 @@ package org.apache.ignite.examples.datagrid; -import org.apache.ignite.*; -import org.apache.ignite.cache.*; -import org.apache.ignite.cache.affinity.*; -import org.apache.ignite.cache.query.*; -import org.apache.ignite.cache.query.annotations.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import javax.cache.*; -import java.io.*; -import java.util.*; +import java.io.Serializable; +import java.util.List; +import java.util.UUID; +import javax.cache.Cache; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.Ignition; +import org.apache.ignite.cache.CacheMode; +import org.apache.ignite.cache.affinity.AffinityKey; +import org.apache.ignite.cache.query.QueryCursor; +import org.apache.ignite.cache.query.ScanQuery; +import org.apache.ignite.cache.query.SqlFieldsQuery; +import org.apache.ignite.cache.query.SqlQuery; +import org.apache.ignite.cache.query.TextQuery; +import org.apache.ignite.cache.query.annotations.QuerySqlField; +import org.apache.ignite.cache.query.annotations.QueryTextField; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteBiPredicate; /** * Cache queries example. This example demonstrates SQL, TEXT, and FULL SCAN @@ -418,4 +425,4 @@ public class CacheQueryExample { return "Organization [id=" + id + ", name=" + name + ']'; } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheTransactionExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheTransactionExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheTransactionExample.java index 797543a..93e51c1 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheTransactionExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/CacheTransactionExample.java @@ -17,16 +17,19 @@ package org.apache.ignite.examples.datagrid; -import org.apache.ignite.*; -import org.apache.ignite.cache.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.transactions.*; - -import java.io.*; - -import static org.apache.ignite.transactions.TransactionConcurrency.*; -import static org.apache.ignite.transactions.TransactionIsolation.*; +import java.io.Serializable; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.cache.CacheAtomicityMode; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.configuration.NearCacheConfiguration; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.transactions.Transaction; + +import static org.apache.ignite.transactions.TransactionConcurrency.PESSIMISTIC; +import static org.apache.ignite.transactions.TransactionIsolation.REPEATABLE_READ; /** * Demonstrates how to use cache transactions. @@ -139,4 +142,4 @@ public class CacheTransactionExample { return "Account [id=" + id + ", balance=$" + balance + ']'; } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/HibernateL2CacheExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/HibernateL2CacheExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/HibernateL2CacheExample.java index af2decf..43088a4 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/HibernateL2CacheExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/HibernateL2CacheExample.java @@ -17,21 +17,28 @@ package org.apache.ignite.examples.datagrid.hibernate; -import org.apache.ignite.*; -import org.apache.ignite.cache.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.examples.*; -import org.hibernate.*; +import java.net.URL; +import java.util.Arrays; +import java.util.List; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.cache.CacheAtomicityMode; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; +import org.hibernate.Session; +import org.hibernate.SessionFactory; +import org.hibernate.Transaction; import org.hibernate.cache.spi.access.AccessType; -import org.hibernate.cfg.*; -import org.hibernate.service.*; -import org.hibernate.stat.*; +import org.hibernate.cfg.Configuration; +import org.hibernate.service.ServiceRegistryBuilder; +import org.hibernate.stat.SecondLevelCacheStatistics; -import java.net.*; -import java.util.*; - -import static org.apache.ignite.cache.CacheAtomicityMode.*; -import static org.apache.ignite.cache.CacheWriteSynchronizationMode.*; +import static org.apache.ignite.cache.CacheAtomicityMode.ATOMIC; +import static org.apache.ignite.cache.CacheAtomicityMode.TRANSACTIONAL; +import static org.apache.ignite.cache.CacheWriteSynchronizationMode.FULL_SYNC; /** * This example demonstrates the use of Ignite In-Memory Data Ignite cluster as a Hibernate @@ -235,4 +242,4 @@ public class HibernateL2CacheExample { System.out.println("====================================="); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/Post.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/Post.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/Post.java index 4c73f3f..798411a 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/Post.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/Post.java @@ -17,8 +17,12 @@ package org.apache.ignite.examples.datagrid.hibernate; -import javax.persistence.*; -import java.util.*; +import java.util.Date; +import javax.persistence.Entity; +import javax.persistence.GeneratedValue; +import javax.persistence.GenerationType; +import javax.persistence.Id; +import javax.persistence.ManyToOne; /** * An entity class representing a post, that a @@ -123,4 +127,4 @@ class Post { ", created=" + created + ']'; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/User.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/User.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/User.java index 500c625..b7d5299 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/User.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/User.java @@ -17,12 +17,15 @@ package org.apache.ignite.examples.datagrid.hibernate; -import org.hibernate.annotations.*; - +import java.util.HashSet; +import java.util.Set; import javax.persistence.CascadeType; import javax.persistence.Entity; -import javax.persistence.*; -import java.util.*; +import javax.persistence.GeneratedValue; +import javax.persistence.GenerationType; +import javax.persistence.Id; +import javax.persistence.OneToMany; +import org.hibernate.annotations.NaturalId; /** * A user entity class. Represents a user of some public service, @@ -148,4 +151,4 @@ class User { ", lastName=" + lastName + ']'; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/package-info.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/package-info.java index 7bddaaf..4bb876b 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/hibernate/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Hibernate example. */ -package org.apache.ignite.examples.datagrid.hibernate; +package org.apache.ignite.examples.datagrid.hibernate; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/package-info.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/package-info.java index cfa37a4..e060581 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Demonstrates data ignite cache usage. */ -package org.apache.ignite.examples.datagrid; +package org.apache.ignite.examples.datagrid; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/CacheStarSchemaExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/CacheStarSchemaExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/CacheStarSchemaExample.java index bef2457..12fee26 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/CacheStarSchemaExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/CacheStarSchemaExample.java @@ -17,15 +17,21 @@ package org.apache.ignite.examples.datagrid.starschema; -import org.apache.ignite.*; -import org.apache.ignite.cache.*; -import org.apache.ignite.cache.query.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.examples.*; - -import javax.cache.*; -import java.util.*; -import java.util.concurrent.*; +import java.util.Collection; +import java.util.ConcurrentModificationException; +import java.util.HashMap; +import java.util.Map; +import java.util.concurrent.ThreadLocalRandom; +import javax.cache.Cache; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.cache.CacheMode; +import org.apache.ignite.cache.query.QueryCursor; +import org.apache.ignite.cache.query.SqlQuery; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.examples.ExampleNodeStartup; /** * <a href="http://en.wikipedia.org/wiki/Snowflake_schema";>Snowflake Schema</a> is a logical @@ -236,4 +242,4 @@ public class CacheStarSchemaExample { throw new ConcurrentModificationException(); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/DimProduct.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/DimProduct.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/DimProduct.java index 46adc80..ec56865 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/DimProduct.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/DimProduct.java @@ -17,8 +17,8 @@ package org.apache.ignite.examples.datagrid.starschema; -import org.apache.ignite.cache.query.annotations.*; -import org.apache.ignite.cache.*; +import org.apache.ignite.cache.CacheMode; +import org.apache.ignite.cache.query.annotations.QuerySqlField; /** * Represents a product available for purchase. In our {@code snowflake} schema a {@code product} @@ -98,4 +98,4 @@ public class DimProduct { ", price=" + price + ", qty=" + qty + ']'; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/DimStore.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/DimStore.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/DimStore.java index da991e8..566a840 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/DimStore.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/DimStore.java @@ -17,8 +17,8 @@ package org.apache.ignite.examples.datagrid.starschema; -import org.apache.ignite.cache.query.annotations.*; -import org.apache.ignite.cache.*; +import org.apache.ignite.cache.CacheMode; +import org.apache.ignite.cache.query.annotations.QuerySqlField; /** * Represents a physical store location. In our {@code snowflake} schema a {@code store} @@ -98,4 +98,4 @@ public class DimStore { ", zip=" + zip + ", addr=" + addr + ']'; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/FactPurchase.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/FactPurchase.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/FactPurchase.java index 7dc46c4..cdb4def 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/FactPurchase.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/FactPurchase.java @@ -17,8 +17,8 @@ package org.apache.ignite.examples.datagrid.starschema; -import org.apache.ignite.cache.query.annotations.*; -import org.apache.ignite.cache.*; +import org.apache.ignite.cache.CacheMode; +import org.apache.ignite.cache.query.annotations.QuerySqlField; /** * Represents a purchase record. In our {@code snowflake} schema purchase @@ -100,4 +100,4 @@ public class FactPurchase { ", storeId=" + storeId + ", purchasePrice=" + purchasePrice + ']'; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/package-info.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/package-info.java index 2ed1469..4db7d8c 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/starschema/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Demonstrates distributed SQL joins over ignite using Snowflake schema. */ -package org.apache.ignite.examples.datagrid.starschema; +package org.apache.ignite.examples.datagrid.starschema; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/Person.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/Person.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/Person.java index 6337401..b54010f 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/Person.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/Person.java @@ -17,7 +17,7 @@ package org.apache.ignite.examples.datagrid.store; -import java.io.*; +import java.io.Serializable; /** * Person definition. @@ -152,4 +152,3 @@ public class Person implements Serializable { "]"; } } - http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/CacheAutoStoreExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/CacheAutoStoreExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/CacheAutoStoreExample.java index 0176451..f8cd4dd 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/CacheAutoStoreExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/CacheAutoStoreExample.java @@ -17,13 +17,15 @@ package org.apache.ignite.examples.datagrid.store.auto; -import org.apache.ignite.*; -import org.apache.ignite.cache.store.jdbc.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.examples.datagrid.store.*; -import org.apache.ignite.transactions.*; - -import java.util.*; +import java.util.UUID; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStore; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.datagrid.store.Person; +import org.apache.ignite.transactions.Transaction; /** * Demonstrates usage of cache with underlying persistent store configured. @@ -83,4 +85,4 @@ public class CacheAutoStoreExample { } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/CacheAutoStoreLoadDataExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/CacheAutoStoreLoadDataExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/CacheAutoStoreLoadDataExample.java index 4cfd520..f0f9feb 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/CacheAutoStoreLoadDataExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/CacheAutoStoreLoadDataExample.java @@ -17,11 +17,15 @@ package org.apache.ignite.examples.datagrid.store.auto; -import org.apache.ignite.*; -import org.apache.ignite.cache.store.jdbc.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.examples.datagrid.store.*; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStore; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; +import org.apache.ignite.examples.datagrid.store.Person; /** * Demonstrates how to load data from database. @@ -78,4 +82,4 @@ public class CacheAutoStoreLoadDataExample { } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/CacheConfig.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/CacheConfig.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/CacheConfig.java index 6c148a6..1eb7cd2 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/CacheConfig.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/CacheConfig.java @@ -17,18 +17,19 @@ package org.apache.ignite.examples.datagrid.store.auto; -import org.apache.ignite.cache.*; -import org.apache.ignite.cache.store.*; -import org.apache.ignite.cache.store.jdbc.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.examples.datagrid.store.*; -import org.h2.jdbcx.*; - -import javax.cache.configuration.*; -import java.sql.*; -import java.util.*; - -import static org.apache.ignite.cache.CacheAtomicityMode.*; +import java.sql.Types; +import java.util.Arrays; +import java.util.Collections; +import javax.cache.configuration.Factory; +import org.apache.ignite.cache.CacheTypeFieldMetadata; +import org.apache.ignite.cache.CacheTypeMetadata; +import org.apache.ignite.cache.store.CacheStore; +import org.apache.ignite.cache.store.jdbc.CacheJdbcPojoStore; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.examples.datagrid.store.Person; +import org.h2.jdbcx.JdbcConnectionPool; + +import static org.apache.ignite.cache.CacheAtomicityMode.TRANSACTIONAL; /** * Predefined configuration for examples with {@link CacheJdbcPojoStore}. @@ -77,4 +78,4 @@ public class CacheConfig { return cfg; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/DbH2ServerStartup.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/DbH2ServerStartup.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/DbH2ServerStartup.java index 96e4622..f5e07a8 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/DbH2ServerStartup.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/DbH2ServerStartup.java @@ -17,12 +17,13 @@ package org.apache.ignite.examples.datagrid.store.auto; -import org.apache.ignite.*; -import org.h2.jdbcx.*; -import org.h2.tools.*; - -import java.io.*; -import java.sql.*; +import java.io.IOException; +import java.io.StringReader; +import java.sql.SQLException; +import org.apache.ignite.IgniteException; +import org.h2.jdbcx.JdbcConnectionPool; +import org.h2.tools.RunScript; +import org.h2.tools.Server; /** * Start H2 database TCP server in order to access sample in-memory database from other processes. @@ -75,4 +76,4 @@ public class DbH2ServerStartup { // No-op. } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/package-info.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/package-info.java index 803253f..57f0b7e 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/auto/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Contains automatic JDBC store example. */ -package org.apache.ignite.examples.datagrid.store.auto; +package org.apache.ignite.examples.datagrid.store.auto; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/dummy/CacheDummyPersonStore.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/dummy/CacheDummyPersonStore.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/dummy/CacheDummyPersonStore.java index 1c9e0d6..f85e92b 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/dummy/CacheDummyPersonStore.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/dummy/CacheDummyPersonStore.java @@ -17,16 +17,18 @@ package org.apache.ignite.examples.datagrid.store.dummy; -import org.apache.ignite.*; -import org.apache.ignite.cache.store.*; -import org.apache.ignite.examples.datagrid.store.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.resources.*; -import org.apache.ignite.transactions.*; -import org.jetbrains.annotations.*; - -import java.util.*; -import java.util.concurrent.*; +import java.util.Map; +import java.util.concurrent.ConcurrentHashMap; +import org.apache.ignite.Ignite; +import org.apache.ignite.cache.store.CacheStoreAdapter; +import org.apache.ignite.cache.store.CacheStoreSession; +import org.apache.ignite.examples.datagrid.store.Person; +import org.apache.ignite.lang.IgniteBiInClosure; +import org.apache.ignite.resources.CacheNameResource; +import org.apache.ignite.resources.CacheStoreSessionResource; +import org.apache.ignite.resources.IgniteInstanceResource; +import org.apache.ignite.transactions.Transaction; +import org.jetbrains.annotations.Nullable; /** * Dummy cache store implementation. @@ -108,4 +110,4 @@ public class CacheDummyPersonStore extends CacheStoreAdapter<Long, Person> { @Nullable private Transaction transaction() { return ses != null ? ses.transaction() : null; } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/dummy/CacheDummyStoreExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/dummy/CacheDummyStoreExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/dummy/CacheDummyStoreExample.java index d79b895..20e6b8f 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/dummy/CacheDummyStoreExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/dummy/CacheDummyStoreExample.java @@ -17,16 +17,19 @@ package org.apache.ignite.examples.datagrid.store.dummy; -import org.apache.ignite.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.examples.datagrid.store.*; -import org.apache.ignite.transactions.*; - -import javax.cache.configuration.*; -import java.util.*; - -import static org.apache.ignite.cache.CacheAtomicityMode.*; +import java.util.UUID; +import javax.cache.configuration.FactoryBuilder; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; +import org.apache.ignite.examples.datagrid.store.Person; +import org.apache.ignite.transactions.Transaction; + +import static org.apache.ignite.cache.CacheAtomicityMode.TRANSACTIONAL; /** * Demonstrates usage of cache with underlying persistent store configured. @@ -127,4 +130,4 @@ public class CacheDummyStoreExample { System.out.println("Read value after commit: " + cache.get(id)); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/dummy/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/dummy/package-info.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/dummy/package-info.java index 9993f67..42c3899 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/dummy/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/dummy/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Contains dummy cache store implementation. */ -package org.apache.ignite.examples.datagrid.store.dummy; +package org.apache.ignite.examples.datagrid.store.dummy; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/hibernate/CacheHibernatePersonStore.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/hibernate/CacheHibernatePersonStore.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/hibernate/CacheHibernatePersonStore.java index 80a9f22..f8831ab 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/hibernate/CacheHibernatePersonStore.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/hibernate/CacheHibernatePersonStore.java @@ -17,14 +17,18 @@ package org.apache.ignite.examples.datagrid.store.hibernate; -import org.apache.ignite.cache.store.*; -import org.apache.ignite.examples.datagrid.store.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.resources.*; -import org.hibernate.*; - -import javax.cache.integration.*; -import java.util.*; +import java.util.List; +import java.util.UUID; +import javax.cache.integration.CacheLoaderException; +import javax.cache.integration.CacheWriterException; +import org.apache.ignite.cache.store.CacheStore; +import org.apache.ignite.cache.store.CacheStoreAdapter; +import org.apache.ignite.cache.store.CacheStoreSession; +import org.apache.ignite.examples.datagrid.store.Person; +import org.apache.ignite.lang.IgniteBiInClosure; +import org.apache.ignite.resources.CacheStoreSessionResource; +import org.hibernate.HibernateException; +import org.hibernate.Session; /** * Example of {@link CacheStore} implementation that uses Hibernate @@ -115,4 +119,4 @@ public class CacheHibernatePersonStore extends CacheStoreAdapter<Long, Person> { throw new CacheLoaderException("Failed to load values from cache store.", e); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/hibernate/CacheHibernateStoreExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/hibernate/CacheHibernateStoreExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/hibernate/CacheHibernateStoreExample.java index 25760f0..fbb761a 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/hibernate/CacheHibernateStoreExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/hibernate/CacheHibernateStoreExample.java @@ -17,18 +17,22 @@ package org.apache.ignite.examples.datagrid.store.hibernate; -import org.apache.ignite.*; -import org.apache.ignite.cache.store.*; -import org.apache.ignite.cache.store.hibernate.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.examples.datagrid.store.*; -import org.apache.ignite.transactions.*; - -import javax.cache.configuration.*; -import java.util.*; - -import static org.apache.ignite.cache.CacheAtomicityMode.*; +import java.util.UUID; +import javax.cache.configuration.Factory; +import javax.cache.configuration.FactoryBuilder; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.cache.store.CacheStoreSessionListener; +import org.apache.ignite.cache.store.hibernate.CacheHibernateStoreSessionListener; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; +import org.apache.ignite.examples.datagrid.store.Person; +import org.apache.ignite.transactions.Transaction; + +import static org.apache.ignite.cache.CacheAtomicityMode.TRANSACTIONAL; /** * Demonstrates usage of cache with underlying persistent store configured. @@ -144,4 +148,4 @@ public class CacheHibernateStoreExample { System.out.println("Read value after commit: " + cache.get(id)); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/hibernate/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/hibernate/package-info.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/hibernate/package-info.java index 7210b49..7a6d6de 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/hibernate/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/hibernate/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Contains Hibernate-based cache store implementation. */ -package org.apache.ignite.examples.datagrid.store.hibernate; +package org.apache.ignite.examples.datagrid.store.hibernate; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/CacheJdbcPersonStore.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/CacheJdbcPersonStore.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/CacheJdbcPersonStore.java index ed14a99..e0ea13a 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/CacheJdbcPersonStore.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/CacheJdbcPersonStore.java @@ -17,17 +17,22 @@ package org.apache.ignite.examples.datagrid.store.jdbc; -import org.apache.ignite.*; -import org.apache.ignite.cache.store.*; -import org.apache.ignite.examples.datagrid.store.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.resources.*; -import org.h2.jdbcx.*; - -import javax.cache.*; -import javax.cache.integration.*; -import javax.sql.*; -import java.sql.*; +import java.sql.Connection; +import java.sql.PreparedStatement; +import java.sql.ResultSet; +import java.sql.SQLException; +import javax.cache.Cache; +import javax.cache.integration.CacheLoaderException; +import javax.cache.integration.CacheWriterException; +import javax.sql.DataSource; +import org.apache.ignite.IgniteException; +import org.apache.ignite.cache.store.CacheStore; +import org.apache.ignite.cache.store.CacheStoreAdapter; +import org.apache.ignite.cache.store.CacheStoreSession; +import org.apache.ignite.examples.datagrid.store.Person; +import org.apache.ignite.lang.IgniteBiInClosure; +import org.apache.ignite.resources.CacheStoreSessionResource; +import org.h2.jdbcx.JdbcConnectionPool; /** * Example of {@link CacheStore} implementation that uses JDBC @@ -172,4 +177,4 @@ public class CacheJdbcPersonStore extends CacheStoreAdapter<Long, Person> { throw new CacheLoaderException("Failed to load values from cache store.", e); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/CacheJdbcStoreExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/CacheJdbcStoreExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/CacheJdbcStoreExample.java index 637d6dc..9d3014f 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/CacheJdbcStoreExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/CacheJdbcStoreExample.java @@ -17,18 +17,22 @@ package org.apache.ignite.examples.datagrid.store.jdbc; -import org.apache.ignite.*; -import org.apache.ignite.cache.store.*; -import org.apache.ignite.cache.store.jdbc.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.examples.datagrid.store.*; -import org.apache.ignite.transactions.*; - -import javax.cache.configuration.*; -import java.util.*; - -import static org.apache.ignite.cache.CacheAtomicityMode.*; +import java.util.UUID; +import javax.cache.configuration.Factory; +import javax.cache.configuration.FactoryBuilder; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.cache.store.CacheStoreSessionListener; +import org.apache.ignite.cache.store.jdbc.CacheJdbcStoreSessionListener; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; +import org.apache.ignite.examples.datagrid.store.Person; +import org.apache.ignite.transactions.Transaction; + +import static org.apache.ignite.cache.CacheAtomicityMode.TRANSACTIONAL; /** * Demonstrates usage of cache with underlying persistent store configured. @@ -140,4 +144,4 @@ public class CacheJdbcStoreExample { System.out.println("Read value after commit: " + cache.get(id)); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/package-info.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/package-info.java index ee6facb..46cfe6b 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/jdbc/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Contains JDBC-based cache store implementation. */ -package org.apache.ignite.examples.datagrid.store.jdbc; +package org.apache.ignite.examples.datagrid.store.jdbc; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/package-info.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/package-info.java index 2c98e7c..c05873a 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Demonstrates using of cache store. */ -package org.apache.ignite.examples.datagrid.store; +package org.apache.ignite.examples.datagrid.store; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/spring/CacheSpringPersonStore.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/spring/CacheSpringPersonStore.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/spring/CacheSpringPersonStore.java index 50149ba..7a0ea33 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/spring/CacheSpringPersonStore.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/spring/CacheSpringPersonStore.java @@ -17,19 +17,22 @@ package org.apache.ignite.examples.datagrid.store.spring; -import org.apache.ignite.*; -import org.apache.ignite.cache.store.*; -import org.apache.ignite.examples.datagrid.store.*; -import org.apache.ignite.lang.*; -import org.springframework.dao.*; -import org.springframework.jdbc.core.*; -import org.springframework.jdbc.datasource.*; - -import javax.cache.*; -import javax.cache.integration.*; -import javax.sql.*; -import java.sql.*; -import java.util.concurrent.atomic.*; +import java.sql.ResultSet; +import java.sql.SQLException; +import java.util.concurrent.atomic.AtomicInteger; +import javax.cache.Cache; +import javax.cache.integration.CacheLoaderException; +import javax.sql.DataSource; +import org.apache.ignite.IgniteException; +import org.apache.ignite.cache.store.CacheStore; +import org.apache.ignite.cache.store.CacheStoreAdapter; +import org.apache.ignite.examples.datagrid.store.Person; +import org.apache.ignite.lang.IgniteBiInClosure; +import org.springframework.dao.EmptyResultDataAccessException; +import org.springframework.jdbc.core.JdbcTemplate; +import org.springframework.jdbc.core.RowCallbackHandler; +import org.springframework.jdbc.core.RowMapper; +import org.springframework.jdbc.datasource.DriverManagerDataSource; /** * Example of {@link CacheStore} implementation that uses JDBC @@ -125,4 +128,4 @@ public class CacheSpringPersonStore extends CacheStoreAdapter<Long, Person> { System.out.println(">>> Loaded " + cnt + " values into cache."); } -} +} \ No newline at end of file
