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 <[email protected]> Authored: Tue Aug 11 10:51:07 2015 -0700 Committer: thomas <[email protected]> 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);
