You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by tu...@apache.org on 2017/05/01 18:53:57 UTC
apex-core git commit: APEXCORE-715 Remove unnecessary @Evolving
annotation in engine
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 <v....@datatorrent.com>
Authored: Thu Apr 27 22:39:09 2017 -0700
Committer: Vlad Rozov <v....@datatorrent.com>
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>
*
*/
-@InterfaceStability.Evolving
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.
*/
-@InterfaceStability.Evolving
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.
*/
-@InterfaceStability.Evolving
public class CascadeStorageAgent implements StorageAgent, AsyncStorageAgent, Serializable
{
private static final long serialVersionUID = 985557590735264920L;