A B C D E F G I J K L M N O P R S T U V W X Y
All Classes All Packages

A

add(Integer) - Method in class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.VectorAccumulator

Increases the result vector component at the specified position by 1.

add(KMeans.Point) - Method in class org.apache.flink.examples.java.clustering.KMeans.Point

AntiJoinVisits() - Constructor for class org.apache.flink.examples.java.relational.WebLogAnalysis.AntiJoinVisits

B

body - Variable in class org.apache.flink.examples.java.misc.CollectionExecutionExample.EMail

BuildOutgoingEdgeList() - Constructor for class org.apache.flink.examples.java.graph.PageRank.BuildOutgoingEdgeList

BYTES_COPIED_CNT_NAME - Static variable in class org.apache.flink.examples.java.distcp.DistCp

C

Centroid() - Constructor for class org.apache.flink.examples.java.clustering.KMeans.Centroid

Centroid(int, double, double) - Constructor for class org.apache.flink.examples.java.clustering.KMeans.Centroid

Centroid(int, KMeans.Point) - Constructor for class org.apache.flink.examples.java.clustering.KMeans.Centroid

CentroidAccumulator() - Constructor for class org.apache.flink.examples.java.clustering.KMeans.CentroidAccumulator

CentroidAverager() - Constructor for class org.apache.flink.examples.java.clustering.KMeans.CentroidAverager

CENTROIDS - Static variable in class org.apache.flink.examples.java.clustering.util.KMeansData

clear() - Method in class org.apache.flink.examples.java.clustering.KMeans.Point

clone() - Method in class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.VectorAccumulator

close() - Method in class org.apache.flink.examples.java.distcp.FileCopyTaskInputFormat

coGroup(Iterable<Tuple3<Integer, String, Integer>>, Iterable<Tuple1<String>>, Collector<Tuple3<Integer, String, Integer>>) - Method in class org.apache.flink.examples.java.relational.WebLogAnalysis.AntiJoinVisits

If the visit iterator is empty, all pairs of the rank iterator are emitted.

CollectionExecutionExample - Class in org.apache.flink.examples.java.misc

This example shows how to use the collection based execution of Flink.

CollectionExecutionExample() - Constructor for class org.apache.flink.examples.java.misc.CollectionExecutionExample

CollectionExecutionExample.EMail - Class in org.apache.flink.examples.java.misc

POJO for an EMail.

CollectionExecutionExample.User - Class in org.apache.flink.examples.java.misc

POJO class representing a user.

ComponentIdFilter() - Constructor for class org.apache.flink.examples.java.graph.ConnectedComponents.ComponentIdFilter

configure(Configuration) - Method in class org.apache.flink.examples.java.distcp.FileCopyTaskInputFormat

ConnectedComponents - Class in org.apache.flink.examples.java.graph

An implementation of the connected components algorithm, using a delta iteration.

ConnectedComponents() - Constructor for class org.apache.flink.examples.java.graph.ConnectedComponents

ConnectedComponents.ComponentIdFilter - Class in org.apache.flink.examples.java.graph

Emit the candidate (Vertex-ID, Component-ID) pair if and only if the candidate component ID is less than the vertex's current component ID.

ConnectedComponents.DuplicateValue<T> - Class in org.apache.flink.examples.java.graph

Function that turns a value into a 2-tuple where both fields are that value.

ConnectedComponents.NeighborWithComponentIDJoin - Class in org.apache.flink.examples.java.graph

UDF that joins a (Vertex-ID, Component-ID) pair that represents the current component that a vertex is associated with, with a (Source-Vertex-ID, Target-VertexID) edge.

ConnectedComponents.UndirectEdge - Class in org.apache.flink.examples.java.graph

Undirected edges by emitting for each input edge the input edges itself and an inverted version.

ConnectedComponentsData - Class in org.apache.flink.examples.java.graph.util

Provides the default data sets used for the Connected Components example program.

ConnectedComponentsData() - Constructor for class org.apache.flink.examples.java.graph.util.ConnectedComponentsData

copyFrom(EnumTrianglesDataTypes.EdgeWithDegrees) - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees

copyVerticesFromEdgeWithDegrees(EnumTrianglesDataTypes.EdgeWithDegrees) - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Edge

