Class Hierarchy
- java.lang.Object
- org.apache.flink.examples.java.graph.ConnectedComponents (implements org.apache.flink.api.common.ProgramDescription)
- org.apache.flink.examples.java.graph.ConnectedComponents.ComponentIdFilter (implements org.apache.flink.api.common.functions.FlatJoinFunction<IN1,IN2,OUT>)
- org.apache.flink.examples.java.graph.ConnectedComponents.DuplicateValue<T> (implements org.apache.flink.api.common.functions.MapFunction<T,O>)
- org.apache.flink.examples.java.graph.ConnectedComponents.NeighborWithComponentIDJoin (implements org.apache.flink.api.common.functions.JoinFunction<IN1,IN2,OUT>)
- org.apache.flink.examples.java.graph.ConnectedComponents.UndirectEdge (implements org.apache.flink.api.common.functions.FlatMapFunction<T,O>)
- org.apache.flink.examples.java.graph.EnumTriangles
- org.apache.flink.examples.java.graph.EnumTriangles.TupleEdgeConverter (implements org.apache.flink.api.common.functions.MapFunction<T,O>)
- org.apache.flink.examples.java.graph.PageRank
- org.apache.flink.examples.java.graph.PageRank.BuildOutgoingEdgeList (implements org.apache.flink.api.common.functions.GroupReduceFunction<T,O>)
- org.apache.flink.examples.java.graph.PageRank.Dampener (implements org.apache.flink.api.common.functions.MapFunction<T,O>)
- org.apache.flink.examples.java.graph.PageRank.EpsilonFilter (implements org.apache.flink.api.common.functions.FilterFunction<T>)
- org.apache.flink.examples.java.graph.PageRank.JoinVertexWithEdgesMatch (implements org.apache.flink.api.common.functions.FlatMapFunction<T,O>)
- org.apache.flink.examples.java.graph.PageRank.RankAssigner (implements org.apache.flink.api.common.functions.MapFunction<T,O>)
- org.apache.flink.examples.java.graph.TransitiveClosureNaive (implements org.apache.flink.api.common.ProgramDescription)
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.