[
https://issues.apache.org/jira/browse/FLINK-1528?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14322906#comment-14322906
]
ASF GitHub Bot commented on FLINK-1528:
---------------------------------------
Github user vasia commented on the pull request:
https://github.com/apache/flink/pull/400#issuecomment-74527767
Right, so let me copy:
The problem is here:
```
DataSet<Tuple2<K, HashSet<K>>> neighborhoods = input.reduceOnEdges(new
NeighborhoodEdgesFunction<K>(), EdgeDirection.OUT);
```
and we try to get the return type `Tuple2<K, HashSet<K>>` like this:
```
public TypeInformation<T> getProducedType() {
return TypeExtractor.createTypeInfo(EdgesFunction.class,
function.getClass(), 2, null, null);
}
```
Anyone have an idea? Is it because of the nested type parameter in
`Tuple2<K, HashSet<K>>` ?
> Add local clustering coefficient library method and example
> -----------------------------------------------------------
>
> Key: FLINK-1528
> URL: https://issues.apache.org/jira/browse/FLINK-1528
> Project: Flink
> Issue Type: Task
> Components: Gelly
> Reporter: Vasia Kalavri
> Assignee: Daniel Bali
>
> Add a gelly library method and example to compute the local clustering
> coefficient.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
