http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java b/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java index 7b1a91d..8287ced 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteCluster.java @@ -111,10 +111,10 @@ public interface IgniteCluster extends ClusterGroup, IgniteAsyncSupport { * @param cacheName Cache name, if {@code null}, then default cache instance is used. * @param keys Cache keys to map to nodes. * @return Map of nodes to cache keys or empty map if there are no alive nodes for this cache. - * @throws IgniteCheckedException If failed to map cache keys. + * @throws IgniteException If failed to map cache keys. */ public <K> Map<ClusterNode, Collection<K>> mapKeysToNodes(@Nullable String cacheName, - @Nullable Collection<? extends K> keys) throws IgniteCheckedException; + @Nullable Collection<? extends K> keys) throws IgniteException; /** * This method provides ability to detect which cache keys are mapped to which nodes @@ -135,9 +135,9 @@ public interface IgniteCluster extends ClusterGroup, IgniteAsyncSupport { * @param key Cache key to map to a node. * @return Primary node for the key or {@code null} if cache with given name * is not present in the grid. - * @throws IgniteCheckedException If failed to map key. + * @throws IgniteException If failed to map key. */ - @Nullable public <K> ClusterNode mapKeyToNode(@Nullable String cacheName, K key) throws IgniteCheckedException; + @Nullable public <K> ClusterNode mapKeyToNode(@Nullable String cacheName, K key) throws IgniteException; /** * Starts one or more nodes on remote host(s). @@ -164,10 +164,10 @@ public interface IgniteCluster extends ClusterGroup, IgniteAsyncSupport { * @param maxConn Number of parallel SSH connections to one host. * @return Collection of tuples, each containing host name, result (success of failure) * and error message (if any). - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. */ public Collection<GridTuple3<String, Boolean, String>> startNodes(File file, boolean restart, - int timeout, int maxConn) throws IgniteCheckedException; + int timeout, int maxConn) throws IgniteException; /** * Starts one or more nodes on remote host(s). @@ -265,10 +265,10 @@ public interface IgniteCluster extends ClusterGroup, IgniteAsyncSupport { * @param maxConn Number of parallel SSH connections to one host. * @return Collection of tuples, each containing host name, result (success of failure) * and error message (if any). - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. */ public Collection<GridTuple3<String, Boolean, String>> startNodes(Collection<Map<String, Object>> hosts, - @Nullable Map<String, Object> dflts, boolean restart, int timeout, int maxConn) throws IgniteCheckedException; + @Nullable Map<String, Object> dflts, boolean restart, int timeout, int maxConn) throws IgniteException; /** * Stops nodes satisfying optional set of predicates. @@ -277,9 +277,9 @@ public interface IgniteCluster extends ClusterGroup, IgniteAsyncSupport { * stopping node. If you have other applications running in the same JVM along with GridGain, * those applications will be stopped as well. * - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. */ - public void stopNodes() throws IgniteCheckedException; + public void stopNodes() throws IgniteException; /** * Stops nodes defined by provided IDs. @@ -289,9 +289,9 @@ public interface IgniteCluster extends ClusterGroup, IgniteAsyncSupport { * those applications will be stopped as well. * * @param ids IDs defining nodes to stop. - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. */ - public void stopNodes(Collection<UUID> ids) throws IgniteCheckedException; + public void stopNodes(Collection<UUID> ids) throws IgniteException; /** * Restarts nodes satisfying optional set of predicates. @@ -299,9 +299,9 @@ public interface IgniteCluster extends ClusterGroup, IgniteAsyncSupport { * <b>NOTE:</b> this command only works for grid nodes started with GridGain * {@code ggstart.sh} or {@code ggstart.bat} scripts. * - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. */ - public void restartNodes() throws IgniteCheckedException; + public void restartNodes() throws IgniteException; /** * Restarts nodes defined by provided IDs. @@ -310,9 +310,9 @@ public interface IgniteCluster extends ClusterGroup, IgniteAsyncSupport { * {@code ggstart.sh} or {@code ggstart.bat} scripts. * * @param ids IDs defining nodes to restart. - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. */ - public void restartNodes(Collection<UUID> ids) throws IgniteCheckedException; + public void restartNodes(Collection<UUID> ids) throws IgniteException; /** * Resets local I/O, job, and task execution metrics.
http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java b/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java index 613a521..e3f6d86 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteCompute.java @@ -114,9 +114,9 @@ public interface IgniteCompute extends IgniteAsyncSupport { * @param job Job which will be co-located on the node with given affinity key. * @see org.apache.ignite.compute.ComputeJobContext#cacheName() * @see org.apache.ignite.compute.ComputeJobContext#affinityKey() - * @throws IgniteCheckedException If job failed. + * @throws IgniteException If job failed. */ - public void affinityRun(@Nullable String cacheName, Object affKey, Runnable job) throws IgniteCheckedException; + public void affinityRun(@Nullable String cacheName, Object affKey, Runnable job) throws IgniteException; /** * Executes given job on the node where data for provided affinity key is located @@ -128,11 +128,11 @@ public interface IgniteCompute extends IgniteAsyncSupport { * @param affKey Affinity key. * @param job Job which will be co-located on the node with given affinity key. * @return Job result. - * @throws IgniteCheckedException If job failed. + * @throws IgniteException If job failed. * @see org.apache.ignite.compute.ComputeJobContext#cacheName() * @see org.apache.ignite.compute.ComputeJobContext#affinityKey() */ - public <R> R affinityCall(@Nullable String cacheName, Object affKey, Callable<R> job) throws IgniteCheckedException; + public <R> R affinityCall(@Nullable String cacheName, Object affKey, Callable<R> job) throws IgniteException; /** * Executes given task on the grid projection. For step-by-step explanation of task execution process @@ -145,9 +145,9 @@ public interface IgniteCompute extends IgniteAsyncSupport { * class name is used as task name. * @param arg Optional argument of task execution, can be {@code null}. * @return Task result. - * @throws IgniteCheckedException If task failed. + * @throws IgniteException If task failed. */ - public <T, R> R execute(Class<? extends ComputeTask<T, R>> taskCls, @Nullable T arg) throws IgniteCheckedException; + public <T, R> R execute(Class<? extends ComputeTask<T, R>> taskCls, @Nullable T arg) throws IgniteException; /** * Executes given task on this grid projection. For step-by-step explanation of task execution process @@ -160,9 +160,9 @@ public interface IgniteCompute extends IgniteAsyncSupport { * class name is used as task name. * @param arg Optional argument of task execution, can be {@code null}. * @return Task result. - * @throws IgniteCheckedException If task failed. + * @throws IgniteException If task failed. */ - public <T, R> R execute(ComputeTask<T, R> task, @Nullable T arg) throws IgniteCheckedException; + public <T, R> R execute(ComputeTask<T, R> task, @Nullable T arg) throws IgniteException; /** * Executes given task on this grid projection. For step-by-step explanation of task execution process @@ -176,10 +176,10 @@ public interface IgniteCompute extends IgniteAsyncSupport { * @param taskName Name of the task to execute. * @param arg Optional argument of task execution, can be {@code null}. * @return Task result. - * @throws IgniteCheckedException If task failed. + * @throws IgniteException If task failed. * @see org.apache.ignite.compute.ComputeTask for information about task execution. */ - public <T, R> R execute(String taskName, @Nullable T arg) throws IgniteCheckedException; + public <T, R> R execute(String taskName, @Nullable T arg) throws IgniteException; /** * Broadcasts given job to all nodes in grid projection. @@ -187,9 +187,9 @@ public interface IgniteCompute extends IgniteAsyncSupport { * Supports asynchronous execution (see {@link IgniteAsyncSupport}). * * @param job Job to broadcast to all projection nodes. - * @throws IgniteCheckedException If job failed. + * @throws IgniteException If job failed. */ - public void broadcast(Runnable job) throws IgniteCheckedException; + public void broadcast(Runnable job) throws IgniteException; /** * Broadcasts given job to all nodes in grid projection. Every participating node will return a @@ -199,9 +199,9 @@ public interface IgniteCompute extends IgniteAsyncSupport { * * @param job Job to broadcast to all projection nodes. * @return Collection of results for this execution. - * @throws IgniteCheckedException If execution failed. + * @throws IgniteException If execution failed. */ - public <R> Collection<R> broadcast(Callable<R> job) throws IgniteCheckedException; + public <R> Collection<R> broadcast(Callable<R> job) throws IgniteException; /** * Broadcasts given closure job with passed in argument to all nodes in grid projection. @@ -213,9 +213,9 @@ public interface IgniteCompute extends IgniteAsyncSupport { * @param job Job to broadcast to all projection nodes. * @param arg Job closure argument. * @return Collection of results for this execution. - * @throws IgniteCheckedException If execution failed. + * @throws IgniteException If execution failed. */ - public <R, T> Collection<R> broadcast(IgniteClosure<T, R> job, @Nullable T arg) throws IgniteCheckedException; + public <R, T> Collection<R> broadcast(IgniteClosure<T, R> job, @Nullable T arg) throws IgniteException; /** * Executes provided job on a node in this grid projection. @@ -223,9 +223,9 @@ public interface IgniteCompute extends IgniteAsyncSupport { * Supports asynchronous execution (see {@link IgniteAsyncSupport}). * * @param job Job closure to execute. - * @throws IgniteCheckedException If execution failed. + * @throws IgniteException If execution failed. */ - public void run(Runnable job) throws IgniteCheckedException; + public void run(Runnable job) throws IgniteException; /** * Executes collection of jobs on grid nodes within this grid projection. @@ -233,9 +233,9 @@ public interface IgniteCompute extends IgniteAsyncSupport { * Supports asynchronous execution (see {@link IgniteAsyncSupport}). * * @param jobs Collection of jobs to execute. - * @throws IgniteCheckedException If execution failed. + * @throws IgniteException If execution failed. */ - public void run(Collection<? extends Runnable> jobs) throws IgniteCheckedException; + public void run(Collection<? extends Runnable> jobs) throws IgniteException; /** * Executes provided job on a node in this grid projection. The result of the @@ -245,9 +245,9 @@ public interface IgniteCompute extends IgniteAsyncSupport { * * @param job Job to execute. * @return Job result. - * @throws IgniteCheckedException If execution failed. + * @throws IgniteException If execution failed. */ - public <R> R call(Callable<R> job) throws IgniteCheckedException; + public <R> R call(Callable<R> job) throws IgniteException; /** * Executes collection of jobs on nodes within this grid projection. @@ -257,9 +257,9 @@ public interface IgniteCompute extends IgniteAsyncSupport { * * @param jobs Collection of jobs to execute. * @return Collection of job results for this execution. - * @throws IgniteCheckedException If execution failed. + * @throws IgniteException If execution failed. */ - public <R> Collection<R> call(Collection<? extends Callable<R>> jobs) throws IgniteCheckedException; + public <R> Collection<R> call(Collection<? extends Callable<R>> jobs) throws IgniteException; /** * Executes collection of jobs on nodes within this grid projection. The returned @@ -270,9 +270,9 @@ public interface IgniteCompute extends IgniteAsyncSupport { * @param jobs Collection of jobs to execute. * @param rdc Reducer to reduce all job results into one individual return value. * @return Future with reduced job result for this execution. - * @throws IgniteCheckedException If execution failed. + * @throws IgniteException If execution failed. */ - public <R1, R2> R2 call(Collection<? extends Callable<R1>> jobs, IgniteReducer<R1, R2> rdc) throws IgniteCheckedException; + public <R1, R2> R2 call(Collection<? extends Callable<R1>> jobs, IgniteReducer<R1, R2> rdc) throws IgniteException; /** * Executes provided closure job on a node in this grid projection. This method is different @@ -284,9 +284,9 @@ public interface IgniteCompute extends IgniteAsyncSupport { * @param job Job to run. * @param arg Job argument. * @return Job result. - * @throws IgniteCheckedException If execution failed. + * @throws IgniteException If execution failed. */ - public <R, T> R apply(IgniteClosure<T, R> job, @Nullable T arg) throws IgniteCheckedException; + public <R, T> R apply(IgniteClosure<T, R> job, @Nullable T arg) throws IgniteException; /** * Executes provided closure job on nodes within this grid projection. A new job is executed for @@ -298,9 +298,9 @@ public interface IgniteCompute extends IgniteAsyncSupport { * @param job Job to run. * @param args Job arguments. * @return Collection of job results. - * @throws IgniteCheckedException If execution failed. + * @throws IgniteException If execution failed. */ - public <T, R> Collection<R> apply(IgniteClosure<T, R> job, Collection<? extends T> args) throws IgniteCheckedException; + public <T, R> Collection<R> apply(IgniteClosure<T, R> job, Collection<? extends T> args) throws IgniteException; /** * Executes provided closure job on nodes within this grid projection. A new job is executed for @@ -314,10 +314,10 @@ public interface IgniteCompute extends IgniteAsyncSupport { * @param args Job arguments. * @param rdc Reducer to reduce all job results into one individual return value. * @return Future with reduced job result for this execution. - * @throws IgniteCheckedException If execution failed. + * @throws IgniteException If execution failed. */ public <R1, R2, T> R2 apply(IgniteClosure<T, R1> job, Collection<? extends T> args, - IgniteReducer<R1, R2> rdc) throws IgniteCheckedException; + IgniteReducer<R1, R2> rdc) throws IgniteException; /** * Gets tasks future for active tasks started on local node. @@ -396,9 +396,9 @@ public interface IgniteCompute extends IgniteAsyncSupport { * class name will be used as task's name. * @param clsLdr Task class loader. This class loader is in charge * of loading all necessary resources for task execution. - * @throws IgniteCheckedException If task is invalid and cannot be deployed. + * @throws IgniteException If task is invalid and cannot be deployed. */ - public void localDeployTask(Class<? extends ComputeTask> taskCls, ClassLoader clsLdr) throws IgniteCheckedException; + public void localDeployTask(Class<? extends ComputeTask> taskCls, ClassLoader clsLdr) throws IgniteException; /** * Gets map of all locally deployed tasks keyed by their task name . @@ -413,9 +413,9 @@ public interface IgniteCompute extends IgniteAsyncSupport { * undeployed on every node. * * @param taskName Name of the task to undeploy. - * @throws IgniteCheckedException Thrown if undeploy failed. + * @throws IgniteException Thrown if undeploy failed. */ - public void undeployTask(String taskName) throws IgniteCheckedException; + public void undeployTask(String taskName) throws IgniteException; /** {@inheritDoc} */ @Override public <R> ComputeTaskFuture<R> future(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/IgniteDataLoader.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteDataLoader.java b/modules/core/src/main/java/org/apache/ignite/IgniteDataLoader.java index ecedb0f..0793e69 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteDataLoader.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteDataLoader.java @@ -109,9 +109,9 @@ public interface IgniteDataLoader<K, V> extends AutoCloseable { * Default is {@code false}. * * @param isolated Flag value. - * @throws IgniteCheckedException If failed. + * @throws IgniteException If failed. */ - public void isolated(boolean isolated) throws IgniteCheckedException; + public void isolated(boolean isolated) throws IgniteException; /** * Gets size of per node key-value pairs buffer. @@ -213,12 +213,12 @@ public interface IgniteDataLoader<K, V> extends AutoCloseable { * * @param key Key. * @return Future fo this operation. - * @throws IgniteCheckedException If failed to map key to node. + * @throws IgniteException If failed to map key to node. * @throws GridInterruptedException If thread has been interrupted. * @throws IllegalStateException If grid has been concurrently stopped or * {@link #close(boolean)} has already been called on loader. */ - public IgniteFuture<?> removeData(K key) throws IgniteCheckedException, GridInterruptedException, IllegalStateException; + public IgniteFuture<?> removeData(K key) throws IgniteException, GridInterruptedException, IllegalStateException; /** * Adds data for loading on remote node. This method can be called from multiple @@ -231,12 +231,12 @@ public interface IgniteDataLoader<K, V> extends AutoCloseable { * @param key Key. * @param val Value or {@code null} if respective entry must be removed from cache. * @return Future fo this operation. - * @throws IgniteCheckedException If failed to map key to node. + * @throws IgniteException If failed to map key to node. * @throws GridInterruptedException If thread has been interrupted. * @throws IllegalStateException If grid has been concurrently stopped or * {@link #close(boolean)} has already been called on loader. */ - public IgniteFuture<?> addData(K key, @Nullable V val) throws IgniteCheckedException, GridInterruptedException, + public IgniteFuture<?> addData(K key, @Nullable V val) throws IgniteException, GridInterruptedException, IllegalStateException; /** @@ -249,12 +249,12 @@ public interface IgniteDataLoader<K, V> extends AutoCloseable { * * @param entry Entry. * @return Future fo this operation. - * @throws IgniteCheckedException If failed to map key to node. + * @throws IgniteException If failed to map key to node. * @throws GridInterruptedException If thread has been interrupted. * @throws IllegalStateException If grid has been concurrently stopped or * {@link #close(boolean)} has already been called on loader. */ - public IgniteFuture<?> addData(Map.Entry<K, V> entry) throws IgniteCheckedException, GridInterruptedException, + public IgniteFuture<?> addData(Map.Entry<K, V> entry) throws IgniteException, GridInterruptedException, IllegalStateException; /** @@ -296,34 +296,34 @@ public interface IgniteDataLoader<K, V> extends AutoCloseable { * another thread to complete flush and exit. If you don't want to wait in this case, * use {@link #tryFlush()} method. * - * @throws IgniteCheckedException If failed to map key to node. + * @throws IgniteException If failed to map key to node. * @throws GridInterruptedException If thread has been interrupted. * @throws IllegalStateException If grid has been concurrently stopped or * {@link #close(boolean)} has already been called on loader. * @see #tryFlush() */ - public void flush() throws IgniteCheckedException, GridInterruptedException, IllegalStateException; + public void flush() throws IgniteException, GridInterruptedException, IllegalStateException; /** * Makes an attempt to load remaining data. This method is mostly similar to {@link #flush}, * with the difference that it won't wait and will exit immediately. * - * @throws IgniteCheckedException If failed to map key to node. + * @throws IgniteException If failed to map key to node. * @throws GridInterruptedException If thread has been interrupted. * @throws IllegalStateException If grid has been concurrently stopped or * {@link #close(boolean)} has already been called on loader. * @see #flush() */ - public void tryFlush() throws IgniteCheckedException, GridInterruptedException, IllegalStateException; + public void tryFlush() throws IgniteException, GridInterruptedException, IllegalStateException; /** * Loads any remaining data and closes this loader. * * @param cancel {@code True} to cancel ongoing loading operations. - * @throws IgniteCheckedException If failed to map key to node. + * @throws IgniteException If failed to map key to node. * @throws GridInterruptedException If thread has been interrupted. */ - public void close(boolean cancel) throws IgniteCheckedException, GridInterruptedException; + public void close(boolean cancel) throws IgniteException, GridInterruptedException; /** * Closes data loader. This method is identical to calling {@link #close(boolean) close(false)} method. @@ -331,8 +331,8 @@ public interface IgniteDataLoader<K, V> extends AutoCloseable { * The method is invoked automatically on objects managed by the * {@code try-with-resources} statement. * - * @throws IgniteCheckedException If failed to close data loader. + * @throws IgniteException If failed to close data loader. * @throws GridInterruptedException If thread has been interrupted. */ - @Override public void close() throws IgniteCheckedException, GridInterruptedException; + @Override public void close() throws IgniteException, GridInterruptedException; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java b/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java index 728320e..e7c7b8d 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteEvents.java @@ -62,10 +62,10 @@ public interface IgniteEvents extends IgniteAsyncSupport { * @param timeout Maximum time to wait for result, {@code 0} to wait forever. * @param types Event types to be queried. * @return Collection of grid events returned from specified nodes. - * @throws IgniteCheckedException If query failed. + * @throws IgniteException If query failed. */ public <T extends IgniteEvent> List<T> remoteQuery(IgnitePredicate<T> p, long timeout, @Nullable int... types) - throws IgniteCheckedException; + throws IgniteException; /** * Adds event listener for specified events to all nodes in the projection (possibly including @@ -89,10 +89,10 @@ public interface IgniteEvents extends IgniteAsyncSupport { * provided remote filter will be sent to local node. * @param <T> Type of the event. * @return {@code Operation ID} that can be passed to {@link #stopRemoteListen(UUID)} method to stop listening. - * @throws IgniteCheckedException If failed to add listener. + * @throws IgniteException If failed to add listener. */ public <T extends IgniteEvent> UUID remoteListen(@Nullable IgniteBiPredicate<UUID, T> locLsnr, - @Nullable IgnitePredicate<T> rmtFilter, @Nullable int... types) throws IgniteCheckedException; + @Nullable IgnitePredicate<T> rmtFilter, @Nullable int... types) throws IgniteException; /** * Adds event listener for specified events to all nodes in the projection (possibly including @@ -127,11 +127,11 @@ public interface IgniteEvents extends IgniteAsyncSupport { * @param <T> Type of the event. * @return {@code Operation ID} that can be passed to {@link #stopRemoteListen(UUID)} method to stop listening. * @see #stopRemoteListen(UUID) - * @throws IgniteCheckedException If failed to add listener. + * @throws IgniteException If failed to add listener. */ public <T extends IgniteEvent> UUID remoteListen(int bufSize, long interval, boolean autoUnsubscribe, @Nullable IgniteBiPredicate<UUID, T> locLsnr, @Nullable IgnitePredicate<T> rmtFilter, - @Nullable int... types) throws IgniteCheckedException; + @Nullable int... types) throws IgniteException; /** * Stops listening to remote events. This will unregister all listeners identified with provided @@ -142,9 +142,9 @@ public interface IgniteEvents extends IgniteAsyncSupport { * @param opId Operation ID that was returned from * {@link #remoteListen(org.apache.ignite.lang.IgniteBiPredicate, org.apache.ignite.lang.IgnitePredicate, int...)} method. * @see #remoteListen(org.apache.ignite.lang.IgniteBiPredicate, org.apache.ignite.lang.IgnitePredicate, int...) - * @throws IgniteCheckedException If failed to stop listeners. + * @throws IgniteException If failed to stop listeners. */ - public void stopRemoteListen(UUID opId) throws IgniteCheckedException; + public void stopRemoteListen(UUID opId) throws IgniteException; /** * Waits for the specified events. @@ -155,10 +155,10 @@ public interface IgniteEvents extends IgniteAsyncSupport { * end the wait. * @param types Types of the events to wait for. If not provided, all events will be passed to the filter. * @return Grid event. - * @throws IgniteCheckedException If wait was interrupted. + * @throws IgniteException If wait was interrupted. */ public <T extends IgniteEvent> T waitForLocal(@Nullable IgnitePredicate<T> filter, @Nullable int... types) - throws IgniteCheckedException; + throws IgniteException; /** * Queries local node for events using passed-in predicate filter for event selection. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/IgniteFs.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteFs.java b/modules/core/src/main/java/org/apache/ignite/IgniteFs.java index 279ac37..e586477 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteFs.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteFs.java @@ -76,19 +76,19 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @param path Path to get information for. * @return Summary object. * @throws org.apache.ignite.fs.IgniteFsFileNotFoundException If path is not found. - * @throws IgniteCheckedException If failed. + * @throws IgniteException If failed. */ - public IgniteFsPathSummary summary(IgniteFsPath path) throws IgniteCheckedException; + public IgniteFsPathSummary summary(IgniteFsPath path) throws IgniteException; /** * Opens a file for reading. * * @param path File path to read. * @return File input stream to read data from. - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. * @throws org.apache.ignite.fs.IgniteFsFileNotFoundException If path doesn't exist. */ - public IgniteFsInputStream open(IgniteFsPath path) throws IgniteCheckedException; + public IgniteFsInputStream open(IgniteFsPath path) throws IgniteException; /** * Opens a file for reading. @@ -96,10 +96,10 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @param path File path to read. * @param bufSize Read buffer size (bytes) or {@code zero} to use default value. * @return File input stream to read data from. - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. * @throws org.apache.ignite.fs.IgniteFsFileNotFoundException If path doesn't exist. */ - @Override public IgniteFsInputStream open(IgniteFsPath path, int bufSize) throws IgniteCheckedException; + @Override public IgniteFsInputStream open(IgniteFsPath path, int bufSize) throws IgniteException; /** * Opens a file for reading. @@ -108,10 +108,10 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @param bufSize Read buffer size (bytes) or {@code zero} to use default value. * @param seqReadsBeforePrefetch Amount of sequential reads before prefetch is started. * @return File input stream to read data from. - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. * @throws org.apache.ignite.fs.IgniteFsFileNotFoundException If path doesn't exist. */ - public IgniteFsInputStream open(IgniteFsPath path, int bufSize, int seqReadsBeforePrefetch) throws IgniteCheckedException; + public IgniteFsInputStream open(IgniteFsPath path, int bufSize, int seqReadsBeforePrefetch) throws IgniteException; /** * Creates a file and opens it for writing. @@ -119,9 +119,9 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @param path File path to create. * @param overwrite Overwrite file if it already exists. Note: you cannot overwrite an existent directory. * @return File output stream to write data to. - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. */ - @Override public IgniteFsOutputStream create(IgniteFsPath path, boolean overwrite) throws IgniteCheckedException; + @Override public IgniteFsOutputStream create(IgniteFsPath path, boolean overwrite) throws IgniteException; /** * Creates a file and opens it for writing. @@ -133,10 +133,10 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @param blockSize Block size. * @param props File properties to set. * @return File output stream to write data to. - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. */ @Override public IgniteFsOutputStream create(IgniteFsPath path, int bufSize, boolean overwrite, int replication, - long blockSize, @Nullable Map<String, String> props) throws IgniteCheckedException; + long blockSize, @Nullable Map<String, String> props) throws IgniteException; /** * Creates a file and opens it for writing. @@ -150,11 +150,11 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @param blockSize Block size. * @param props File properties to set. * @return File output stream to write data to. - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. */ public IgniteFsOutputStream create(IgniteFsPath path, int bufSize, boolean overwrite, @Nullable IgniteUuid affKey, int replication, long blockSize, @Nullable Map<String, String> props) - throws IgniteCheckedException; + throws IgniteException; /** * Opens an output stream to an existing file for appending data. @@ -162,10 +162,10 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @param path File path to append. * @param create Create file if it doesn't exist yet. * @return File output stream to append data to. - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. * @throws org.apache.ignite.fs.IgniteFsFileNotFoundException If path doesn't exist and create flag is {@code false}. */ - public IgniteFsOutputStream append(IgniteFsPath path, boolean create) throws IgniteCheckedException; + public IgniteFsOutputStream append(IgniteFsPath path, boolean create) throws IgniteException; /** * Opens an output stream to an existing file for appending data. @@ -175,11 +175,11 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @param create Create file if it doesn't exist yet. * @param props File properties to set only in case it file was just created. * @return File output stream to append data to. - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. * @throws org.apache.ignite.fs.IgniteFsFileNotFoundException If path doesn't exist and create flag is {@code false}. */ @Override public IgniteFsOutputStream append(IgniteFsPath path, int bufSize, boolean create, - @Nullable Map<String, String> props) throws IgniteCheckedException; + @Nullable Map<String, String> props) throws IgniteException; /** * Sets last access time and last modification time for a given path. If argument is {@code null}, @@ -190,9 +190,9 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @param modificationTime Optional last modification time to set. Value {@code -1} does not update * modification time. * @throws org.apache.ignite.fs.IgniteFsFileNotFoundException If target was not found. - * @throws IgniteCheckedException If error occurred. + * @throws IgniteException If error occurred. */ - public void setTimes(IgniteFsPath path, long accessTime, long modificationTime) throws IgniteCheckedException; + public void setTimes(IgniteFsPath path, long accessTime, long modificationTime) throws IgniteException; /** * Gets affinity block locations for data blocks of the file, i.e. the nodes, on which the blocks @@ -202,10 +202,10 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @param start Position in the file to start affinity resolution from. * @param len Size of data in the file to resolve affinity for. * @return Affinity block locations. - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. * @throws org.apache.ignite.fs.IgniteFsFileNotFoundException If path doesn't exist. */ - public Collection<IgniteFsBlockLocation> affinity(IgniteFsPath path, long start, long len) throws IgniteCheckedException; + public Collection<IgniteFsBlockLocation> affinity(IgniteFsPath path, long start, long len) throws IgniteException; /** * Get affinity block locations for data blocks of the file. In case {@code maxLen} parameter is set and @@ -217,26 +217,26 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @param len Size of data in the file to resolve affinity for. * @param maxLen Maximum length of a single returned block location length. * @return Affinity block locations. - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. * @throws org.apache.ignite.fs.IgniteFsFileNotFoundException If path doesn't exist. */ public Collection<IgniteFsBlockLocation> affinity(IgniteFsPath path, long start, long len, long maxLen) - throws IgniteCheckedException; + throws IgniteException; /** * Gets metrics snapshot for this file system. * * @return Metrics. - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. */ - public IgniteFsMetrics metrics() throws IgniteCheckedException; + public IgniteFsMetrics metrics() throws IgniteException; /** * Resets metrics for this file system. * - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. */ - public void resetMetrics() throws IgniteCheckedException; + public void resetMetrics() throws IgniteException; /** * Determines size of the file denoted by provided path. In case if path is a directory, then @@ -244,18 +244,18 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * * @param path File system path. * @return Total size. - * @throws IgniteCheckedException In case of error. + * @throws IgniteException In case of error. */ - public long size(IgniteFsPath path) throws IgniteCheckedException; + public long size(IgniteFsPath path) throws IgniteException; /** * Formats the file system removing all existing entries from it. * <p> * Supports asynchronous execution (see {@link IgniteAsyncSupport}). * - * @throws IgniteCheckedException In case format has failed. + * @throws IgniteException In case format has failed. */ - public void format() throws IgniteCheckedException; + public void format() throws IgniteException; /** * Executes GGFS task. @@ -267,10 +267,10 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @param paths Collection of paths to be processed within this task. * @param arg Optional task argument. * @return Task result. - * @throws IgniteCheckedException If execution failed. + * @throws IgniteException If execution failed. */ public <T, R> R execute(IgniteFsTask<T, R> task, @Nullable IgniteFsRecordResolver rslvr, - Collection<IgniteFsPath> paths, @Nullable T arg) throws IgniteCheckedException; + Collection<IgniteFsPath> paths, @Nullable T arg) throws IgniteException; /** * Executes GGFS task with overridden maximum range length (see @@ -287,11 +287,11 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * GGFS blocks will be included. * @param arg Optional task argument. * @return Task result. - * @throws IgniteCheckedException If execution failed. + * @throws IgniteException If execution failed. */ public <T, R> R execute(IgniteFsTask<T, R> task, @Nullable IgniteFsRecordResolver rslvr, Collection<IgniteFsPath> paths, boolean skipNonExistentFiles, long maxRangeLen, @Nullable T arg) - throws IgniteCheckedException; + throws IgniteException; /** * Executes GGFS task. @@ -303,10 +303,10 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @param paths Collection of paths to be processed within this task. * @param arg Optional task argument. * @return Task result. - * @throws IgniteCheckedException If execution failed. + * @throws IgniteException If execution failed. */ public <T, R> R execute(Class<? extends IgniteFsTask<T, R>> taskCls, - @Nullable IgniteFsRecordResolver rslvr, Collection<IgniteFsPath> paths, @Nullable T arg) throws IgniteCheckedException; + @Nullable IgniteFsRecordResolver rslvr, Collection<IgniteFsPath> paths, @Nullable T arg) throws IgniteException; /** * Executes GGFS task with overridden maximum range length (see @@ -322,11 +322,11 @@ public interface IgniteFs extends IgniteFsFileSystem, IgniteAsyncSupport { * @param maxRangeLen Maximum range length. * @param arg Optional task argument. * @return Task result. - * @throws IgniteCheckedException If execution failed. + * @throws IgniteException If execution failed. */ public <T, R> R execute(Class<? extends IgniteFsTask<T, R>> taskCls, @Nullable IgniteFsRecordResolver rslvr, Collection<IgniteFsPath> paths, boolean skipNonExistentFiles, - long maxRangeLen, @Nullable T arg) throws IgniteCheckedException; + long maxRangeLen, @Nullable T arg) throws IgniteException; /** {@inheritDoc} */ @Override public IgniteFs enableAsync(); http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java b/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java index 9aaa644..3886db0 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteManaged.java @@ -141,9 +141,9 @@ public interface IgniteManaged extends IgniteAsyncSupport { * * @param name Service name. * @param svc Service instance. - * @throws IgniteCheckedException If failed to deploy service. + * @throws IgniteException If failed to deploy service. */ - public void deployClusterSingleton(String name, ManagedService svc) throws IgniteCheckedException; + public void deployClusterSingleton(String name, ManagedService svc) throws IgniteException; /** * Deploys a per-node singleton service. GridGain will guarantee that there is always @@ -158,9 +158,9 @@ public interface IgniteManaged extends IgniteAsyncSupport { * * @param name Service name. * @param svc Service instance. - * @throws IgniteCheckedException If failed to deploy service. + * @throws IgniteException If failed to deploy service. */ - public void deployNodeSingleton(String name, ManagedService svc) throws IgniteCheckedException; + public void deployNodeSingleton(String name, ManagedService svc) throws IgniteException; /** * Deploys one instance of this service on the primary node for a given affinity key. @@ -193,10 +193,10 @@ public interface IgniteManaged extends IgniteAsyncSupport { * @param cacheName Name of the cache on which affinity for key should be calculated, {@code null} for * default cache. * @param affKey Affinity cache key. - * @throws IgniteCheckedException If failed to deploy service. + * @throws IgniteException If failed to deploy service. */ public void deployKeyAffinitySingleton(String name, ManagedService svc, @Nullable String cacheName, Object affKey) - throws IgniteCheckedException; + throws IgniteException; /** * Deploys multiple instances of the service on the grid. GridGain will deploy a @@ -228,9 +228,9 @@ public interface IgniteManaged extends IgniteAsyncSupport { * @param svc Service instance. * @param totalCnt Maximum number of deployed services in the grid, {@code 0} for unlimited. * @param maxPerNodeCnt Maximum number of deployed services on each node, {@code 0} for unlimited. - * @throws IgniteCheckedException If failed to deploy service. + * @throws IgniteException If failed to deploy service. */ - public void deployMultiple(String name, ManagedService svc, int totalCnt, int maxPerNodeCnt) throws IgniteCheckedException; + public void deployMultiple(String name, ManagedService svc, int totalCnt, int maxPerNodeCnt) throws IgniteException; /** * Deploys multiple instances of the service on the grid according to provided @@ -268,9 +268,9 @@ public interface IgniteManaged extends IgniteAsyncSupport { * </pre> * * @param cfg Service configuration. - * @throws IgniteCheckedException If failed to deploy service. + * @throws IgniteException If failed to deploy service. */ - public void deploy(ManagedServiceConfiguration cfg) throws IgniteCheckedException; + public void deploy(ManagedServiceConfiguration cfg) throws IgniteException; /** * Cancels service deployment. If a service with specified name was deployed on the grid, @@ -283,9 +283,9 @@ public interface IgniteManaged extends IgniteAsyncSupport { * Supports asynchronous execution (see {@link IgniteAsyncSupport}). * * @param name Name of service to cancel. - * @throws IgniteCheckedException If failed to cancel service. + * @throws IgniteException If failed to cancel service. */ - public void cancel(String name) throws IgniteCheckedException; + public void cancel(String name) throws IgniteException; /** * Cancels all deployed services. @@ -295,9 +295,9 @@ public interface IgniteManaged extends IgniteAsyncSupport { * <p> * Supports asynchronous execution (see {@link IgniteAsyncSupport}). * - * @throws IgniteCheckedException If failed to cancel services. + * @throws IgniteException If failed to cancel services. */ - public void cancelAll() throws IgniteCheckedException; + public void cancelAll() throws IgniteException; /** * Gets metadata about all deployed services. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java b/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java index f11b3a6..f1b8e6a 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteMessaging.java @@ -57,10 +57,10 @@ public interface IgniteMessaging extends IgniteAsyncSupport { * * @param topic Topic to send to, {@code null} for default topic. * @param msg Message to send. - * @throws IgniteCheckedException If failed to send a message to any of the nodes. + * @throws IgniteException If failed to send a message to any of the nodes. * @throws org.apache.ignite.cluster.ClusterGroupEmptyException Thrown in case when this projection is empty. */ - public void send(@Nullable Object topic, Object msg) throws IgniteCheckedException; + public void send(@Nullable Object topic, Object msg) throws IgniteException; /** * Sends given messages with specified topic to the nodes in this projection. @@ -68,10 +68,10 @@ public interface IgniteMessaging extends IgniteAsyncSupport { * @param topic Topic to send to, {@code null} for default topic. * @param msgs Messages to send. Order of the sending is undefined. If the method produces * the exception none or some messages could have been sent already. - * @throws IgniteCheckedException If failed to send a message to any of the nodes. + * @throws IgniteException If failed to send a message to any of the nodes. * @throws org.apache.ignite.cluster.ClusterGroupEmptyException Thrown in case when this projection is empty. */ - public void send(@Nullable Object topic, Collection<?> msgs) throws IgniteCheckedException; + public void send(@Nullable Object topic, Collection<?> msgs) throws IgniteException; /** * Sends given message with specified topic to the nodes in this projection. Messages sent with @@ -87,10 +87,10 @@ public interface IgniteMessaging extends IgniteAsyncSupport { * @param msg Message to send. * @param timeout Message timeout in milliseconds, {@code 0} for default * which is {@link org.apache.ignite.configuration.IgniteConfiguration#getNetworkTimeout()}. - * @throws IgniteCheckedException If failed to send a message to any of the nodes. + * @throws IgniteException If failed to send a message to any of the nodes. * @throws org.apache.ignite.cluster.ClusterGroupEmptyException Thrown in case when this projection is empty. */ - public void sendOrdered(@Nullable Object topic, Object msg, long timeout) throws IgniteCheckedException; + public void sendOrdered(@Nullable Object topic, Object msg, long timeout) throws IgniteException; /** * Adds local listener for given topic on local node only. This listener will be notified whenever any @@ -123,9 +123,9 @@ public interface IgniteMessaging extends IgniteAsyncSupport { * @param p Predicate that is called on each node for each received message. If predicate returns {@code false}, * then it will be unsubscribed from any further notifications. * @return {@code Operation ID} that can be passed to {@link #stopRemoteListen(UUID)} method to stop listening. - * @throws IgniteCheckedException If failed to add listener. + * @throws IgniteException If failed to add listener. */ - public UUID remoteListen(@Nullable Object topic, IgniteBiPredicate<UUID, ?> p) throws IgniteCheckedException; + public UUID remoteListen(@Nullable Object topic, IgniteBiPredicate<UUID, ?> p) throws IgniteException; /** * Unregisters all listeners identified with provided operation ID on all nodes in this projection. @@ -133,9 +133,9 @@ public interface IgniteMessaging extends IgniteAsyncSupport { * Supports asynchronous execution (see {@link IgniteAsyncSupport}). * * @param opId Listen ID that was returned from {@link #remoteListen(Object, org.apache.ignite.lang.IgniteBiPredicate)} method. - * @throws IgniteCheckedException If failed to unregister listeners. + * @throws IgniteException If failed to unregister listeners. */ - public void stopRemoteListen(UUID opId) throws IgniteCheckedException; + public void stopRemoteListen(UUID opId) throws IgniteException; /** {@inheritDoc} */ @Override http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/IgniteStreamer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/IgniteStreamer.java b/modules/core/src/main/java/org/apache/ignite/IgniteStreamer.java index 418c7bb..f878cf0 100644 --- a/modules/core/src/main/java/org/apache/ignite/IgniteStreamer.java +++ b/modules/core/src/main/java/org/apache/ignite/IgniteStreamer.java @@ -60,9 +60,9 @@ public interface IgniteStreamer { * * @param evt Event to add. * @param evts Optional events to add. - * @throws IgniteCheckedException If event submission failed. + * @throws IgniteException If event submission failed. */ - public void addEvent(Object evt, Object... evts) throws IgniteCheckedException; + public void addEvent(Object evt, Object... evts) throws IgniteException; /** * Submits group of events to streamer. Events will be processed from a stage with specified name. @@ -70,27 +70,27 @@ public interface IgniteStreamer { * @param stageName Stage name to start with. * @param evt Event tp process. * @param evts Optional events. - * @throws IgniteCheckedException If event submission failed. + * @throws IgniteException If event submission failed. */ - public void addEventToStage(String stageName, Object evt, Object... evts) throws IgniteCheckedException; + public void addEventToStage(String stageName, Object evt, Object... evts) throws IgniteException; /** * Submits group of events for processing. This group of events will be processed on default stage, * i.e. stage that is the first in the streamer stages list. * * @param evts Events to add. - * @throws IgniteCheckedException If event submission failed. + * @throws IgniteException If event submission failed. */ - public void addEvents(Collection<?> evts) throws IgniteCheckedException; + public void addEvents(Collection<?> evts) throws IgniteException; /** * Submits events to streamer. Events will be processed from a stage with specified name. * * @param stageName Stage name to start with. * @param evts Events to process. - * @throws IgniteCheckedException If event submission failed. + * @throws IgniteException If event submission failed. */ - public void addEventsToStage(String stageName, Collection<?> evts) throws IgniteCheckedException; + public void addEventsToStage(String stageName, Collection<?> evts) throws IgniteException; /** * Gets streamer context. Streamer context provides access to streamer local space on this node, configured http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/Ignition.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/Ignition.java b/modules/core/src/main/java/org/apache/ignite/Ignition.java index 1a8d17f..8b883c9 100644 --- a/modules/core/src/main/java/org/apache/ignite/Ignition.java +++ b/modules/core/src/main/java/org/apache/ignite/Ignition.java @@ -13,6 +13,7 @@ import org.apache.ignite.configuration.*; import org.apache.ignite.lifecycle.*; import org.gridgain.grid.*; import org.gridgain.grid.kernal.*; +import org.gridgain.grid.util.typedef.internal.*; import org.jetbrains.annotations.*; import java.net.*; @@ -261,11 +262,16 @@ public class Ignition { * configuration file. If such file is not found, then all system defaults will be used. * * @return Started grid. - * @throws IgniteCheckedException If default grid could not be started. This exception will be thrown + * @throws IgniteException If default grid could not be started. This exception will be thrown * also if default grid has already been started. */ - public static Ignite start() throws IgniteCheckedException { - return GridGainEx.start(); + public static Ignite start() throws IgniteException { + try { + return GridGainEx.start(); + } + catch (IgniteCheckedException e) { + throw U.wrap(e); + } } /** @@ -274,11 +280,16 @@ public class Ignition { * * @param cfg Grid configuration. This cannot be {@code null}. * @return Started grid. - * @throws IgniteCheckedException If grid could not be started. This exception will be thrown + * @throws IgniteException If grid could not be started. This exception will be thrown * also if named grid has already been started. */ - public static Ignite start(IgniteConfiguration cfg) throws IgniteCheckedException { - return GridGainEx.start(cfg); + public static Ignite start(IgniteConfiguration cfg) throws IgniteException { + try { + return GridGainEx.start(cfg); + } + catch (IgniteCheckedException e) { + throw U.wrap(e); + } } /** @@ -293,12 +304,17 @@ public class Ignition { * @param springCfgPath Spring XML configuration file path or URL. * @return Started grid. If Spring configuration contains multiple grid instances, * then the 1st found instance is returned. - * @throws IgniteCheckedException If grid could not be started or configuration + * @throws IgniteException If grid could not be started or configuration * read. This exception will be thrown also if grid with given name has already * been started or Spring XML configuration file is invalid. */ - public static Ignite start(@Nullable String springCfgPath) throws IgniteCheckedException { - return GridGainEx.start(springCfgPath); + public static Ignite start(@Nullable String springCfgPath) throws IgniteException { + try { + return GridGainEx.start(springCfgPath); + } + catch (IgniteCheckedException e) { + throw U.wrap(e); + } } /** @@ -313,12 +329,17 @@ public class Ignition { * @param springCfgUrl Spring XML configuration file URL. This cannot be {@code null}. * @return Started grid. If Spring configuration contains multiple grid instances, * then the 1st found instance is returned. - * @throws IgniteCheckedException If grid could not be started or configuration + * @throws IgniteException If grid could not be started or configuration * read. This exception will be thrown also if grid with given name has already * been started or Spring XML configuration file is invalid. */ - public static Ignite start(URL springCfgUrl) throws IgniteCheckedException { - return GridGainEx.start(springCfgUrl); + public static Ignite start(URL springCfgUrl) throws IgniteException { + try { + return GridGainEx.start(springCfgUrl); + } + catch (IgniteCheckedException e) { + throw U.wrap(e); + } } /** http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/cache/query/QueryContinuousPredicate.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cache/query/QueryContinuousPredicate.java b/modules/core/src/main/java/org/apache/ignite/cache/query/QueryContinuousPredicate.java index 91892e8..59ad03e 100644 --- a/modules/core/src/main/java/org/apache/ignite/cache/query/QueryContinuousPredicate.java +++ b/modules/core/src/main/java/org/apache/ignite/cache/query/QueryContinuousPredicate.java @@ -193,7 +193,7 @@ public final class QueryContinuousPredicate<K, V> extends QueryPredicate<K, V> i * * @throws IgniteCheckedException In case of error. */ - @Override public void close() throws IgniteCheckedException { + @Override public void close() throws IgniteException { // TODO: implement. } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/cluster/ClusterGroup.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterGroup.java b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterGroup.java index 0035a25..91ce0e5 100644 --- a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterGroup.java +++ b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterGroup.java @@ -243,7 +243,7 @@ public interface ClusterGroup { * Gets a metrics snapshot for this projection. * * @return Grid projection metrics snapshot. - * @throws IgniteCheckedException If projection is empty. + * @throws IgniteException If projection is empty. */ - public ClusterMetrics metrics() throws IgniteCheckedException; + public ClusterMetrics metrics() throws IgniteException; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/cluster/ClusterTopologyException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterTopologyException.java b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterTopologyException.java index 879e6bb..baa13ec 100644 --- a/modules/core/src/main/java/org/apache/ignite/cluster/ClusterTopologyException.java +++ b/modules/core/src/main/java/org/apache/ignite/cluster/ClusterTopologyException.java @@ -15,7 +15,7 @@ import org.jetbrains.annotations.*; /** * This exception is used to indicate error with grid topology (e.g., crashed node, etc.). */ -public class ClusterTopologyException extends IgniteCheckedException { +public class ClusterTopologyException extends IgniteException { /** */ private static final long serialVersionUID = 0L; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/compute/ComputeExecutionRejectedException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeExecutionRejectedException.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeExecutionRejectedException.java index ff526b9..0ce49f2 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeExecutionRejectedException.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeExecutionRejectedException.java @@ -18,7 +18,7 @@ import org.jetbrains.annotations.*; * rejects execution. * @see org.apache.ignite.configuration.IgniteConfiguration#getExecutorService() */ -public class ComputeExecutionRejectedException extends IgniteCheckedException { +public class ComputeExecutionRejectedException extends IgniteException { /** */ private static final long serialVersionUID = 0L; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/compute/ComputeJob.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJob.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJob.java index 48926c6..0ffff8e 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJob.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJob.java @@ -151,11 +151,11 @@ public interface ComputeJob extends Serializable { * @return Job execution result (possibly {@code null}). This result will be returned * in {@link ComputeJobResult#getData()} method passed into * {@link ComputeTask#result(ComputeJobResult, List)} task method on caller node. - * @throws IgniteCheckedException If job execution caused an exception. This exception will be + * @throws IgniteException If job execution caused an exception. This exception will be * returned in {@link ComputeJobResult#getException()} method passed into * {@link ComputeTask#result(ComputeJobResult, List)} task method on caller node. * If execution produces a {@link RuntimeException} or {@link Error}, then - * it will be wrapped into {@link IgniteCheckedException}. + * it will be wrapped into {@link IgniteException}. */ - @Nullable public Object execute() throws IgniteCheckedException; + @Nullable public Object execute() throws IgniteException; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContinuationAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContinuationAdapter.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContinuationAdapter.java index f9fff7f..80bf5a8 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContinuationAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobContinuationAdapter.java @@ -35,13 +35,13 @@ import org.jetbrains.annotations.*; * private int multiplier = 3; * * @Override - * protected Collection<? extends ComputeJob> split(int gridSize, final String arg) throws IgniteCheckedException { + * protected Collection<? extends ComputeJob> split(int gridSize, final String arg) throws IgniteException { * List<GridComputeJobAdapter<String>> jobs = new ArrayList<GridComputeJobAdapter<String>>(gridSize); * * for (int i = 0; i < gridSize; i++) { * jobs.add(new GridComputeJobAdapter() { * // Job execution logic. - * public Object execute() throws IgniteCheckedException { + * public Object execute() throws IgniteException { * return multiplier * arg.length(); * } * }); @@ -52,7 +52,7 @@ import org.jetbrains.annotations.*; * * // Aggregate multiple job results into * // one task result. - * public Integer reduce(List<GridComputeJobResult> results) throws IgniteCheckedException { + * public Integer reduce(List<GridComputeJobResult> results) throws IgniteException { * int sum = 0; * * // For the sake of this example, let's sum all results. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobMasterLeaveAware.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobMasterLeaveAware.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobMasterLeaveAware.java index ab4ab6a..cb4f77d 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobMasterLeaveAware.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobMasterLeaveAware.java @@ -17,7 +17,7 @@ public interface ComputeJobMasterLeaveAware { * A method which is executed in case master node has left topology during job execution. * * @param ses Task session, can be used for checkpoint saving. - * @throws IgniteCheckedException In case of any exception. + * @throws IgniteException In case of any exception. */ - public void onMasterNodeLeft(ComputeTaskSession ses) throws IgniteCheckedException; + public void onMasterNodeLeft(ComputeTaskSession ses) throws IgniteException; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobResult.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobResult.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobResult.java index 7c9ae3e..585d109 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobResult.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobResult.java @@ -49,7 +49,7 @@ public interface ComputeJobResult { * Gets exception produced by execution of remote job, or {@code null} if * remote execution finished normally and did not produce any exceptions. * - * @return {@link IgniteCheckedException} produced by execution of remote job or {@code null} if + * @return {@link IgniteException} produced by execution of remote job or {@code null} if * no exception was produced. * <p> * Note that if remote job resulted in {@link RuntimeException} @@ -62,7 +62,7 @@ public interface ComputeJobResult { * If node on which job was computing failed, then {@link org.apache.ignite.cluster.ClusterTopologyException} is * returned. */ - public IgniteCheckedException getException(); + public IgniteException getException(); /** * Gets local instance of remote job returned by {@link ComputeTask#map(List, Object)} method. http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobSibling.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobSibling.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobSibling.java index 330196a..8285fc2 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobSibling.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeJobSibling.java @@ -32,7 +32,7 @@ public interface ComputeJobSibling extends GridMetadataAware { /** * Sends a request to cancel this sibling. * - * @throws IgniteCheckedException If cancellation message could not be sent. + * @throws IgniteException If cancellation message could not be sent. */ - public void cancel() throws IgniteCheckedException; + public void cancel() throws IgniteException; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/compute/ComputeLoadBalancer.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeLoadBalancer.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeLoadBalancer.java index e4ee221..df8d4aa 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeLoadBalancer.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeLoadBalancer.java @@ -34,7 +34,7 @@ import java.util.*; * <pre name="code" class="java"> * public class MyFooBarTask extends GridComputeTaskSplitAdapter<String> { * @Override - * protected Collection<? extends ComputeJob> split(int gridSize, String arg) throws IgniteCheckedException { + * protected Collection<? extends ComputeJob> split(int gridSize, String arg) throws IgniteException { * List<MyFooBarJob> jobs = new ArrayList<MyFooBarJob>(gridSize); * * for (int i = 0; i < gridSize; i++) { @@ -60,7 +60,7 @@ import java.util.*; * GridComputeLoadBalancer balancer; * * // Map jobs to grid nodes. - * public Map<? extends ComputeJob, GridNode> map(List<GridNode> subgrid, String arg) throws IgniteCheckedException { + * public Map<? extends ComputeJob, GridNode> map(List<GridNode> subgrid, String arg) throws IgniteException { * Map<MyFooBarJob, GridNode> jobs = new HashMap<MyFooBarJob, GridNode>(subgrid.size()); * * // In more complex cases, you can actually do @@ -76,7 +76,7 @@ import java.util.*; * } * * // Aggregate results into one compound result. - * public String reduce(List<GridComputeJobResult> results) throws IgniteCheckedException { + * public String reduce(List<GridComputeJobResult> results) throws IgniteException { * // For the purpose of this example we simply * // concatenate string representation of every * // job result @@ -101,8 +101,8 @@ public interface ComputeLoadBalancer extends GridMetadataAware { * @param exclNodes Optional collection of nodes that should be excluded from balanced nodes. * If collection is {@code null} or empty - no nodes will be excluded. * @return Next balanced node. - * @throws IgniteCheckedException If any error occurred when finding next balanced node. + * @throws IgniteException If any error occurred when finding next balanced node. */ @Nullable public ClusterNode getBalancedNode(ComputeJob job, @Nullable Collection<ClusterNode> exclNodes) - throws IgniteCheckedException; + throws IgniteException; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/compute/ComputeTask.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTask.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTask.java index b3d90f3..6d81e86 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTask.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTask.java @@ -153,7 +153,7 @@ import java.util.*; * GridComputeLoadBalancer balancer; * * // Map jobs to grid nodes. - * public Map<? extends ComputeJob, GridNode> map(List<GridNode> subgrid, String arg) throws IgniteCheckedException { + * public Map<? extends ComputeJob, GridNode> map(List<GridNode> subgrid, String arg) throws IgniteException { * Map<MyFooBarJob, GridNode> jobs = new HashMap<MyFooBarJob, GridNode>(subgrid.size()); * * // In more complex cases, you can actually do @@ -167,7 +167,7 @@ import java.util.*; * } * * // Aggregate results into one compound result. - * public String reduce(List<GridComputeJobResult> results) throws IgniteCheckedException { + * public String reduce(List<GridComputeJobResult> results) throws IgniteException { * // For the purpose of this example we simply * // concatenate string representation of every * // job result @@ -192,7 +192,7 @@ import java.util.*; * <pre name="code" class="java"> * public class MyFooBarTask extends GridComputeTaskSplitAdapter<Object, String> { * @Override - * protected Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteCheckedException { + * protected Collection<? extends ComputeJob> split(int gridSize, Object arg) throws IgniteException { * List<MyFooBarJob> jobs = new ArrayList<MyFooBarJob>(gridSize); * * for (int i = 0; i < gridSize; i++) { @@ -205,7 +205,7 @@ import java.util.*; * } * * // Aggregate results into one compound result. - * public String reduce(List<GridComputeJobResult> results) throws IgniteCheckedException { + * public String reduce(List<GridComputeJobResult> results) throws IgniteException { * // For the purpose of this example we simply * // concatenate string representation of every * // job result @@ -239,10 +239,10 @@ public interface ComputeTask<T, R> extends Serializable { * over time should result into all nodes being used equally. * @return Map of grid jobs assigned to subgrid node. Unless {@link ComputeTaskContinuousMapper} is * injected into task, if {@code null} or empty map is returned, exception will be thrown. - * @throws IgniteCheckedException If mapping could not complete successfully. This exception will be + * @throws IgniteException If mapping could not complete successfully. This exception will be * thrown out of {@link ComputeTaskFuture#get()} method. */ - @Nullable public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable T arg) throws IgniteCheckedException; + @Nullable public Map<? extends ComputeJob, ClusterNode> map(List<ClusterNode> subgrid, @Nullable T arg) throws IgniteException; /** * Asynchronous callback invoked every time a result from remote execution is @@ -256,10 +256,10 @@ public interface ComputeTask<T, R> extends Serializable { * {@link ComputeTaskNoResultCache} annotation, then this list will be empty. * @return Result policy that dictates how to process further upcoming * job results. - * @throws IgniteCheckedException If handling a job result caused an error. This exception will + * @throws IgniteException If handling a job result caused an error. This exception will * be thrown out of {@link ComputeTaskFuture#get()} method. */ - public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException; + public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteException; /** * Reduces (or aggregates) results received so far into one compound result to be returned to @@ -272,8 +272,8 @@ public interface ComputeTask<T, R> extends Serializable { * @param results Received results of broadcasted remote executions. Note that if task class has * {@link ComputeTaskNoResultCache} annotation, then this list will be empty. * @return Grid job result constructed from results of remote executions. - * @throws IgniteCheckedException If reduction or results caused an error. This exception will + * @throws IgniteException If reduction or results caused an error. This exception will * be thrown out of {@link ComputeTaskFuture#get()} method. */ - @Nullable public R reduce(List<ComputeJobResult> results) throws IgniteCheckedException; + @Nullable public R reduce(List<ComputeJobResult> results) throws IgniteException; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskAdapter.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskAdapter.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskAdapter.java index bcb3715..859c85a 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskAdapter.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskAdapter.java @@ -25,7 +25,7 @@ import java.util.*; * GridComputeLoadBalancer balancer; * * // Map jobs to grid nodes. - * public Map<? extends ComputeJob, GridNode> map(List<GridNode> subgrid, String arg) throws IgniteCheckedException { + * public Map<? extends ComputeJob, GridNode> map(List<GridNode> subgrid, String arg) throws IgniteException { * Map<MyFooBarJob, GridNode> jobs = new HashMap<MyFooBarJob, GridNode>(subgrid.size()); * * // In more complex cases, you can actually do @@ -39,7 +39,7 @@ import java.util.*; * } * * // Aggregate results into one compound result. - * public String reduce(List<GridComputeJobResult> results) throws IgniteCheckedException { + * public String reduce(List<GridComputeJobResult> results) throws IgniteException { * // For the purpose of this example we simply * // concatenate string representation of every * // job result @@ -77,11 +77,11 @@ public abstract class ComputeTaskAdapter<T, R> implements ComputeTask<T, R> { * @param rcvd All previously received results. * @return Result policy that dictates how to process further upcoming * job results. - * @throws IgniteCheckedException If handling a job result caused an error effectively rejecting + * @throws IgniteException If handling a job result caused an error effectively rejecting * a failover. This exception will be thrown out of {@link ComputeTaskFuture#get()} method. */ - @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteCheckedException { - IgniteCheckedException e = res.getException(); + @Override public ComputeJobResultPolicy result(ComputeJobResult res, List<ComputeJobResult> rcvd) throws IgniteException { + IgniteException e = res.getException(); // Try to failover if result is failed. if (e != null) { @@ -92,7 +92,7 @@ public abstract class ComputeTaskAdapter<T, R> implements ComputeTask<T, R> { e.hasCause(ComputeJobFailoverException.class)) return ComputeJobResultPolicy.FAILOVER; - throw new IgniteCheckedException("Remote job threw user exception (override or implement GridComputeTask.result(..) " + + throw new IgniteException("Remote job threw user exception (override or implement GridComputeTask.result(..) " + "method if you would like to have automatic failover for this exception).", e); } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskCancelledException.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskCancelledException.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskCancelledException.java index 7f79a4c..3646050 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskCancelledException.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskCancelledException.java @@ -15,7 +15,7 @@ import org.jetbrains.annotations.*; /** * This exception indicates that grid task was cancelled. */ -public class ComputeTaskCancelledException extends IgniteCheckedException { +public class ComputeTaskCancelledException extends IgniteException { /** */ private static final long serialVersionUID = 0L; http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskContinuousMapper.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskContinuousMapper.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskContinuousMapper.java index e43c06f..f7caf07 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskContinuousMapper.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskContinuousMapper.java @@ -59,33 +59,33 @@ public interface ComputeTaskContinuousMapper { * * @param job Job instance to send. If {@code null} is passed, exception will be thrown. * @param node Grid node. If {@code null} is passed, exception will be thrown. - * @throws IgniteCheckedException If job can not be processed. + * @throws IgniteException If job can not be processed. */ - public void send(ComputeJob job, ClusterNode node) throws IgniteCheckedException; + public void send(ComputeJob job, ClusterNode node) throws IgniteException; /** * Sends collection of grid jobs to assigned nodes. * * @param mappedJobs Map of grid jobs assigned to grid node. If {@code null} * or empty list is passed, exception will be thrown. - * @throws IgniteCheckedException If job can not be processed. + * @throws IgniteException If job can not be processed. */ - public void send(Map<? extends ComputeJob, ClusterNode> mappedJobs) throws IgniteCheckedException; + public void send(Map<? extends ComputeJob, ClusterNode> mappedJobs) throws IgniteException; /** * Sends job to a node automatically picked by the underlying load balancer. * * @param job Job instance to send. If {@code null} is passed, exception will be thrown. - * @throws IgniteCheckedException If job can not be processed. + * @throws IgniteException If job can not be processed. */ - public void send(ComputeJob job) throws IgniteCheckedException; + public void send(ComputeJob job) throws IgniteException; /** * Sends collection of jobs to nodes automatically picked by the underlying load balancer. * * @param jobs Collection of grid job instances. If {@code null} or empty * list is passed, exception will be thrown. - * @throws IgniteCheckedException If job can not be processed. + * @throws IgniteException If job can not be processed. */ - public void send(Collection<? extends ComputeJob> jobs) throws IgniteCheckedException; + public void send(Collection<? extends ComputeJob> jobs) throws IgniteException; } http://git-wip-us.apache.org/repos/asf/incubator-ignite/blob/8bc850c2/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskFuture.java ---------------------------------------------------------------------- diff --git a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskFuture.java b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskFuture.java index 70d4934..aa3fc2a 100644 --- a/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskFuture.java +++ b/modules/core/src/main/java/org/apache/ignite/compute/ComputeTaskFuture.java @@ -27,21 +27,21 @@ public interface ComputeTaskFuture<R> extends IgniteFuture<R> { * * @throws ComputeTaskTimeoutException If task execution timed out. */ - @Override public R get() throws IgniteCheckedException; + @Override public R get() throws IgniteException; /** * {@inheritDoc} * * @throws ComputeTaskTimeoutException If task execution timed out. */ - @Override public R get(long timeout) throws IgniteCheckedException; + @Override public R get(long timeout) throws IgniteException; /** * {@inheritDoc} * * @throws ComputeTaskTimeoutException If task execution timed out. */ - @Override public R get(long timeout, TimeUnit unit) throws IgniteCheckedException; + @Override public R get(long timeout, TimeUnit unit) throws IgniteException; /** * Gets task session of execution grid task.
