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.generator | |
org.apache.flink.graph.library | |
org.apache.flink.graph.pregel | |
org.apache.flink.graph.utils | |
org.apache.flink.python.api.functions.util |
Modifier and Type | Class and Description |
---|---|
class |
KeyExtractingMapper<T,K> |
class |
KeyRemovingMapper<T,K> |
class |
PlanFilterOperator<T> |
class |
TwoKeyExtractingMapper<T,K1,K2> |
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 |
CompleteGraph.LinkVertexToAll |
class |
GridGraph.LinkVertexToNeighbors |
class |
StarGraph.LinkVertexToCenter |
Modifier and Type | Class and Description |
---|---|
static class |
CommunityDetection.AddScoreToVertexValuesMapper<K> |
Modifier and Type | Class and Description |
---|---|
static class |
VertexCentricIteration.MessageCombinerUdf<K,Message> |
Modifier and Type | Class and Description |
---|---|
class |
EdgeToTuple3Map<K,EV>
Create a Tuple3 DataSet from an Edge DataSet
|
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 |
KeyDiscarder<T> |
class |
NestedKeyDiscarder<IN> |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.