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 |
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.
|
Copyright © 2014–2024 The Apache Software Foundation. All rights reserved.