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

Class Summary

Class	Description
EmptyFieldsCountAccumulator	This program filters lines from a CSV file with empty fields.
EmptyFieldsCountAccumulator.EmptyFieldFilter	This function filters all incoming tuples that have one or more empty fields.
EmptyFieldsCountAccumulator.StringTriple	It is recommended to use POJOs (Plain old Java objects) instead of TupleX for data types with many fields.
EmptyFieldsCountAccumulator.VectorAccumulator	This accumulator maintains a vector of counts.
TPCHQuery10	This program implements a modified version of the TPC-H query 10.
TPCHQuery3	This program implements a modified version of the TPC-H query 3.
TPCHQuery3.Customer	Customer.
TPCHQuery3.Lineitem	Lineitem.
TPCHQuery3.Order	Order.
TPCHQuery3.ShippingPriorityItem	ShippingPriorityItem.
WebLogAnalysis	This program processes web logs and relational data.
WebLogAnalysis.AntiJoinVisits	CoGroupFunction that realizes an anti-join.
WebLogAnalysis.FilterByRank	MapFunction that filters for records where the rank exceeds a certain threshold.
WebLogAnalysis.FilterDocByKeyWords	MapFunction that filters for documents that contain a certain set of keywords.
WebLogAnalysis.FilterVisitsByDate	MapFunction that filters for records of the visits relation where the year (from the date string) is equal to a certain value.