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