copyVerticesFromTuple2(Tuple2<Integer, Integer>) - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Edge

CountAppender() - Constructor for class org.apache.flink.examples.java.clustering.KMeans.CountAppender

createInputSplits(int) - Method in class org.apache.flink.examples.java.distcp.FileCopyTaskInputFormat

Customer() - Constructor for class org.apache.flink.examples.java.relational.TPCHQuery3.Customer

D

D1 - Static variable in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees

D2 - Static variable in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees

Dampener(double, double) - Constructor for class org.apache.flink.examples.java.graph.PageRank.Dampener

DATASET_DEPRECATION_INFO - Static variable in class org.apache.flink.examples.java.util.DataSetDeprecationInfo

DataSetDeprecationInfo - Class in org.apache.flink.examples.java.util

The info about the deprecation of DataSet API.

DataSetDeprecationInfo() - Constructor for class org.apache.flink.examples.java.util.DataSetDeprecationInfo

DistCp - Class in org.apache.flink.examples.java.distcp

A main class of the Flink distcp utility.

DistCp() - Constructor for class org.apache.flink.examples.java.distcp.DistCp

div(long) - Method in class org.apache.flink.examples.java.clustering.KMeans.Point

DOCUMENTS - Static variable in class org.apache.flink.examples.java.relational.util.WebLogData

DuplicateValue() - Constructor for class org.apache.flink.examples.java.graph.ConnectedComponents.DuplicateValue

E

Edge() - Constructor for class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Edge

Edge(Integer, Integer) - Constructor for class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Edge

EDGES - Static variable in class org.apache.flink.examples.java.graph.util.ConnectedComponentsData

EDGES - Static variable in class org.apache.flink.examples.java.graph.util.EnumTrianglesData

EDGES - Static variable in class org.apache.flink.examples.java.graph.util.PageRankData

EdgeWithDegrees() - Constructor for class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees

EMail() - Constructor for class org.apache.flink.examples.java.misc.CollectionExecutionExample.EMail

EMail(int, String, String) - Constructor for class org.apache.flink.examples.java.misc.CollectionExecutionExample.EMail

EmptyFieldFilter() - Constructor for class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.EmptyFieldFilter

EmptyFieldsCountAccumulator - Class in org.apache.flink.examples.java.relational

This program filters lines from a CSV file with empty fields.

EmptyFieldsCountAccumulator() - Constructor for class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator

EmptyFieldsCountAccumulator.EmptyFieldFilter - Class in org.apache.flink.examples.java.relational

This function filters all incoming tuples that have one or more empty fields.

EmptyFieldsCountAccumulator.StringTriple - Class in org.apache.flink.examples.java.relational

It is recommended to use POJOs (Plain old Java objects) instead of TupleX for data types with many fields.

EmptyFieldsCountAccumulator.VectorAccumulator - Class in org.apache.flink.examples.java.relational

This accumulator maintains a vector of counts.

EnumTriangles - Class in org.apache.flink.examples.java.graph

Triangle enumeration is a pre-processing step to find closely connected parts in graphs.

EnumTriangles() - Constructor for class org.apache.flink.examples.java.graph.EnumTriangles

EnumTriangles.TupleEdgeConverter - Class in org.apache.flink.examples.java.graph

Converts a Tuple2 into an Edge.

EnumTrianglesData - Class in org.apache.flink.examples.java.graph.util

Provides the default data sets used for the Triangle Enumeration example programs.

EnumTrianglesData() - Constructor for class org.apache.flink.examples.java.graph.util.EnumTrianglesData

EnumTrianglesDataTypes - Class in org.apache.flink.examples.java.graph.util

The data classes for EnumTriangles.

EnumTrianglesDataTypes() - Constructor for class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes

EnumTrianglesDataTypes.Edge - Class in org.apache.flink.examples.java.graph.util

A POJO storing two vertex IDs.

EnumTrianglesDataTypes.EdgeWithDegrees - Class in org.apache.flink.examples.java.graph.util

A POJO storing two vertex IDs with degree.

EnumTrianglesDataTypes.Triad - Class in org.apache.flink.examples.java.graph.util

