Package | Description |
---|---|
org.apache.flink.api.java.operators.translation | |
org.apache.flink.examples.java.clustering | |
org.apache.flink.examples.java.graph | |
org.apache.flink.graph.asm.degree.annotate |
The degree annotation package provides a collection of edge-centric graph
algorithms for counting the vertex degree of directed and undirected graphs.
|
org.apache.flink.graph.utils | |
org.apache.flink.python.api.functions.util |
Modifier and Type | Class and Description |
---|---|
class |
KeyExtractingMapper<T,K>
Mapper that extracts keys.
|
class |
KeyRemovingMapper<T,K>
Mapper that removes keys.
|
class |
PlanFilterOperator<T> |
class |
TwoKeyExtractingMapper<T,K1,K2>
Mapper that extracts two keys of a value.
|
Modifier and Type | Class and Description |
---|---|
static class |
KMeans.CentroidAccumulator
Sums and counts point coordinates.
|
static class |
KMeans.CentroidAverager
Computes new centroid from coordinate sum and count of points.
|
static class |
KMeans.CountAppender
Appends a count variable to the tuple.
|
static class |
KMeans.SelectNearestCenter
Determines the closest cluster center for a data point.
|
Modifier and Type | Class and Description |
---|---|
static class |
ConnectedComponents.DuplicateValue<T>
Function that turns a value into a 2-tuple where both fields are that value.
|
static class |
EnumTriangles.TupleEdgeConverter
Converts a Tuple2 into an Edge.
|
static class |
PageRank.BuildOutgoingEdgeList
A reduce function that takes a sequence of edges and builds the adjacency list for the vertex where the edges
originate.
|
static class |
PageRank.Dampener
The function that applies the page rank dampening formula.
|
Modifier and Type | Class and Description |
---|---|
static class |
DegreeAnnotationFunctions.DegreeCount<K>
Combines the vertex degree count.
|
static class |
DegreeAnnotationFunctions.MapEdgeToSourceId<K,EV>
Emits the source vertex ID along with an initial count.
|
static class |
DegreeAnnotationFunctions.MapEdgeToTargetId<K,EV>
Emits the target vertex ID along with an initial count.
|
Modifier and Type | Class and Description |
---|---|
class |
EdgeToTuple2Map<K,EV>
Create a Tuple2 DataSet from the vertices of an Edge DataSet.
|
class |
EdgeToTuple3Map<K,EV>
Create a Tuple3 DataSet from an Edge DataSet.
|
static class |
GraphUtils.IdentityMapper<T>
The identity mapper returns the input as output.
|
class |
Tuple2ToEdgeMap<K>
Create an Edge from a Tuple2.
|
class |
Tuple2ToVertexMap<K,VV>
Create a Vertex DataSet from a Tuple2 DataSet.
|
class |
Tuple3ToEdgeMap<K,EV>
Create an Edge DataSet from a Tuple3 DataSet.
|
class |
VertexToTuple2Map<K,VV>
Create a Tuple2 DataSet from a Vertex DataSet.
|
Modifier and Type | Class and Description |
---|---|
class |
IdentityGroupReduce<IN>
Utility function to group and sort data.
|
class |
KeyDiscarder<T>
Utility function to extract the value from a Key-Value Tuple.
|
class |
NestedKeyDiscarder<IN>
Utility function to extract values from 2 Key-Value Tuples after a DefaultJoin.
|
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.