Serialized Form

Package org.apache.flink.examples.java.clustering

Class org.apache.flink.examples.java.clustering.KMeans.Centroid extends KMeans.Point implements Serializable

Serialized Fields

id

int id

Class org.apache.flink.examples.java.clustering.KMeans.CentroidAccumulator extends Object implements Serializable

Class org.apache.flink.examples.java.clustering.KMeans.CentroidAverager extends Object implements Serializable

Class org.apache.flink.examples.java.clustering.KMeans.CountAppender extends Object implements Serializable

Class org.apache.flink.examples.java.clustering.KMeans.Point extends Object implements Serializable

Serialized Fields

x

double x

y

double y

Class org.apache.flink.examples.java.clustering.KMeans.SelectNearestCenter extends org.apache.flink.api.common.functions.RichMapFunction<KMeans.Point,org.apache.flink.api.java.tuple.Tuple2<Integer,KMeans.Point>> implements Serializable

Serialized Fields

centroids

Collection<KMeans.Centroid> centroids

Package org.apache.flink.examples.java.distcp

Class org.apache.flink.examples.java.distcp.FileCopyTask extends Object implements Serializable

serialVersionUID:

-8760082278978316032L

Serialized Fields

path

org.apache.flink.core.fs.Path path

relativePath

String relativePath

Class org.apache.flink.examples.java.distcp.FileCopyTaskInputFormat extends Object implements Serializable

serialVersionUID:

-644394866425221151L

Serialized Fields

curInputSplit

FileCopyTaskInputSplit curInputSplit

tasks

List<FileCopyTask> tasks

Class org.apache.flink.examples.java.distcp.FileCopyTaskInputSplit extends Object implements Serializable

serialVersionUID:

-7621656017747660450L

Serialized Fields

splitNumber

int splitNumber

task

FileCopyTask task

Package org.apache.flink.examples.java.graph

Class org.apache.flink.examples.java.graph.ConnectedComponents.ComponentIdFilter extends Object implements Serializable

Class org.apache.flink.examples.java.graph.ConnectedComponents.DuplicateValue extends Object implements Serializable

Class org.apache.flink.examples.java.graph.ConnectedComponents.NeighborWithComponentIDJoin extends Object implements Serializable

Class org.apache.flink.examples.java.graph.ConnectedComponents.UndirectEdge extends Object implements Serializable

Serialized Fields

invertedEdge

org.apache.flink.api.java.tuple.Tuple2<Long,Long> invertedEdge

Class org.apache.flink.examples.java.graph.EnumTriangles.TupleEdgeConverter extends Object implements Serializable

Serialized Fields

outEdge

EnumTrianglesDataTypes.Edge outEdge

Class org.apache.flink.examples.java.graph.PageRank.BuildOutgoingEdgeList extends Object implements Serializable

Serialized Fields

neighbors

ArrayList<Long> neighbors

Class org.apache.flink.examples.java.graph.PageRank.Dampener extends Object implements Serializable

Serialized Fields

dampening

double dampening

randomJump

double randomJump

Class org.apache.flink.examples.java.graph.PageRank.EpsilonFilter extends Object implements Serializable

Class org.apache.flink.examples.java.graph.PageRank.JoinVertexWithEdgesMatch extends Object implements Serializable

Class org.apache.flink.examples.java.graph.PageRank.RankAssigner extends Object implements Serializable

Serialized Fields

outPageWithRank

org.apache.flink.api.java.tuple.Tuple2<Long,Double> outPageWithRank

Package org.apache.flink.examples.java.graph.util

Class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Edge extends org.apache.flink.api.java.tuple.Tuple2<Integer,Integer> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.EdgeWithDegrees extends org.apache.flink.api.java.tuple.Tuple4<Integer,Integer,Integer,Integer> implements Serializable

serialVersionUID:

1L

Class org.apache.flink.examples.java.graph.util.EnumTrianglesDataTypes.Triad extends org.apache.flink.api.java.tuple.Tuple3<Integer,Integer,Integer> implements Serializable

serialVersionUID:

1L

Package org.apache.flink.examples.java.misc

Class org.apache.flink.examples.java.misc.PiEstimation extends Object implements Serializable

Class org.apache.flink.examples.java.misc.PiEstimation.Sampler extends Object implements Serializable

Class org.apache.flink.examples.java.misc.PiEstimation.SumReducer extends Object implements Serializable

Package org.apache.flink.examples.java.relational

Class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.EmptyFieldFilter extends org.apache.flink.api.common.functions.RichFilterFunction<EmptyFieldsCountAccumulator.StringTriple> implements Serializable

Serialized Fields

emptyFieldCounter

EmptyFieldsCountAccumulator.VectorAccumulator emptyFieldCounter

Class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.StringTriple extends org.apache.flink.api.java.tuple.Tuple3<String,String,String> implements Serializable

Class org.apache.flink.examples.java.relational.EmptyFieldsCountAccumulator.VectorAccumulator extends Object implements Serializable

Serialized Fields

resultVector

ArrayList<Integer> resultVector

Stores the accumulated vector components.

Class org.apache.flink.examples.java.relational.TPCHQuery3.Customer extends org.apache.flink.api.java.tuple.Tuple2<Long,String> implements Serializable

Class org.apache.flink.examples.java.relational.TPCHQuery3.Lineitem extends org.apache.flink.api.java.tuple.Tuple4<Long,Double,Double,String> implements Serializable

Class org.apache.flink.examples.java.relational.TPCHQuery3.Order extends org.apache.flink.api.java.tuple.Tuple4<Long,Long,String,Long> implements Serializable

Class org.apache.flink.examples.java.relational.TPCHQuery3.ShippingPriorityItem extends org.apache.flink.api.java.tuple.Tuple4<Long,Double,String,Long> implements Serializable

Class org.apache.flink.examples.java.relational.WebLogAnalysis.AntiJoinVisits extends Object implements Serializable

Class org.apache.flink.examples.java.relational.WebLogAnalysis.FilterByRank extends Object implements Serializable

Class org.apache.flink.examples.java.relational.WebLogAnalysis.FilterDocByKeyWords extends Object implements Serializable

Class org.apache.flink.examples.java.relational.WebLogAnalysis.FilterVisitsByDate extends Object implements Serializable

Package org.apache.flink.examples.java.wordcount

Class org.apache.flink.examples.java.wordcount.WordCount.Tokenizer extends Object implements Serializable

Class org.apache.flink.examples.java.wordcount.WordCountPojo.Tokenizer extends Object implements Serializable