A POJO storing three vertex IDs.

EpsilonFilter() - Constructor for class org.apache.flink.examples.java.graph.PageRank.EpsilonFilter

euclideanDistance(KMeans.Point) - Method in class org.apache.flink.examples.java.clustering.KMeans.Point

F

FileCopyTask - Class in org.apache.flink.examples.java.distcp

A Java POJO that represents a task for copying a single file.

FileCopyTask(Path, String) - Constructor for class org.apache.flink.examples.java.distcp.FileCopyTask

FileCopyTaskInputFormat - Class in org.apache.flink.examples.java.distcp

An implementation of an input format that dynamically assigns FileCopyTask to the mappers that have finished previously assigned tasks.

FileCopyTaskInputFormat(List<FileCopyTask>) - Constructor for class org.apache.flink.examples.java.distcp.FileCopyTaskInputFormat

FileCopyTaskInputSplit - Class in org.apache.flink.examples.java.distcp

Implementation of InputSplit for copying files.

FileCopyTaskInputSplit(FileCopyTask, int) - Constructor for class org.apache.flink.examples.java.distcp.FileCopyTaskInputSplit

FILES_COPIED_CNT_NAME - Static variable in class org.apache.flink.examples.java.distcp.DistCp

filter(Tuple2<String, String>) - Method in class org.apache.flink.examples.java.relational.WebLogAnalysis.FilterDocByKeyWords

Filters for documents that contain all of the given keywords and projects the records on the URL field.

filter(Tuple2<String, String>) - Method in class org.apache.flink.examples.java.relational.WebLogAnalysis.FilterVisitsByDate

Filters for records of the visits relation where the year of visit is equal to a specified value.

filter(Tuple2<Tuple2<Long, Double>, Tuple2<Long, Double>>) - Method in class org.apache.flink.examples.java.graph.PageRank.EpsilonFilter

filter(Tuple3<Integer, String, Integer>) - Method in class org.apache.flink.examples.java.relational.WebLogAnalysis.FilterByRank

Filters for records of the rank relation where the rank is greater than the given threshold.

filter(EmptyFieldsCountAccumulator.StringTriple) - Method in class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.EmptyFieldFilter

FilterByRank() - Constructor for class org.apache.flink.examples.java.relational.WebLogAnalysis.FilterByRank

FilterDocByKeyWords() - Constructor for class org.apache.flink.examples.java.relational.WebLogAnalysis.FilterDocByKeyWords

FilterVisitsByDate() - Constructor for class org.apache.flink.examples.java.relational.WebLogAnalysis.FilterVisitsByDate

flatMap(String, Collector<Tuple2<String, Integer>>) - Method in class org.apache.flink.examples.java.wordcount.WordCount.Tokenizer

flatMap(String, Collector<WordCountPojo.Word>) - Method in class org.apache.flink.examples.java.wordcount.WordCountPojo.Tokenizer

flatMap(Tuple2<Long, Long>, Collector<Tuple2<Long, Long>>) - Method in class org.apache.flink.examples.java.graph.ConnectedComponents.UndirectEdge

flatMap(Tuple2<Tuple2<Long, Double>, Tuple2<Long, Long[]>>, Collector<Tuple2<Long, Double>>) - Method in class org.apache.flink.examples.java.graph.PageRank.JoinVertexWithEdgesMatch

flipVertices() - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Edge

G

getCustKey() - Method in class org.apache.flink.examples.java.relational.TPCHQuery3.Customer

getCustKey() - Method in class org.apache.flink.examples.java.relational.TPCHQuery3.Order

getDefaultCentroidDataSet(ExecutionEnvironment) - Static method in class org.apache.flink.examples.java.clustering.util.KMeansData

getDefaultEdgeDataSet(ExecutionEnvironment) - Static method in class org.apache.flink.examples.java.graph.util.ConnectedComponentsData

getDefaultEdgeDataSet(ExecutionEnvironment) - Static method in class org.apache.flink.examples.java.graph.util.EnumTrianglesData

getDefaultEdgeDataSet(ExecutionEnvironment) - Static method in class org.apache.flink.examples.java.graph.util.PageRankData

