Class and Description |
---|
FData |
FlinkDataSource.Reducer
Used in MRQL total aggregations in FlinkEvaluator.aggregate
|
FlinkEvaluator
Evaluates physical plans in Apache Flink mode
|
FlinkJsonSplitter
Extract the JSON objects tagged by tags from a data split of the input stream (fsin)
|
FlinkMRQLFileInputFormat
A superclass for all MRQL FileInputFormats
|
FlinkParser
for a new text data source, you must implement a new parser
|
FlinkXMLSplitter
Extract the XML elements tagged by tags from a data split of the input stream (fsin)
and store them in a buffer (to be parsed by SAX).
|
LineReader |
Copyright © 2013-2016 The Apache Software Foundation. All Rights Reserved.