http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java/org/apache/ignite/examples/datagrid/store/spring/CacheSpringStoreExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/spring/CacheSpringStoreExample.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/spring/CacheSpringStoreExample.java index aa624bc..16437da 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/spring/CacheSpringStoreExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/spring/CacheSpringStoreExample.java @@ -17,18 +17,22 @@ package org.apache.ignite.examples.datagrid.store.spring; -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 CacheSpringStoreExample { 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/spring/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/spring/package-info.java b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/spring/package-info.java index 211239f..3f03bde 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datagrid/store/spring/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/datagrid/store/spring/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Contains Spring-based cache store implementation. */ -package org.apache.ignite.examples.datagrid.store.spring; +package org.apache.ignite.examples.datagrid.store.spring; \ 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/datastructures/IgniteAtomicLongExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicLongExample.java b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicLongExample.java index e83673f..058ed5b 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicLongExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicLongExample.java @@ -17,11 +17,12 @@ package org.apache.ignite.examples.datastructures; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import java.util.*; +import java.util.UUID; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteAtomicLong; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteCallable; /** * Demonstrates a simple usage of distributed atomic long. @@ -71,4 +72,4 @@ public final class IgniteAtomicLongExample { System.out.println("Atomic long value after successful CAS: " + atomicLong.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/datastructures/IgniteAtomicReferenceExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicReferenceExample.java b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicReferenceExample.java index 76c1d5e..0b6d6f2 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicReferenceExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicReferenceExample.java @@ -17,11 +17,12 @@ package org.apache.ignite.examples.datastructures; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import java.util.*; +import java.util.UUID; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteAtomicReference; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteRunnable; /** * Demonstrates a simple usage of distributed atomic reference. @@ -107,4 +108,4 @@ public final class IgniteAtomicReferenceExample { System.out.println("Atomic reference value is " + ref.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/datastructures/IgniteAtomicSequenceExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicSequenceExample.java b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicSequenceExample.java index 3052da5..756cb75 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicSequenceExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicSequenceExample.java @@ -17,9 +17,11 @@ package org.apache.ignite.examples.datastructures; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteAtomicSequence; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteRunnable; /** * Demonstrates a simple usage of distributed atomic sequence. @@ -88,4 +90,4 @@ public final class IgniteAtomicSequenceExample { seq.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/datastructures/IgniteAtomicStampedExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicStampedExample.java b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicStampedExample.java index 077ae89..8c96801 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicStampedExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteAtomicStampedExample.java @@ -17,11 +17,12 @@ package org.apache.ignite.examples.datastructures; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import java.util.*; +import java.util.UUID; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteAtomicStamped; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteRunnable; /** * Demonstrates a simple usage of distributed atomic stamped. @@ -114,4 +115,4 @@ public final class IgniteAtomicStampedExample { System.out.println("Atomic stamped [value=" + stamped.value() + ", stamp=" + stamped.stamp() + ']'); } } -} +} \ 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/datastructures/IgniteCountDownLatchExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteCountDownLatchExample.java b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteCountDownLatchExample.java index 3882a43..f1802fc 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteCountDownLatchExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteCountDownLatchExample.java @@ -17,11 +17,12 @@ package org.apache.ignite.examples.datastructures; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import java.util.*; +import java.util.UUID; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCountDownLatch; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteRunnable; /** * Demonstrates a simple usage of distributed count down latch. @@ -92,4 +93,4 @@ public class IgniteCountDownLatchExample { System.out.println("Counted down [newCnt=" + newCnt + ", nodeId=" + Ignition.ignite().cluster().localNode().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/datastructures/IgniteExecutorServiceExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteExecutorServiceExample.java b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteExecutorServiceExample.java index d8f32d3..e840650 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteExecutorServiceExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteExecutorServiceExample.java @@ -17,11 +17,12 @@ package org.apache.ignite.examples.datastructures; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import java.util.concurrent.*; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.TimeUnit; +import org.apache.ignite.Ignite; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteRunnable; /** * Simple example to demonstrate usage of distributed executor service provided by Ignite. @@ -68,4 +69,4 @@ public final class IgniteExecutorServiceExample { 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/datastructures/IgniteQueueExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteQueueExample.java b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteQueueExample.java index 79067e6..45f180f 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteQueueExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteQueueExample.java @@ -17,14 +17,16 @@ package org.apache.ignite.examples.datastructures; -import org.apache.ignite.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; +import java.util.UUID; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.IgniteQueue; +import org.apache.ignite.Ignition; +import org.apache.ignite.configuration.CollectionConfiguration; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteRunnable; -import java.util.*; - -import static org.apache.ignite.cache.CacheMode.*; +import static org.apache.ignite.cache.CacheMode.PARTITIONED; /** * Ignite cache distributed queue example. This example demonstrates {@code FIFO} unbounded @@ -202,4 +204,4 @@ public class IgniteQueueExample { } } } -} +} \ 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/datastructures/IgniteSetExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteSetExample.java b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteSetExample.java index 8d4fc89..184f865 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteSetExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/datastructures/IgniteSetExample.java @@ -17,15 +17,17 @@ package org.apache.ignite.examples.datastructures; -import org.apache.ignite.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import java.util.*; - -import static org.apache.ignite.cache.CacheAtomicityMode.*; -import static org.apache.ignite.cache.CacheMode.*; +import java.util.UUID; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.IgniteSet; +import org.apache.ignite.Ignition; +import org.apache.ignite.configuration.CollectionConfiguration; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteRunnable; + +import static org.apache.ignite.cache.CacheAtomicityMode.TRANSACTIONAL; +import static org.apache.ignite.cache.CacheMode.PARTITIONED; /** * Ignite cache distributed set example. @@ -184,4 +186,4 @@ public class IgniteSetExample { } } } -} +} \ 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/datastructures/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/datastructures/package-info.java b/examples/src/main/java/org/apache/ignite/examples/datastructures/package-info.java index 09b9c66..962ba44 100644 --- a/examples/src/main/java/org/apache/ignite/examples/datastructures/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/datastructures/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Demonstrates using of blocking and non-blocking queues and atomic data structures. */ -package org.apache.ignite.examples.datastructures; +package org.apache.ignite.examples.datastructures; \ 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/events/EventsExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/events/EventsExample.java b/examples/src/main/java/org/apache/ignite/examples/events/EventsExample.java index dd23e14..6cc6659 100644 --- a/examples/src/main/java/org/apache/ignite/examples/events/EventsExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/events/EventsExample.java @@ -17,16 +17,19 @@ package org.apache.ignite.examples.events; -import org.apache.ignite.*; -import org.apache.ignite.compute.*; -import org.apache.ignite.events.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.resources.*; - -import java.util.*; - -import static org.apache.ignite.events.EventType.*; +import java.util.UUID; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.compute.ComputeTaskSession; +import org.apache.ignite.events.TaskEvent; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteBiPredicate; +import org.apache.ignite.lang.IgnitePredicate; +import org.apache.ignite.lang.IgniteRunnable; +import org.apache.ignite.resources.TaskSessionResource; + +import static org.apache.ignite.events.EventType.EVTS_TASK_EXECUTION; /** * Demonstrates event consume API that allows to register event listeners on remote nodes. @@ -141,4 +144,4 @@ public class EventsExample { }); } } -} +} \ 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/events/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/events/package-info.java b/examples/src/main/java/org/apache/ignite/examples/events/package-info.java index 3dd8543..8b66103 100644 --- a/examples/src/main/java/org/apache/ignite/examples/events/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/events/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Demonstrates events management API. */ -package org.apache.ignite.examples.events; +package org.apache.ignite.examples.events; \ 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/igfs/IgfsExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/igfs/IgfsExample.java b/examples/src/main/java/org/apache/ignite/examples/igfs/IgfsExample.java index 8bfd38d..b040ace 100644 --- a/examples/src/main/java/org/apache/ignite/examples/igfs/IgfsExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/igfs/IgfsExample.java @@ -17,12 +17,18 @@ package org.apache.ignite.examples.igfs; -import org.apache.ignite.*; -import org.apache.ignite.igfs.*; -import org.jetbrains.annotations.*; - -import java.io.*; -import java.util.*; +import java.io.IOException; +import java.io.OutputStream; +import java.util.Arrays; +import java.util.Collection; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.IgniteFileSystem; +import org.apache.ignite.Ignition; +import org.apache.ignite.igfs.IgfsException; +import org.apache.ignite.igfs.IgfsInputStream; +import org.apache.ignite.igfs.IgfsPath; +import org.jetbrains.annotations.Nullable; /** * Example that shows usage of {@link org.apache.ignite.IgniteFileSystem} API. It starts a node with {@code IgniteFs} @@ -275,4 +281,4 @@ public final class IgfsExample { System.out.println(); System.out.println("Information for " + path + ": " + fs.info(path)); } -} +} \ 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/igfs/IgfsMapReduceExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/igfs/IgfsMapReduceExample.java b/examples/src/main/java/org/apache/ignite/examples/igfs/IgfsMapReduceExample.java index f4fa95e..666e623 100644 --- a/examples/src/main/java/org/apache/ignite/examples/igfs/IgfsMapReduceExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/igfs/IgfsMapReduceExample.java @@ -17,14 +17,31 @@ package org.apache.ignite.examples.igfs; -import org.apache.ignite.*; -import org.apache.ignite.compute.*; -import org.apache.ignite.igfs.*; -import org.apache.ignite.igfs.mapreduce.*; -import org.apache.ignite.igfs.mapreduce.records.*; - -import java.io.*; -import java.util.*; +import java.io.BufferedReader; +import java.io.File; +import java.io.FileInputStream; +import java.io.IOException; +import java.io.InputStreamReader; +import java.util.Collection; +import java.util.Collections; +import java.util.Comparator; +import java.util.HashSet; +import java.util.List; +import java.util.TreeSet; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.IgniteFileSystem; +import org.apache.ignite.Ignition; +import org.apache.ignite.compute.ComputeJobResult; +import org.apache.ignite.igfs.IgfsOutputStream; +import org.apache.ignite.igfs.IgfsPath; +import org.apache.ignite.igfs.mapreduce.IgfsFileRange; +import org.apache.ignite.igfs.mapreduce.IgfsInputStreamJobAdapter; +import org.apache.ignite.igfs.mapreduce.IgfsJob; +import org.apache.ignite.igfs.mapreduce.IgfsRangeInputStream; +import org.apache.ignite.igfs.mapreduce.IgfsTask; +import org.apache.ignite.igfs.mapreduce.IgfsTaskArgs; +import org.apache.ignite.igfs.mapreduce.records.IgfsNewLineRecordResolver; /** * Example that shows how to use {@link org.apache.ignite.igfs.mapreduce.IgfsTask} to find lines matching particular pattern in the file in pretty @@ -249,4 +266,4 @@ public class IgfsMapReduceExample { return line; } } -} +} \ 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/igfs/IgfsNodeStartup.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/igfs/IgfsNodeStartup.java b/examples/src/main/java/org/apache/ignite/examples/igfs/IgfsNodeStartup.java index 20ddcbd..ac3e4e3 100644 --- a/examples/src/main/java/org/apache/ignite/examples/igfs/IgfsNodeStartup.java +++ b/examples/src/main/java/org/apache/ignite/examples/igfs/IgfsNodeStartup.java @@ -17,7 +17,8 @@ package org.apache.ignite.examples.igfs; -import org.apache.ignite.*; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; /** * Starts up an empty node with IGFS configuration. @@ -38,4 +39,4 @@ public class IgfsNodeStartup { public static void main(String[] args) throws IgniteException { Ignition.start("examples/config/filesystem/example-igfs.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/igfs/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/igfs/package-info.java b/examples/src/main/java/org/apache/ignite/examples/igfs/package-info.java index 6a48c2c..0fbb5f7 100644 --- a/examples/src/main/java/org/apache/ignite/examples/igfs/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/igfs/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Demonstrates usage of Ignite File System. */ -package org.apache.ignite.examples.igfs; +package org.apache.ignite.examples.igfs; \ 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/messaging/MessagingExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingExample.java b/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingExample.java index a8a06fb..8f37d59 100644 --- a/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingExample.java @@ -17,14 +17,17 @@ package org.apache.ignite.examples.messaging; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.resources.*; - -import java.util.*; -import java.util.concurrent.*; +import java.util.UUID; +import java.util.concurrent.CountDownLatch; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.IgniteMessaging; +import org.apache.ignite.Ignition; +import org.apache.ignite.cluster.ClusterGroup; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; +import org.apache.ignite.lang.IgniteBiPredicate; +import org.apache.ignite.resources.IgniteInstanceResource; /** * Example that demonstrates how to exchange messages between nodes. Use such @@ -170,4 +173,4 @@ public final class MessagingExample { } }); } -} +} \ 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/messaging/MessagingPingPongExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongExample.java b/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongExample.java index e4a0159..eca4a2c 100644 --- a/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongExample.java @@ -17,13 +17,15 @@ package org.apache.ignite.examples.messaging; -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.concurrent.*; +import java.util.UUID; +import java.util.concurrent.CountDownLatch; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.cluster.ClusterGroup; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; +import org.apache.ignite.lang.IgniteBiPredicate; /** * Demonstrates simple message exchange between local and remote nodes. @@ -114,4 +116,4 @@ public class MessagingPingPongExample { } } } -} +} \ 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/messaging/MessagingPingPongListenActorExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongListenActorExample.java b/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongListenActorExample.java index 79a64ec..cf976aa 100644 --- a/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongListenActorExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/messaging/MessagingPingPongListenActorExample.java @@ -17,13 +17,17 @@ package org.apache.ignite.examples.messaging; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.messaging.*; - -import java.util.*; -import java.util.concurrent.*; +import java.util.Collection; +import java.util.UUID; +import java.util.concurrent.CountDownLatch; +import org.apache.ignite.Ignite; +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.messaging.MessagingListenActor; /** * Demonstrates messaging with {@link MessagingListenActor} convenience adapter. @@ -103,4 +107,4 @@ public class MessagingPingPongListenActorExample { } } } -} +} \ 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/messaging/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/messaging/package-info.java b/examples/src/main/java/org/apache/ignite/examples/messaging/package-info.java index c1a6244..b22287c 100644 --- a/examples/src/main/java/org/apache/ignite/examples/messaging/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/messaging/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Demonstrates how to exchange messages between nodes. */ -package org.apache.ignite.examples.messaging; +package org.apache.ignite.examples.messaging; \ 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/misc/client/memcache/MemcacheRestExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/misc/client/memcache/MemcacheRestExample.java b/examples/src/main/java/org/apache/ignite/examples/misc/client/memcache/MemcacheRestExample.java index a15afd7..eb0e2d4 100644 --- a/examples/src/main/java/org/apache/ignite/examples/misc/client/memcache/MemcacheRestExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/misc/client/memcache/MemcacheRestExample.java @@ -17,12 +17,15 @@ package org.apache.ignite.examples.misc.client.memcache; -import net.spy.memcached.*; -import org.apache.ignite.*; - -import java.io.*; -import java.net.*; -import java.util.*; +import java.io.IOException; +import java.net.InetSocketAddress; +import java.util.Arrays; +import net.spy.memcached.BinaryConnectionFactory; +import net.spy.memcached.MemcachedClient; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteAtomicLong; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.Ignition; /** * This example shows how to use Memcache client for manipulating Ignite cache. @@ -122,4 +125,4 @@ public class MemcacheRestExample { return new MemcachedClient(new BinaryConnectionFactory(), Arrays.asList(new InetSocketAddress(host, port))); } -} +} \ 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/misc/client/memcache/MemcacheRestExampleNodeStartup.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/misc/client/memcache/MemcacheRestExampleNodeStartup.java b/examples/src/main/java/org/apache/ignite/examples/misc/client/memcache/MemcacheRestExampleNodeStartup.java index 1c79b64..3c835be 100644 --- a/examples/src/main/java/org/apache/ignite/examples/misc/client/memcache/MemcacheRestExampleNodeStartup.java +++ b/examples/src/main/java/org/apache/ignite/examples/misc/client/memcache/MemcacheRestExampleNodeStartup.java @@ -17,18 +17,20 @@ package org.apache.ignite.examples.misc.client.memcache; -import org.apache.ignite.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.marshaller.optimized.*; -import org.apache.ignite.spi.discovery.tcp.*; -import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.*; - -import java.util.*; - -import static org.apache.ignite.cache.CacheAtomicityMode.*; -import static org.apache.ignite.cache.CacheRebalanceMode.*; -import static org.apache.ignite.cache.CacheWriteSynchronizationMode.*; -import static org.apache.ignite.configuration.DeploymentMode.*; +import java.util.Collections; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.configuration.ConnectorConfiguration; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.marshaller.optimized.OptimizedMarshaller; +import org.apache.ignite.spi.discovery.tcp.TcpDiscoverySpi; +import org.apache.ignite.spi.discovery.tcp.ipfinder.vm.TcpDiscoveryVmIpFinder; + +import static org.apache.ignite.cache.CacheAtomicityMode.TRANSACTIONAL; +import static org.apache.ignite.cache.CacheRebalanceMode.SYNC; +import static org.apache.ignite.cache.CacheWriteSynchronizationMode.FULL_SYNC; +import static org.apache.ignite.configuration.DeploymentMode.SHARED; /** * Starts up an empty node with cache configuration that contains default cache. @@ -89,4 +91,4 @@ public class MemcacheRestExampleNodeStartup { 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/misc/client/memcache/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/misc/client/memcache/package-info.java b/examples/src/main/java/org/apache/ignite/examples/misc/client/memcache/package-info.java index b3e7c9d..67bbce2 100644 --- a/examples/src/main/java/org/apache/ignite/examples/misc/client/memcache/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/misc/client/memcache/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Demonstrates Java Client usage with Memcache protocol. */ -package org.apache.ignite.examples.misc.client.memcache; +package org.apache.ignite.examples.misc.client.memcache; \ 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/misc/client/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/misc/client/package-info.java b/examples/src/main/java/org/apache/ignite/examples/misc/client/package-info.java index e0c62e8..efbca4e 100644 --- a/examples/src/main/java/org/apache/ignite/examples/misc/client/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/misc/client/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Demonstrates Java Client usage. */ -package org.apache.ignite.examples.misc.client; +package org.apache.ignite.examples.misc.client; \ 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/misc/deployment/DeploymentExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/misc/deployment/DeploymentExample.java b/examples/src/main/java/org/apache/ignite/examples/misc/deployment/DeploymentExample.java index 5336620..9497ed7 100644 --- a/examples/src/main/java/org/apache/ignite/examples/misc/deployment/DeploymentExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/misc/deployment/DeploymentExample.java @@ -17,13 +17,22 @@ package org.apache.ignite.examples.misc.deployment; -import org.apache.ignite.*; -import org.apache.ignite.compute.*; -import org.apache.ignite.examples.*; -import org.jetbrains.annotations.*; - -import java.io.*; -import java.util.*; +import java.io.Serializable; +import java.util.ArrayList; +import java.util.Collection; +import java.util.List; +import java.util.Map; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCompute; +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.ComputeTask; +import org.apache.ignite.compute.ComputeTaskName; +import org.apache.ignite.compute.ComputeTaskSplitAdapter; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.jetbrains.annotations.Nullable; /** * Demonstrates how to explicitly deploy a task. Note that @@ -126,4 +135,4 @@ public final class DeploymentExample { return 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/misc/deployment/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/misc/deployment/package-info.java b/examples/src/main/java/org/apache/ignite/examples/misc/deployment/package-info.java index 20be358..44b0f79 100644 --- a/examples/src/main/java/org/apache/ignite/examples/misc/deployment/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/misc/deployment/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Deployment examples for direct deployments. */ -package org.apache.ignite.examples.misc.deployment; +package org.apache.ignite.examples.misc.deployment; \ 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/misc/lifecycle/LifecycleExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/misc/lifecycle/LifecycleExample.java b/examples/src/main/java/org/apache/ignite/examples/misc/lifecycle/LifecycleExample.java index 497872a..c603bbf 100644 --- a/examples/src/main/java/org/apache/ignite/examples/misc/lifecycle/LifecycleExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/misc/lifecycle/LifecycleExample.java @@ -17,12 +17,16 @@ package org.apache.ignite.examples.misc.lifecycle; -import org.apache.ignite.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.lifecycle.*; -import org.apache.ignite.resources.*; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.configuration.IgniteConfiguration; +import org.apache.ignite.lifecycle.LifecycleBean; +import org.apache.ignite.lifecycle.LifecycleEventType; +import org.apache.ignite.resources.IgniteInstanceResource; -import static org.apache.ignite.lifecycle.LifecycleEventType.*; +import static org.apache.ignite.lifecycle.LifecycleEventType.AFTER_NODE_START; +import static org.apache.ignite.lifecycle.LifecycleEventType.AFTER_NODE_STOP; /** * This example shows how to provide your own {@link LifecycleBean} implementation @@ -89,4 +93,4 @@ public final class LifecycleExample { return isStarted; } } -} +} \ 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/misc/lifecycle/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/misc/lifecycle/package-info.java b/examples/src/main/java/org/apache/ignite/examples/misc/lifecycle/package-info.java index 2feda25..f830165 100644 --- a/examples/src/main/java/org/apache/ignite/examples/misc/lifecycle/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/misc/lifecycle/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Demonstrates how to write and use lifecycle beans. */ -package org.apache.ignite.examples.misc.lifecycle; +package org.apache.ignite.examples.misc.lifecycle; \ 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/misc/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/misc/package-info.java b/examples/src/main/java/org/apache/ignite/examples/misc/package-info.java index c103603..616f24f 100644 --- a/examples/src/main/java/org/apache/ignite/examples/misc/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/misc/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Contains examples taht are common across all editions. */ -package org.apache.ignite.examples.misc; +package org.apache.ignite.examples.misc; \ 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/misc/schedule/ComputeScheduleExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/misc/schedule/ComputeScheduleExample.java b/examples/src/main/java/org/apache/ignite/examples/misc/schedule/ComputeScheduleExample.java index f92285b..f8d0660 100644 --- a/examples/src/main/java/org/apache/ignite/examples/misc/schedule/ComputeScheduleExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/misc/schedule/ComputeScheduleExample.java @@ -17,12 +17,13 @@ package org.apache.ignite.examples.misc.schedule; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.scheduler.*; - -import java.util.concurrent.*; +import java.util.concurrent.Callable; +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.IgniteRunnable; +import org.apache.ignite.scheduler.SchedulerFuture; /** * Demonstrates a cron-based {@link Runnable} execution scheduling. @@ -78,4 +79,4 @@ public class ComputeScheduleExample { System.out.println(">>> Check all nodes for hello message output."); } } -} +} \ 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/misc/schedule/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/misc/schedule/package-info.java b/examples/src/main/java/org/apache/ignite/examples/misc/schedule/package-info.java index 5888bc2..6602a6e 100644 --- a/examples/src/main/java/org/apache/ignite/examples/misc/schedule/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/misc/schedule/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Demonstrates usage of cron-based scheduler. */ -package org.apache.ignite.examples.misc.schedule; +package org.apache.ignite.examples.misc.schedule; \ 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/misc/springbean/SpringBeanExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/misc/springbean/SpringBeanExample.java b/examples/src/main/java/org/apache/ignite/examples/misc/springbean/SpringBeanExample.java index 69c84f4..0b9d213 100644 --- a/examples/src/main/java/org/apache/ignite/examples/misc/springbean/SpringBeanExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/misc/springbean/SpringBeanExample.java @@ -17,11 +17,12 @@ package org.apache.ignite.examples.misc.springbean; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.springframework.context.support.*; - -import java.util.concurrent.*; +import java.util.concurrent.Callable; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.Future; +import org.apache.ignite.Ignite; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.springframework.context.support.ClassPathXmlApplicationContext; /** * Demonstrates a simple use of Ignite configured with Spring. @@ -85,4 +86,4 @@ public final class SpringBeanExample { ctx.destroy(); } } -} +} \ 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/misc/springbean/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/misc/springbean/package-info.java b/examples/src/main/java/org/apache/ignite/examples/misc/springbean/package-info.java index 6f77b2e..42e83bb 100644 --- a/examples/src/main/java/org/apache/ignite/examples/misc/springbean/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/misc/springbean/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * HelloWorld example that accesses ignite started directly from Spring bean. */ -package org.apache.ignite.examples.misc.springbean; +package org.apache.ignite.examples.misc.springbean; \ 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/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/package-info.java b/examples/src/main/java/org/apache/ignite/examples/package-info.java index ab184d8..5825225 100644 --- a/examples/src/main/java/org/apache/ignite/examples/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Basic examples for ignite functionality. */ -package org.apache.ignite.examples; +package org.apache.ignite.examples; \ 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/servicegrid/ServicesExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/servicegrid/ServicesExample.java b/examples/src/main/java/org/apache/ignite/examples/servicegrid/ServicesExample.java index ec8e54e..5fc85a4 100644 --- a/examples/src/main/java/org/apache/ignite/examples/servicegrid/ServicesExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/servicegrid/ServicesExample.java @@ -17,12 +17,14 @@ package org.apache.ignite.examples.servicegrid; -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.IgniteServices; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; +import org.apache.ignite.lang.IgniteCallable; +import org.apache.ignite.resources.ServiceResource; /** * Example that demonstrates how to deploy distributed services in Ignite. @@ -166,4 +168,4 @@ public class ServicesExample { return mapSize; } } -} +} \ 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/servicegrid/SimpleMapService.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/servicegrid/SimpleMapService.java b/examples/src/main/java/org/apache/ignite/examples/servicegrid/SimpleMapService.java index 5e32bd2..8f2d31a 100644 --- a/examples/src/main/java/org/apache/ignite/examples/servicegrid/SimpleMapService.java +++ b/examples/src/main/java/org/apache/ignite/examples/servicegrid/SimpleMapService.java @@ -46,4 +46,4 @@ public interface SimpleMapService<K, V> { * @return Map size. */ int size(); -} +} \ 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/servicegrid/SimpleMapServiceImpl.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/servicegrid/SimpleMapServiceImpl.java b/examples/src/main/java/org/apache/ignite/examples/servicegrid/SimpleMapServiceImpl.java index 38db88b..69668d2 100644 --- a/examples/src/main/java/org/apache/ignite/examples/servicegrid/SimpleMapServiceImpl.java +++ b/examples/src/main/java/org/apache/ignite/examples/servicegrid/SimpleMapServiceImpl.java @@ -17,10 +17,12 @@ package org.apache.ignite.examples.servicegrid; -import org.apache.ignite.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.resources.*; -import org.apache.ignite.services.*; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.resources.IgniteInstanceResource; +import org.apache.ignite.services.Service; +import org.apache.ignite.services.ServiceContext; /** * Simple service which utilizes Ignite cache as a mechanism to provide @@ -78,4 +80,4 @@ public class SimpleMapServiceImpl<K, V> implements Service, SimpleMapService<K, @Override public void execute(ServiceContext ctx) throws Exception { System.out.println("Executing distributed service: " + ctx.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/servicegrid/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/servicegrid/package-info.java b/examples/src/main/java/org/apache/ignite/examples/servicegrid/package-info.java index 5873209..576df4e 100644 --- a/examples/src/main/java/org/apache/ignite/examples/servicegrid/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/servicegrid/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Demonstrates usage of grid-managed services. */ -package org.apache.ignite.examples.servicegrid; +package org.apache.ignite.examples.servicegrid; \ 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/streaming/StreamTransformerExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/streaming/StreamTransformerExample.java b/examples/src/main/java/org/apache/ignite/examples/streaming/StreamTransformerExample.java index 966fce2..2ef5e70 100644 --- a/examples/src/main/java/org/apache/ignite/examples/streaming/StreamTransformerExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/streaming/StreamTransformerExample.java @@ -17,14 +17,18 @@ package org.apache.ignite.examples.streaming; -import org.apache.ignite.*; -import org.apache.ignite.cache.query.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.stream.*; - -import javax.cache.processor.*; -import java.util.*; +import java.util.List; +import java.util.Random; +import javax.cache.processor.MutableEntry; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteDataStreamer; +import org.apache.ignite.Ignition; +import org.apache.ignite.cache.query.SqlFieldsQuery; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; +import org.apache.ignite.stream.StreamTransformer; /** * Stream random numbers into the streaming cache. @@ -95,4 +99,4 @@ public class StreamTransformerExample { } } } -} +} \ 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/streaming/StreamVisitorExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/streaming/StreamVisitorExample.java b/examples/src/main/java/org/apache/ignite/examples/streaming/StreamVisitorExample.java index baae5af..f2e1e9f 100644 --- a/examples/src/main/java/org/apache/ignite/examples/streaming/StreamVisitorExample.java +++ b/examples/src/main/java/org/apache/ignite/examples/streaming/StreamVisitorExample.java @@ -17,15 +17,20 @@ package org.apache.ignite.examples.streaming; -import org.apache.ignite.*; -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.stream.*; - -import java.io.*; -import java.util.*; +import java.io.Serializable; +import java.util.List; +import java.util.Map; +import java.util.Random; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteDataStreamer; +import org.apache.ignite.Ignition; +import org.apache.ignite.cache.query.SqlFieldsQuery; +import org.apache.ignite.cache.query.annotations.QuerySqlField; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; +import org.apache.ignite.stream.StreamVisitor; /** * Stream random numbers into the streaming cache. @@ -163,4 +168,4 @@ public class StreamVisitorExample { this.latest = price; } } -} +} \ 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/streaming/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/streaming/package-info.java b/examples/src/main/java/org/apache/ignite/examples/streaming/package-info.java index 43fbab3..7cd31d1 100644 --- a/examples/src/main/java/org/apache/ignite/examples/streaming/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/streaming/package-info.java @@ -18,4 +18,4 @@ /** * Demonstrates usage of data streamer. */ -package org.apache.ignite.examples.streaming; +package org.apache.ignite.examples.streaming; \ 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/streaming/wordcount/CacheConfig.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/CacheConfig.java b/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/CacheConfig.java index d17b97d..4de9d90 100644 --- a/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/CacheConfig.java +++ b/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/CacheConfig.java @@ -17,13 +17,13 @@ package org.apache.ignite.examples.streaming.wordcount; -import org.apache.ignite.cache.affinity.*; -import org.apache.ignite.configuration.*; +import javax.cache.configuration.FactoryBuilder; +import javax.cache.expiry.CreatedExpiryPolicy; +import javax.cache.expiry.Duration; +import org.apache.ignite.cache.affinity.AffinityUuid; +import org.apache.ignite.configuration.CacheConfiguration; -import javax.cache.configuration.*; -import javax.cache.expiry.*; - -import static java.util.concurrent.TimeUnit.*; +import static java.util.concurrent.TimeUnit.SECONDS; /** * Configuration for the streaming cache to store the stream of words. @@ -45,4 +45,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/streaming/wordcount/QueryWords.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/QueryWords.java b/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/QueryWords.java index 58c6ef2..034c0c2 100644 --- a/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/QueryWords.java +++ b/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/QueryWords.java @@ -17,12 +17,14 @@ package org.apache.ignite.examples.streaming.wordcount; -import org.apache.ignite.*; -import org.apache.ignite.cache.affinity.*; -import org.apache.ignite.cache.query.*; -import org.apache.ignite.examples.*; - -import java.util.*; +import java.util.List; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.Ignition; +import org.apache.ignite.cache.affinity.AffinityUuid; +import org.apache.ignite.cache.query.SqlFieldsQuery; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; /** * Periodically query popular numbers from the streaming cache. @@ -80,4 +82,4 @@ public class QueryWords { } } } -} +} \ 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/streaming/wordcount/StreamWords.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/StreamWords.java b/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/StreamWords.java index 6024c4b..98b865e 100644 --- a/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/StreamWords.java +++ b/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/StreamWords.java @@ -17,11 +17,16 @@ package org.apache.ignite.examples.streaming.wordcount; -import org.apache.ignite.*; -import org.apache.ignite.cache.affinity.*; -import org.apache.ignite.examples.*; - -import java.io.*; +import java.io.InputStream; +import java.io.InputStreamReader; +import java.io.LineNumberReader; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteCache; +import org.apache.ignite.IgniteDataStreamer; +import org.apache.ignite.Ignition; +import org.apache.ignite.cache.affinity.AffinityUuid; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; /** * Stream words into Ignite cache. @@ -69,4 +74,4 @@ public class StreamWords { } } } -} +} \ 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/streaming/wordcount/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/package-info.java b/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/package-info.java index 5d48ae3..a635f9f 100644 --- a/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/package-info.java @@ -18,4 +18,4 @@ /** * Streaming word count example. */ -package org.apache.ignite.examples.streaming.wordcount; +package org.apache.ignite.examples.streaming.wordcount; \ 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/streaming/wordcount/socket/WordsSocketStreamerClient.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/socket/WordsSocketStreamerClient.java b/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/socket/WordsSocketStreamerClient.java index c4d7b8c..19830e0 100644 --- a/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/socket/WordsSocketStreamerClient.java +++ b/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/socket/WordsSocketStreamerClient.java @@ -17,12 +17,17 @@ package org.apache.ignite.examples.streaming.wordcount.socket; -import org.apache.ignite.examples.*; -import org.apache.ignite.examples.streaming.wordcount.*; -import org.apache.ignite.stream.socket.*; - -import java.io.*; -import java.net.*; +import java.io.BufferedOutputStream; +import java.io.IOException; +import java.io.InputStream; +import java.io.InputStreamReader; +import java.io.LineNumberReader; +import java.io.OutputStream; +import java.net.InetAddress; +import java.net.Socket; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.streaming.wordcount.QueryWords; +import org.apache.ignite.stream.socket.SocketStreamer; /** * Example demonstrates streaming of data from external components into Ignite cache. @@ -79,4 +84,4 @@ public class WordsSocketStreamerClient { } } } -} +} \ 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/streaming/wordcount/socket/WordsSocketStreamerServer.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/socket/WordsSocketStreamerServer.java b/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/socket/WordsSocketStreamerServer.java index 9e68096..8e961b9 100644 --- a/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/socket/WordsSocketStreamerServer.java +++ b/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/socket/WordsSocketStreamerServer.java @@ -17,17 +17,23 @@ package org.apache.ignite.examples.streaming.wordcount.socket; -import org.apache.ignite.*; -import org.apache.ignite.cache.affinity.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.examples.streaming.wordcount.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.stream.*; -import org.apache.ignite.stream.socket.*; - -import java.io.*; -import java.net.*; -import java.util.*; +import java.io.UnsupportedEncodingException; +import java.net.InetAddress; +import java.util.Map; +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.cache.affinity.AffinityUuid; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; +import org.apache.ignite.examples.streaming.wordcount.CacheConfig; +import org.apache.ignite.examples.streaming.wordcount.QueryWords; +import org.apache.ignite.lang.IgniteBiTuple; +import org.apache.ignite.stream.StreamTupleExtractor; +import org.apache.ignite.stream.socket.SocketMessageConverter; +import org.apache.ignite.stream.socket.SocketStreamer; /** * Example demonstrates streaming of data from external components into Ignite cache. @@ -121,4 +127,4 @@ public class WordsSocketStreamerServer { ignite.close(); } } -} +} \ 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/streaming/wordcount/socket/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/socket/package-info.java b/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/socket/package-info.java index 048299f..04e1b49 100644 --- a/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/socket/package-info.java +++ b/examples/src/main/java/org/apache/ignite/examples/streaming/wordcount/socket/package-info.java @@ -18,4 +18,4 @@ /** * Contains {@link org.apache.ignite.stream.socket.SocketStreamer} usage examples. */ -package org.apache.ignite.examples.streaming.wordcount.socket; +package org.apache.ignite.examples.streaming.wordcount.socket; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java8/org/apache/ignite/examples/java8/cluster/ClusterGroupExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/cluster/ClusterGroupExample.java b/examples/src/main/java8/org/apache/ignite/examples/java8/cluster/ClusterGroupExample.java index 508caf2..751032b 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/cluster/ClusterGroupExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/cluster/ClusterGroupExample.java @@ -17,9 +17,13 @@ package org.apache.ignite.examples.java8.cluster; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.examples.*; +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.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; /** * Demonstrates new functional APIs. @@ -79,4 +83,4 @@ public class ClusterGroupExample { ignite.compute(grp).broadcast( () -> System.out.println(">>> Hello Node: " + grp.ignite().cluster().localNode().id())); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java8/org/apache/ignite/examples/java8/cluster/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/cluster/package-info.java b/examples/src/main/java8/org/apache/ignite/examples/java8/cluster/package-info.java index 2cca35f..618e844 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/cluster/package-info.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/cluster/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Cluster group example. */ -package org.apache.ignite.examples.java8.cluster; +package org.apache.ignite.examples.java8.cluster; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeAsyncExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeAsyncExample.java b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeAsyncExample.java index b6922b8..77d1ac2 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeAsyncExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeAsyncExample.java @@ -17,11 +17,15 @@ package org.apache.ignite.examples.java8.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}. @@ -68,4 +72,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/java8/org/apache/ignite/examples/java8/computegrid/ComputeBroadcastExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeBroadcastExample.java b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeBroadcastExample.java index ded14b4..f839911 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeBroadcastExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeBroadcastExample.java @@ -17,10 +17,11 @@ package org.apache.ignite.examples.java8.computegrid; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; - -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; /** * Demonstrates broadcasting computations within cluster. @@ -98,4 +99,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/java8/org/apache/ignite/examples/java8/computegrid/ComputeCallableExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeCallableExample.java b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeCallableExample.java index d15f564..2cbece8 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeCallableExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeCallableExample.java @@ -17,11 +17,13 @@ package org.apache.ignite.examples.java8.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. @@ -70,4 +72,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/java8/org/apache/ignite/examples/java8/computegrid/ComputeClosureExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeClosureExample.java b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeClosureExample.java index de22687..fc7564f 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeClosureExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeClosureExample.java @@ -17,10 +17,12 @@ package org.apache.ignite.examples.java8.computegrid; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; - -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; /** * Demonstrates a simple use of Ignite with reduce closure. @@ -66,4 +68,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/java8/org/apache/ignite/examples/java8/computegrid/ComputeRunnableExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeRunnableExample.java b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeRunnableExample.java index 474ae20..4dc7c5f 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeRunnableExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/ComputeRunnableExample.java @@ -17,11 +17,12 @@ package org.apache.ignite.examples.java8.computegrid; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import java.util.*; +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 +61,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/java8/org/apache/ignite/examples/java8/computegrid/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/package-info.java b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/package-info.java index 7c88fc1..a293faa 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/package-info.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/computegrid/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Basic examples for computational ignite functionality. */ -package org.apache.ignite.examples.java8.computegrid; +package org.apache.ignite.examples.java8.computegrid; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/CacheAffinityExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/CacheAffinityExample.java b/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/CacheAffinityExample.java index 0424457..aa1fc25 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/CacheAffinityExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/CacheAffinityExample.java @@ -17,15 +17,6 @@ package org.apache.ignite.examples.java8.datagrid; -import org.apache.ignite.*; -import org.apache.ignite.cache.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import java.util.*; - /** * This example demonstrates the simplest code that populates the distributed cache * and co-locates simple closure execution with each key. The goal of this particular @@ -128,4 +119,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/java8/org/apache/ignite/examples/java8/datagrid/CacheApiExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/CacheApiExample.java b/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/CacheApiExample.java index f0cb2ac..98f37c7 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/CacheApiExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/CacheApiExample.java @@ -17,12 +17,14 @@ package org.apache.ignite.examples.java8.datagrid; -import org.apache.ignite.*; -import org.apache.ignite.cache.*; -import org.apache.ignite.configuration.*; -import org.apache.ignite.examples.*; - -import java.util.concurrent.*; +import java.util.concurrent.ConcurrentMap; +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.configuration.CacheConfiguration; +import org.apache.ignite.examples.ExampleNodeStartup; /** * This example demonstrates some of the cache rich API capabilities. @@ -100,4 +102,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/java8/org/apache/ignite/examples/java8/datagrid/CacheAsyncApiExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/CacheAsyncApiExample.java b/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/CacheAsyncApiExample.java index 0a95169..1313181 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/CacheAsyncApiExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/CacheAsyncApiExample.java @@ -17,13 +17,16 @@ package org.apache.ignite.examples.java8.datagrid; -import org.apache.ignite.*; -import org.apache.ignite.cache.*; -import org.apache.ignite.configuration.*; -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.cache.CacheMode; +import org.apache.ignite.configuration.CacheConfiguration; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteFuture; /** * This example demonstrates some of the cache rich API capabilities. @@ -79,4 +82,4 @@ public class CacheAsyncApiExample { } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/package-info.java b/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/package-info.java index 2730f26..d8c45d6 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/package-info.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/datagrid/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Demonstrates data ignite cache usage. */ -package org.apache.ignite.examples.java8.datagrid; +package org.apache.ignite.examples.java8.datagrid; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java8/org/apache/ignite/examples/java8/datastructures/IgniteExecutorServiceExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/datastructures/IgniteExecutorServiceExample.java b/examples/src/main/java8/org/apache/ignite/examples/java8/datastructures/IgniteExecutorServiceExample.java index 2526f60..a0c9701 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/datastructures/IgniteExecutorServiceExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/datastructures/IgniteExecutorServiceExample.java @@ -17,11 +17,12 @@ package org.apache.ignite.examples.java8.datastructures; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; - -import java.util.concurrent.*; +import java.util.concurrent.ExecutorService; +import java.util.concurrent.TimeUnit; +import org.apache.ignite.Ignite; +import org.apache.ignite.Ignition; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteRunnable; /** * Simple example to demonstrate usage of distributed executor service provided by Ignite. @@ -66,4 +67,4 @@ public final class IgniteExecutorServiceExample { 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/java8/org/apache/ignite/examples/java8/datastructures/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/datastructures/package-info.java b/examples/src/main/java8/org/apache/ignite/examples/java8/datastructures/package-info.java index baa5769..79b2f9a 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/datastructures/package-info.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/datastructures/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Demonstrates using of blocking and non-blocking queues and atomic data structures. */ -package org.apache.ignite.examples.java8.datastructures; +package org.apache.ignite.examples.java8.datastructures; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java8/org/apache/ignite/examples/java8/events/EventsExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/events/EventsExample.java b/examples/src/main/java8/org/apache/ignite/examples/java8/events/EventsExample.java index d1c32a3..83a39ec 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/events/EventsExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/events/EventsExample.java @@ -17,16 +17,19 @@ package org.apache.ignite.examples.java8.events; -import org.apache.ignite.*; -import org.apache.ignite.compute.*; -import org.apache.ignite.events.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.lang.*; -import org.apache.ignite.resources.*; - -import java.util.*; - -import static org.apache.ignite.events.EventType.*; +import java.util.UUID; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.compute.ComputeTaskSession; +import org.apache.ignite.events.TaskEvent; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.lang.IgniteBiPredicate; +import org.apache.ignite.lang.IgnitePredicate; +import org.apache.ignite.lang.IgniteRunnable; +import org.apache.ignite.resources.TaskSessionResource; + +import static org.apache.ignite.events.EventType.EVTS_TASK_EXECUTION; /** * Demonstrates event consume API that allows to register event listeners on remote nodes. @@ -129,4 +132,4 @@ public class EventsExample { }); } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java8/org/apache/ignite/examples/java8/events/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/events/package-info.java b/examples/src/main/java8/org/apache/ignite/examples/java8/events/package-info.java index f31a4c6..2fadf17 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/events/package-info.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/events/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Demonstrates events management API. */ -package org.apache.ignite.examples.java8.events; +package org.apache.ignite.examples.java8.events; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/MessagingExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/MessagingExample.java b/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/MessagingExample.java index f992a82..f8f9242 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/MessagingExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/MessagingExample.java @@ -17,12 +17,6 @@ package org.apache.ignite.examples.java8.messaging; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.examples.*; - -import java.util.concurrent.*; - /** * Example that demonstrates how to exchange messages between nodes. Use such * functionality for cases when you need to communicate to other nodes outside @@ -160,4 +154,4 @@ public final class MessagingExample { return unorderedLatch.getCount() > 0; }); } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/MessagingPingPongExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/MessagingPingPongExample.java b/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/MessagingPingPongExample.java index 8285956..9962748 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/MessagingPingPongExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/MessagingPingPongExample.java @@ -17,11 +17,13 @@ package org.apache.ignite.examples.java8.messaging; -import org.apache.ignite.*; -import org.apache.ignite.cluster.*; -import org.apache.ignite.examples.*; - -import java.util.concurrent.*; +import java.util.concurrent.CountDownLatch; +import org.apache.ignite.Ignite; +import org.apache.ignite.IgniteException; +import org.apache.ignite.Ignition; +import org.apache.ignite.cluster.ClusterGroup; +import org.apache.ignite.examples.ExampleNodeStartup; +import org.apache.ignite.examples.ExamplesUtils; /** * Demonstrates simple message exchange between local and remote nodes. @@ -108,4 +110,4 @@ public class MessagingPingPongExample { } } } -} +} \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/package-info.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/package-info.java b/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/package-info.java index 0b03ea7..c950225 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/package-info.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/messaging/package-info.java @@ -19,4 +19,4 @@ * <!-- Package description. --> * Demonstrates how to exchange messages between nodes. */ -package org.apache.ignite.examples.java8.messaging; +package org.apache.ignite.examples.java8.messaging; \ No newline at end of file http://git-wip-us.apache.org/repos/asf/ignite/blob/90e9555c/examples/src/main/java8/org/apache/ignite/examples/java8/misc/schedule/ComputeScheduleExample.java ---------------------------------------------------------------------- diff --git a/examples/src/main/java8/org/apache/ignite/examples/java8/misc/schedule/ComputeScheduleExample.java b/examples/src/main/java8/org/apache/ignite/examples/java8/misc/schedule/ComputeScheduleExample.java index 64e4e2d..c250638 100644 --- a/examples/src/main/java8/org/apache/ignite/examples/java8/misc/schedule/ComputeScheduleExample.java +++ b/examples/src/main/java8/org/apache/ignite/examples/java8/misc/schedule/ComputeScheduleExample.java @@ -17,9 +17,11 @@ package org.apache.ignite.examples.java8.misc.schedule; -import org.apache.ignite.*; -import org.apache.ignite.examples.*; -import org.apache.ignite.scheduler.*; +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.scheduler.SchedulerFuture; /** * Demonstrates a cron-based {@link Runnable} execution scheduling. @@ -63,4 +65,4 @@ public class ComputeScheduleExample { System.out.println(">>> Check all nodes for hello message output."); } } -} +} \ No newline at end of file