getDefaultPagesDataSet(ExecutionEnvironment) - Static method in class org.apache.flink.examples.java.graph.util.PageRankData

getDefaultPointDataSet(ExecutionEnvironment) - Static method in class org.apache.flink.examples.java.clustering.util.KMeansData

getDefaultTextLineDataSet(ExecutionEnvironment) - Static method in class org.apache.flink.examples.java.wordcount.util.WordCountData

getDefaultVertexDataSet(ExecutionEnvironment) - Static method in class org.apache.flink.examples.java.graph.util.ConnectedComponentsData

getDiscount() - Method in class org.apache.flink.examples.java.relational.TPCHQuery3.Lineitem

getDocumentDataSet(ExecutionEnvironment) - Static method in class org.apache.flink.examples.java.relational.util.WebLogData

getExtendedprice() - Method in class org.apache.flink.examples.java.relational.TPCHQuery3.Lineitem

getFirstDegree() - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees

getFirstVertex() - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Edge

getFirstVertex() - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees

getFrequency() - Method in class org.apache.flink.examples.java.wordcount.WordCountPojo.Word

getInputSplitAssigner(FileCopyTaskInputSplit[]) - Method in class org.apache.flink.examples.java.distcp.FileCopyTaskInputFormat

getLocalValue() - Method in class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.VectorAccumulator

getMktsegment() - Method in class org.apache.flink.examples.java.relational.TPCHQuery3.Customer

getNumberOfPages() - Static method in class org.apache.flink.examples.java.graph.util.PageRankData

getOrderdate() - Method in class org.apache.flink.examples.java.relational.TPCHQuery3.Order

getOrderdate() - Method in class org.apache.flink.examples.java.relational.TPCHQuery3.ShippingPriorityItem

getOrderkey() - Method in class org.apache.flink.examples.java.relational.TPCHQuery3.Lineitem

getOrderkey() - Method in class org.apache.flink.examples.java.relational.TPCHQuery3.ShippingPriorityItem

getOrderKey() - Method in class org.apache.flink.examples.java.relational.TPCHQuery3.Order

getPath() - Method in class org.apache.flink.examples.java.distcp.FileCopyTask

getRankDataSet(ExecutionEnvironment) - Static method in class org.apache.flink.examples.java.relational.util.WebLogData

getRelativePath() - Method in class org.apache.flink.examples.java.distcp.FileCopyTask

getRevenue() - Method in class org.apache.flink.examples.java.relational.TPCHQuery3.ShippingPriorityItem

getSecondDegree() - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees

getSecondVertex() - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Edge

getSecondVertex() - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees

getShipdate() - Method in class org.apache.flink.examples.java.relational.TPCHQuery3.Lineitem

getShippriority() - Method in class org.apache.flink.examples.java.relational.TPCHQuery3.Order

getShippriority() - Method in class org.apache.flink.examples.java.relational.TPCHQuery3.ShippingPriorityItem

getSplitNumber() - Method in class org.apache.flink.examples.java.distcp.FileCopyTaskInputSplit

getStatistics(BaseStatistics) - Method in class org.apache.flink.examples.java.distcp.FileCopyTaskInputFormat

getTask() - Method in class org.apache.flink.examples.java.distcp.FileCopyTaskInputSplit

getVisitDataSet(ExecutionEnvironment) - Static method in class org.apache.flink.examples.java.relational.util.WebLogData

getWord() - Method in class org.apache.flink.examples.java.wordcount.WordCountPojo.Word

I

id - Variable in class org.apache.flink.examples.java.clustering.KMeans.Centroid

J

join(Tuple2<Long, Long>, Tuple2<Long, Long>) - Method in class org.apache.flink.examples.java.graph.ConnectedComponents.NeighborWithComponentIDJoin

join(Tuple2<Long, Long>, Tuple2<Long, Long>, Collector<Tuple2<Long, Long>>) - Method in class org.apache.flink.examples.java.graph.ConnectedComponents.ComponentIdFilter

JoinVertexWithEdgesMatch() - Constructor for class org.apache.flink.examples.java.graph.PageRank.JoinVertexWithEdgesMatch

K

KMeans - Class in org.apache.flink.examples.java.clustering

This example implements a basic K-Means clustering algorithm.

