Repository: apex-core Updated Branches: refs/heads/release-3.6 ea0adae72 -> ce0a13581
APEXCORE-715 Remove unnecessary @Evolving annotation in engine Project: http://git-wip-us.apache.org/repos/asf/apex-core/repo Commit: http://git-wip-us.apache.org/repos/asf/apex-core/commit/ce0a1358 Tree: http://git-wip-us.apache.org/repos/asf/apex-core/tree/ce0a1358 Diff: http://git-wip-us.apache.org/repos/asf/apex-core/diff/ce0a1358 Branch: refs/heads/release-3.6 Commit: ce0a135813012b989555e2c98203051c7596a15c Parents: ea0adae Author: Vlad Rozov <[email protected]> Authored: Thu Apr 27 22:39:09 2017 -0700 Committer: Vlad Rozov <[email protected]> Committed: Thu Apr 27 22:39:09 2017 -0700 ---------------------------------------------------------------------- .../org/apache/apex/engine/api/plugin/DAGExecutionPlugin.java | 3 --- .../java/org/apache/apex/engine/api/plugin/PluginLocator.java | 2 -- .../java/org/apache/apex/engine/util/CascadeStorageAgent.java | 2 -- 3 files changed, 7 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/apex-core/blob/ce0a1358/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionPlugin.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionPlugin.java b/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionPlugin.java index a9722ac..7cfb1fa 100644 --- a/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionPlugin.java +++ b/engine/src/main/java/org/apache/apex/engine/api/plugin/DAGExecutionPlugin.java @@ -23,7 +23,6 @@ import java.util.Map; import java.util.Queue; import org.apache.apex.api.plugin.Plugin; -import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; import com.datatorrent.api.DAG; @@ -45,7 +44,6 @@ import com.datatorrent.stram.webapp.LogicalOperatorInfo; * </ul> * */ [email protected] public interface DAGExecutionPlugin<T extends DAGExecutionPlugin.Context> extends Plugin<T> { @@ -60,7 +58,6 @@ public interface DAGExecutionPlugin<T extends DAGExecutionPlugin.Context> extend * </ul> * */ - @InterfaceStability.Evolving interface Context<E extends DAGExecutionEvent> extends PluginContext<DAGExecutionEvent.Type, E> { VersionInfo getEngineVersion(); http://git-wip-us.apache.org/repos/asf/apex-core/blob/ce0a1358/engine/src/main/java/org/apache/apex/engine/api/plugin/PluginLocator.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/org/apache/apex/engine/api/plugin/PluginLocator.java b/engine/src/main/java/org/apache/apex/engine/api/plugin/PluginLocator.java index b93d64c..cd9a208 100644 --- a/engine/src/main/java/org/apache/apex/engine/api/plugin/PluginLocator.java +++ b/engine/src/main/java/org/apache/apex/engine/api/plugin/PluginLocator.java @@ -20,14 +20,12 @@ package org.apache.apex.engine.api.plugin; import java.util.Collection; -import org.apache.hadoop.classification.InterfaceStability; import org.apache.hadoop.conf.Configuration; /** * Interface to discover plugins during Apex Master initialization. This should return collection of * objects implementing an interface of type T. */ [email protected] public interface PluginLocator<T> { /** http://git-wip-us.apache.org/repos/asf/apex-core/blob/ce0a1358/engine/src/main/java/org/apache/apex/engine/util/CascadeStorageAgent.java ---------------------------------------------------------------------- diff --git a/engine/src/main/java/org/apache/apex/engine/util/CascadeStorageAgent.java b/engine/src/main/java/org/apache/apex/engine/util/CascadeStorageAgent.java index 9903010..bc3df77 100644 --- a/engine/src/main/java/org/apache/apex/engine/util/CascadeStorageAgent.java +++ b/engine/src/main/java/org/apache/apex/engine/util/CascadeStorageAgent.java @@ -28,7 +28,6 @@ import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.apache.apex.common.util.AsyncStorageAgent; -import org.apache.hadoop.classification.InterfaceStability; import com.google.common.collect.Maps; @@ -42,7 +41,6 @@ import com.datatorrent.api.StorageAgent; * restart to avoiding copying checkpoints from old application directory to improve application * restart time. */ [email protected] public class CascadeStorageAgent implements StorageAgent, AsyncStorageAgent, Serializable { private static final long serialVersionUID = 985557590735264920L;
