Class Summary
| Class |
Description |
| HadoopDummyProgressable |
This is a dummy progress.
|
| HadoopDummyReporter |
This is a dummy progress monitor / reporter.
|
| HadoopInputFormat<K,V> |
Wrapper for using HadoopInputFormats (mapred-variant) with Flink.
|
| HadoopInputFormat<K,V> |
InputFormat implementation allowing to use Hadoop (mapreduce) InputFormats with Flink.
|
| HadoopInputFormatBase<K,V,T> |
Common base for Java and Scala API for using Hadoop input formats with Flink.
|
| HadoopInputFormatBase<K,V,T> |
Base class shared between the Java and Scala API of Flink.
|
| HadoopInputFormatCommonBase<T,SPITTYPE extends org.apache.flink.core.io.InputSplit> |
A common base for both "mapred" and "mapreduce" Hadoop input formats.
|
| HadoopInputs |
HadoopInputs is a utility class to use Apache Hadoop InputFormats with Apache Flink.
|
| HadoopInputSplit |
A wrapper that represents an input split from the Hadoop mapred API as a Flink InputSplit.
|
| HadoopInputSplit |
A wrapper that represents an input split from the Hadoop mapreduce API as a Flink InputSplit.
|
| HadoopMapFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT> |
This wrapper maps a Hadoop Mapper (mapred API) to a Flink FlatMapFunction.
|
| HadoopOutputCollector<KEY,VALUE> |
A Hadoop OutputCollector that wraps a Flink OutputCollector.
|
| HadoopOutputFormat<K,V> |
Wrapper for using HadoopOutputFormats (mapred-variant) with Flink.
|
| HadoopOutputFormat<K,V> |
OutputFormat implementation allowing to use Hadoop (mapreduce) OutputFormats with Flink.
|
| HadoopOutputFormatBase<K,V,T> |
Common base for the mapred HadoopOutputFormat wrappers.
|
| HadoopOutputFormatBase<K,V,T> |
Base class shared between the Java and Scala API of Flink.
|
| HadoopOutputFormatCommonBase<T> |
A common base for both "mapred" and "mapreduce" Hadoop output formats.
|
| HadoopReducerWrappedFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT> |
This wrapper maps a Hadoop Reducer (mapred API) to a Flink window function.
|
| HadoopTupleUnwrappingIterator<KEY,VALUE> |
Wraps a Flink Tuple2 (key-value-pair) iterator into an iterator over the second (value) field.
|
| HadoopUtils |
Utility class to work with Apache Hadoop MapRed classes.
|
| HadoopUtils |
Utility class to work with next generation of Apache Hadoop MapReduce classes.
|
| HadoopUtils |
Utility class to work with Apache Hadoop libraries.
|
| WritableComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>> |
A TypeComparator for Writable.
|
| WritableSerializer<T extends org.apache.hadoop.io.Writable> |
A TypeSerializer for Writable.
|
| WritableSerializer.WritableSerializerSnapshot<T extends org.apache.hadoop.io.Writable> |
|
| WritableTypeInfo<T extends org.apache.hadoop.io.Writable> |
Type information for data types that extend Hadoop's Writable interface.
|