KMeans() - Constructor for class org.apache.flink.examples.java.clustering.KMeans

KMeans.Centroid - Class in org.apache.flink.examples.java.clustering

A simple two-dimensional centroid, basically a point with an ID.

KMeans.CentroidAccumulator - Class in org.apache.flink.examples.java.clustering

Sums and counts point coordinates.

KMeans.CentroidAverager - Class in org.apache.flink.examples.java.clustering

Computes new centroid from coordinate sum and count of points.

KMeans.CountAppender - Class in org.apache.flink.examples.java.clustering

Appends a count variable to the tuple.

KMeans.Point - Class in org.apache.flink.examples.java.clustering

A simple two-dimensional point.

KMeans.SelectNearestCenter - Class in org.apache.flink.examples.java.clustering

Determines the closest cluster center for a data point.

KMeansData - Class in org.apache.flink.examples.java.clustering.util

Provides the default data sets used for the K-Means example program.

KMeansData() - Constructor for class org.apache.flink.examples.java.clustering.util.KMeansData

KMeansDataGenerator - Class in org.apache.flink.examples.java.clustering.util

Generates data for the KMeans example program.

KMeansDataGenerator() - Constructor for class org.apache.flink.examples.java.clustering.util.KMeansDataGenerator

L

Lineitem() - Constructor for class org.apache.flink.examples.java.relational.TPCHQuery3.Lineitem

M

main(String[]) - Static method in class org.apache.flink.examples.java.clustering.KMeans

main(String[]) - Static method in class org.apache.flink.examples.java.clustering.util.KMeansDataGenerator

Main method to generate data for the KMeans example program.

main(String[]) - Static method in class org.apache.flink.examples.java.distcp.DistCp

main(String...) - Static method in class org.apache.flink.examples.java.graph.ConnectedComponents

main(String[]) - Static method in class org.apache.flink.examples.java.graph.EnumTriangles

main(String[]) - Static method in class org.apache.flink.examples.java.graph.PageRank

main(String...) - Static method in class org.apache.flink.examples.java.graph.TransitiveClosureNaive

main(String[]) - Static method in class org.apache.flink.examples.java.misc.CollectionExecutionExample

main(String[]) - Static method in class org.apache.flink.examples.java.misc.PiEstimation

main(String[]) - Static method in class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator

main(String[]) - Static method in class org.apache.flink.examples.java.relational.TPCHQuery10

main(String[]) - Static method in class org.apache.flink.examples.java.relational.TPCHQuery3

main(String[]) - Static method in class org.apache.flink.examples.java.relational.util.WebLogDataGenerator

Main method to generate data for the WebLogAnalysis example program.

main(String[]) - Static method in class org.apache.flink.examples.java.relational.WebLogAnalysis

main(String[]) - Static method in class org.apache.flink.examples.java.wordcount.WordCount

main(String[]) - Static method in class org.apache.flink.examples.java.wordcount.WordCountPojo

map(Long) - Method in class org.apache.flink.examples.java.graph.PageRank.RankAssigner

map(Long) - Method in class org.apache.flink.examples.java.misc.PiEstimation.Sampler

map(Tuple2<Integer, Integer>) - Method in class org.apache.flink.examples.java.graph.EnumTriangles.TupleEdgeConverter

map(Tuple2<Integer, KMeans.Point>) - Method in class org.apache.flink.examples.java.clustering.KMeans.CountAppender

map(Tuple2<Long, Double>) - Method in class org.apache.flink.examples.java.graph.PageRank.Dampener

map(Tuple3<Integer, KMeans.Point, Long>) - Method in class org.apache.flink.examples.java.clustering.KMeans.CentroidAverager

map(KMeans.Point) - Method in class org.apache.flink.examples.java.clustering.KMeans.SelectNearestCenter

map(T) - Method in class org.apache.flink.examples.java.graph.ConnectedComponents.DuplicateValue

merge(Accumulator<Integer, ArrayList<Integer>>) - Method in class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.VectorAccumulator

N

name - Variable in class org.apache.flink.examples.java.misc.CollectionExecutionExample.User

NeighborWithComponentIDJoin() - Constructor for class org.apache.flink.examples.java.graph.ConnectedComponents.NeighborWithComponentIDJoin

