You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@apex.apache.org by ch...@apache.org on 2015/09/10 00:12:57 UTC
[26/50] incubator-apex-core git commit: Remove warnings and obsolete
internal attributes.
Remove warnings and obsolete internal attributes.
Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/repo
Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/commit/485c9ac8
Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/tree/485c9ac8
Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-core/diff/485c9ac8
Branch: refs/heads/master
Commit: 485c9ac86735bb775589a1dcfc3e9c716a167c39
Parents: 39ef1cf
Author: thomas <th...@datatorrent.com>
Authored: Tue Aug 11 10:51:07 2015 -0700
Committer: thomas <th...@datatorrent.com>
Committed: Tue Aug 11 10:51:07 2015 -0700
----------------------------------------------------------------------
.../java/com/datatorrent/stram/plan/logical/LogicalPlan.java | 4 +---
1 file changed, 1 insertion(+), 3 deletions(-)
----------------------------------------------------------------------
http://git-wip-us.apache.org/repos/asf/incubator-apex-core/blob/485c9ac8/engine/src/main/java/com/datatorrent/stram/plan/logical/LogicalPlan.java
----------------------------------------------------------------------
diff --git a/engine/src/main/java/com/datatorrent/stram/plan/logical/LogicalPlan.java b/engine/src/main/java/com/datatorrent/stram/plan/logical/LogicalPlan.java
index 9bfc2bd..d140d17 100644
--- a/engine/src/main/java/com/datatorrent/stram/plan/logical/LogicalPlan.java
+++ b/engine/src/main/java/com/datatorrent/stram/plan/logical/LogicalPlan.java
@@ -49,7 +49,6 @@ import com.datatorrent.common.metric.MetricsAggregator;
import com.datatorrent.common.metric.SingleMetricAggregator;
import com.datatorrent.common.metric.sum.DoubleSumAggregator;
import com.datatorrent.common.metric.sum.LongSumAggregator;
-import com.datatorrent.common.util.BaseOperator;
import com.datatorrent.common.util.FSStorageAgent;
import com.datatorrent.stram.engine.DefaultUnifier;
import com.datatorrent.stram.engine.Slider;
@@ -103,8 +102,6 @@ public class LogicalPlan implements Serializable, DAG
public static Attribute<Long> RM_TOKEN_LIFE_TIME = new Attribute<Long>(YarnConfiguration.DELEGATION_TOKEN_MAX_LIFETIME_DEFAULT);
public static Attribute<String> KEY_TAB_FILE = new Attribute<String>((String) null, new StringCodec.String2String());
public static Attribute<Double> TOKEN_REFRESH_ANTICIPATORY_FACTOR = new Attribute<Double>(0.7);
- public static Attribute<String> LICENSE = new Attribute<String>((String) null, new StringCodec.String2String());
- public static Attribute<String> LICENSE_ROOT = new Attribute<String>((String) null, new StringCodec.String2String());
/**
* Comma separated list of jar file dependencies to be deployed with the application.
* The launcher will combine the list with built-in dependencies and those specified
@@ -897,6 +894,7 @@ public class LogicalPlan implements Serializable, DAG
}
@Override
+ @SuppressWarnings("unchecked")
public <T> StreamMeta addStream(String id, Operator.OutputPort<? extends T> source, Operator.InputPort<? super T>... sinks)
{
StreamMeta s = addStream(id);