Repository: incubator-apex-malhar Updated Branches: refs/heads/master 127ffe752 -> df4cc4d2a
APEXMALHAR-998 extend second type parameter from Object Project: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/commit/e809bee2 Tree: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/tree/e809bee2 Diff: http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/diff/e809bee2 Branch: refs/heads/master Commit: e809bee20b0761e32bf4b1213e0dafa2791178de Parents: a91287c Author: Tushar R. Gosavi <[email protected]> Authored: Wed Jun 1 15:02:27 2016 +0530 Committer: Tushar R. Gosavi <[email protected]> Committed: Wed Jun 1 15:02:27 2016 +0530 ---------------------------------------------------------------------- .../src/main/java/com/datatorrent/lib/algo/UniqueValueCount.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-apex-malhar/blob/e809bee2/library/src/main/java/com/datatorrent/lib/algo/UniqueValueCount.java ---------------------------------------------------------------------- diff --git a/library/src/main/java/com/datatorrent/lib/algo/UniqueValueCount.java b/library/src/main/java/com/datatorrent/lib/algo/UniqueValueCount.java index 6f8750d..c56448e 100644 --- a/library/src/main/java/com/datatorrent/lib/algo/UniqueValueCount.java +++ b/library/src/main/java/com/datatorrent/lib/algo/UniqueValueCount.java @@ -63,11 +63,11 @@ public class UniqueValueCount<K> extends BaseOperator /** * The input port that receives key value pairs. */ - public transient DefaultInputPort<KeyValPair<K, Object>> input = new DefaultInputPort<KeyValPair<K, Object>>() + public transient DefaultInputPort<KeyValPair<K, ? extends Object>> input = new DefaultInputPort<KeyValPair<K, ? extends Object>>() { @Override - public void process(KeyValPair<K, Object> pair) + public void process(KeyValPair<K, ? extends Object> pair) { Set<Object> values = interimUniqueValues.get(pair.getKey()); if (values == null) {