nextRecord(FileCopyTask) - Method in class org.apache.flink.examples.java.distcp.FileCopyTaskInputFormat

O

open(OpenContext) - Method in class org.apache.flink.examples.java.clustering.KMeans.SelectNearestCenter

Reads the centroid values from a broadcast variable into a collection.

open(OpenContext) - Method in class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.EmptyFieldFilter

open(FileCopyTaskInputSplit) - Method in class org.apache.flink.examples.java.distcp.FileCopyTaskInputFormat

Order() - Constructor for class org.apache.flink.examples.java.relational.TPCHQuery3.Order

org.apache.flink.examples.java.clustering - package org.apache.flink.examples.java.clustering

org.apache.flink.examples.java.clustering.util - package org.apache.flink.examples.java.clustering.util

org.apache.flink.examples.java.distcp - package org.apache.flink.examples.java.distcp

org.apache.flink.examples.java.graph - package org.apache.flink.examples.java.graph

org.apache.flink.examples.java.graph.util - package org.apache.flink.examples.java.graph.util

org.apache.flink.examples.java.misc - package org.apache.flink.examples.java.misc

org.apache.flink.examples.java.relational - package org.apache.flink.examples.java.relational

org.apache.flink.examples.java.relational.util - package org.apache.flink.examples.java.relational.util

org.apache.flink.examples.java.util - package org.apache.flink.examples.java.util

org.apache.flink.examples.java.wordcount - package org.apache.flink.examples.java.wordcount

org.apache.flink.examples.java.wordcount.util - package org.apache.flink.examples.java.wordcount.util

P

PageRank - Class in org.apache.flink.examples.java.graph

A basic implementation of the Page Rank algorithm using a bulk iteration.

PageRank() - Constructor for class org.apache.flink.examples.java.graph.PageRank

PageRank.BuildOutgoingEdgeList - Class in org.apache.flink.examples.java.graph

A reduce function that takes a sequence of edges and builds the adjacency list for the vertex where the edges originate.

PageRank.Dampener - Class in org.apache.flink.examples.java.graph

The function that applies the page rank dampening formula.

PageRank.EpsilonFilter - Class in org.apache.flink.examples.java.graph

Filter that filters vertices where the rank difference is below a threshold.

PageRank.JoinVertexWithEdgesMatch - Class in org.apache.flink.examples.java.graph

Join function that distributes a fraction of a vertex's rank to all neighbors.

PageRank.RankAssigner - Class in org.apache.flink.examples.java.graph

A map function that assigns an initial rank to all pages.

PageRankData - Class in org.apache.flink.examples.java.graph.util

Provides the default data sets used for the PageRank example program.

PageRankData() - Constructor for class org.apache.flink.examples.java.graph.util.PageRankData

PiEstimation - Class in org.apache.flink.examples.java.misc

Estimates the value of Pi using the Monte Carlo method.

PiEstimation() - Constructor for class org.apache.flink.examples.java.misc.PiEstimation

PiEstimation.Sampler - Class in org.apache.flink.examples.java.misc

Sampler randomly emits points that fall within a square of edge x * y.

PiEstimation.SumReducer - Class in org.apache.flink.examples.java.misc

Simply sums up all long values.

Point() - Constructor for class org.apache.flink.examples.java.clustering.KMeans.Point

Point(double, double) - Constructor for class org.apache.flink.examples.java.clustering.KMeans.Point

POINTS - Static variable in class org.apache.flink.examples.java.clustering.util.KMeansData

R

RankAssigner(double) - Constructor for class org.apache.flink.examples.java.graph.PageRank.RankAssigner

RANKS - Static variable in class org.apache.flink.examples.java.relational.util.WebLogData

reachedEnd() - Method in class org.apache.flink.examples.java.distcp.FileCopyTaskInputFormat

reduce(Iterable<Tuple2<Long, Long>>, Collector<Tuple2<Long, Long[]>>) - Method in class org.apache.flink.examples.java.graph.PageRank.BuildOutgoingEdgeList

reduce(Long, Long) - Method in class org.apache.flink.examples.java.misc.PiEstimation.SumReducer

