org.apache.flink.graph.examples

Class MusicProfiles.CreateSimilarUserEdges

java.lang.Object

org.apache.flink.graph.examples.MusicProfiles.CreateSimilarUserEdges

All Implemented Interfaces:

Serializable, Function, GroupReduceFunction<Edge<String,Integer>,Edge<String,NullValue>>

Enclosing class:

MusicProfiles

public static final class MusicProfiles.CreateSimilarUserEdges
extends Object
implements GroupReduceFunction<Edge<String,Integer>,Edge<String,NullValue>>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
CreateSimilarUserEdges()

Method Summary

Modifier and Type	Method and Description
void	reduce(Iterable<Edge<String,Integer>> edges, Collector<Edge<String,NullValue>> out) The reduce method.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CreateSimilarUserEdges

public CreateSimilarUserEdges()

Method Detail

reduce

public void reduce(Iterable<Edge<String,Integer>> edges,
                   Collector<Edge<String,NullValue>> out)

Description copied from interface: GroupReduceFunction

The reduce method. The function receives one call per group of elements.

Specified by:

reduce in interface GroupReduceFunction<Edge<String,Integer>,Edge<String,NullValue>>

Parameters:

edges - All records that belong to the given input key.

out - The collector to hand results to.