reduce(Tuple3<Integer, KMeans.Point, Long>, Tuple3<Integer, KMeans.Point, Long>) - Method in class org.apache.flink.examples.java.clustering.KMeans.CentroidAccumulator

resetLocal() - Method in class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.VectorAccumulator

S

Sampler() - Constructor for class org.apache.flink.examples.java.misc.PiEstimation.Sampler

SelectNearestCenter() - Constructor for class org.apache.flink.examples.java.clustering.KMeans.SelectNearestCenter

setFirstDegree(Integer) - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees

setFirstVertex(Integer) - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Edge

setFirstVertex(Integer) - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees

setFirstVertex(Integer) - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Triad

setFrequency(int) - Method in class org.apache.flink.examples.java.wordcount.WordCountPojo.Word

setOrderkey(Long) - Method in class org.apache.flink.examples.java.relational.TPCHQuery3.ShippingPriorityItem

setRevenue(Double) - Method in class org.apache.flink.examples.java.relational.TPCHQuery3.ShippingPriorityItem

setSecondDegree(Integer) - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees

setSecondVertex(Integer) - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Edge

setSecondVertex(Integer) - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees

setSecondVertex(Integer) - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Triad

setThirdVertex(Integer) - Method in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Triad

setWord(String) - Method in class org.apache.flink.examples.java.wordcount.WordCountPojo.Word

ShippingPriorityItem() - Constructor for class org.apache.flink.examples.java.relational.TPCHQuery3.ShippingPriorityItem

ShippingPriorityItem(Long, Double, String, Long) - Constructor for class org.apache.flink.examples.java.relational.TPCHQuery3.ShippingPriorityItem

StringTriple() - Constructor for class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.StringTriple

StringTriple(String, String, String) - Constructor for class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.StringTriple

subject - Variable in class org.apache.flink.examples.java.misc.CollectionExecutionExample.EMail

SumReducer() - Constructor for class org.apache.flink.examples.java.misc.PiEstimation.SumReducer

T

Tokenizer() - Constructor for class org.apache.flink.examples.java.wordcount.WordCount.Tokenizer

Tokenizer() - Constructor for class org.apache.flink.examples.java.wordcount.WordCountPojo.Tokenizer

toString() - Method in class org.apache.flink.examples.java.clustering.KMeans.Centroid

toString() - Method in class org.apache.flink.examples.java.clustering.KMeans.Point

toString() - Method in class org.apache.flink.examples.java.distcp.FileCopyTask

toString() - Method in class org.apache.flink.examples.java.misc.CollectionExecutionExample.EMail

toString() - Method in class org.apache.flink.examples.java.misc.CollectionExecutionExample.User

toString() - Method in class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.VectorAccumulator

toString() - Method in class org.apache.flink.examples.java.wordcount.WordCountPojo.Word

TPCHQuery10 - Class in org.apache.flink.examples.java.relational

This program implements a modified version of the TPC-H query 10.

TPCHQuery10() - Constructor for class org.apache.flink.examples.java.relational.TPCHQuery10

TPCHQuery3 - Class in org.apache.flink.examples.java.relational

This program implements a modified version of the TPC-H query 3.

TPCHQuery3() - Constructor for class org.apache.flink.examples.java.relational.TPCHQuery3

TPCHQuery3.Customer - Class in org.apache.flink.examples.java.relational

Customer.

TPCHQuery3.Lineitem - Class in org.apache.flink.examples.java.relational

Lineitem.

TPCHQuery3.Order - Class in org.apache.flink.examples.java.relational

Order.

TPCHQuery3.ShippingPriorityItem - Class in org.apache.flink.examples.java.relational

ShippingPriorityItem.

TransitiveClosureNaive - Class in org.apache.flink.examples.java.graph

The transitive closure of a graph contains an edge for each pair of vertices which are endpoints of at least one path in the graph.

TransitiveClosureNaive() - Constructor for class org.apache.flink.examples.java.graph.TransitiveClosureNaive

Triad() - Constructor for class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Triad

TupleEdgeConverter() - Constructor for class org.apache.flink.examples.java.graph.EnumTriangles.TupleEdgeConverter

U

UndirectEdge() - Constructor for class org.apache.flink.examples.java.graph.ConnectedComponents.UndirectEdge

User() - Constructor for class org.apache.flink.examples.java.misc.CollectionExecutionExample.User

User(int, String) - Constructor for class org.apache.flink.examples.java.misc.CollectionExecutionExample.User

userId - Variable in class org.apache.flink.examples.java.misc.CollectionExecutionExample.EMail

userIdentifier - Variable in class org.apache.flink.examples.java.misc.CollectionExecutionExample.User

V

V1 - Static variable in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Edge

V1 - Static variable in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees

V1 - Static variable in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Triad

V2 - Static variable in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Edge

V2 - Static variable in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees

V2 - Static variable in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Triad

V3 - Static variable in class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Triad

VectorAccumulator() - Constructor for class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.VectorAccumulator

VectorAccumulator(ArrayList<Integer>) - Constructor for class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.VectorAccumulator

VERTICES - Static variable in class org.apache.flink.examples.java.graph.util.ConnectedComponentsData

VISITS - Static variable in class org.apache.flink.examples.java.relational.util.WebLogData

W

WebLogAnalysis - Class in org.apache.flink.examples.java.relational

This program processes web logs and relational data.

WebLogAnalysis() - Constructor for class org.apache.flink.examples.java.relational.WebLogAnalysis

WebLogAnalysis.AntiJoinVisits - Class in org.apache.flink.examples.java.relational

CoGroupFunction that realizes an anti-join.

WebLogAnalysis.FilterByRank - Class in org.apache.flink.examples.java.relational

MapFunction that filters for records where the rank exceeds a certain threshold.

WebLogAnalysis.FilterDocByKeyWords - Class in org.apache.flink.examples.java.relational

MapFunction that filters for documents that contain a certain set of keywords.

WebLogAnalysis.FilterVisitsByDate - Class in org.apache.flink.examples.java.relational

MapFunction that filters for records of the visits relation where the year (from the date string) is equal to a certain value.

WebLogData - Class in org.apache.flink.examples.java.relational.util

Provides the default data sets used for the Weblog Analysis example program.

WebLogData() - Constructor for class org.apache.flink.examples.java.relational.util.WebLogData

WebLogDataGenerator - Class in org.apache.flink.examples.java.relational.util

Data generator for the WebLogAnalysis example program.

WebLogDataGenerator() - Constructor for class org.apache.flink.examples.java.relational.util.WebLogDataGenerator

Word() - Constructor for class org.apache.flink.examples.java.wordcount.WordCountPojo.Word

Word(String, int) - Constructor for class org.apache.flink.examples.java.wordcount.WordCountPojo.Word

WordCount - Class in org.apache.flink.examples.java.wordcount

Implements the "WordCount" program that computes a simple word occurrence histogram over text files.

WordCount() - Constructor for class org.apache.flink.examples.java.wordcount.WordCount

WordCount.Tokenizer - Class in org.apache.flink.examples.java.wordcount

Implements the string tokenizer that splits sentences into words as a user-defined FlatMapFunction.

WordCountData - Class in org.apache.flink.examples.java.wordcount.util

Provides the default data sets used for the WordCount example program.

WordCountData() - Constructor for class org.apache.flink.examples.java.wordcount.util.WordCountData

WordCountPojo - Class in org.apache.flink.examples.java.wordcount

This example shows an implementation of WordCount without using the Tuple2 type, but a custom class.

WordCountPojo() - Constructor for class org.apache.flink.examples.java.wordcount.WordCountPojo

WordCountPojo.Tokenizer - Class in org.apache.flink.examples.java.wordcount

Implements the string tokenizer that splits sentences into words as a user-defined FlatMapFunction.

WordCountPojo.Word - Class in org.apache.flink.examples.java.wordcount

This is the POJO (Plain Old Java Object) that is being used for all the operations.

WORDS - Static variable in class org.apache.flink.examples.java.wordcount.util.WordCountData

X

x - Variable in class org.apache.flink.examples.java.clustering.KMeans.Point

Y

y - Variable in class org.apache.flink.examples.java.clustering.KMeans.Point

A B C D E F G I J K L M N O P R S T U V W X Y
All Classes All Packages