Modifier and Type | Class and Description |
---|---|
class |
HBaseRowInputFormat
InputFormat subclass that wraps the access for HTables. |
Modifier and Type | Class and Description |
---|---|
class |
HadoopInputFormat<K,V>
InputFormat implementation allowing to use Hadoop (mapreduce) InputFormats with Flink.
|
Modifier and Type | Class and Description |
---|---|
class |
AvroInputFormat<E>
Provides a
FileInputFormat for Avro records. |
class |
RowCsvInputFormat |
class |
TypeSerializerInputFormat<T>
Reads elements by deserializing them with a given type serializer.
|
Modifier and Type | Class and Description |
---|---|
class |
JDBCInputFormat
InputFormat to read data from a database and generate Rows.
|
Modifier and Type | Class and Description |
---|---|
class |
SimpleTweetInputFormat |
Modifier and Type | Class and Description |
---|---|
static class |
ConnectedComponents.CCMessenger<K,VV extends Comparable<VV>>
Sends the current vertex value to all adjacent vertices.
|
static class |
LabelPropagation.SendNewLabelToNeighbors<K,VV extends Comparable<VV>>
Sends the vertex label to all out-neighbors
|
Modifier and Type | Class and Description |
---|---|
static class |
VertexCentricIteration.MessageCombinerUdf<K,Message> |
Modifier and Type | Class and Description |
---|---|
static class |
GraphUtils.MapTo<I,O>
Map each element to a value.
|
Modifier and Type | Class and Description |
---|---|
class |
HadoopMapFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
This wrapper maps a Hadoop Mapper (mapred API) to a Flink FlatMapFunction.
|
class |
HadoopReduceCombineFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
This wrapper maps a Hadoop Reducer and Combiner (mapred API) to a combinable Flink GroupReduceFunction.
|
class |
HadoopReduceFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT>
This wrapper maps a Hadoop Reducer (mapred API) to a non-combinable Flink GroupReduceFunction.
|
Modifier and Type | Class and Description |
---|---|
class |
HCatInputFormatBase<T>
A InputFormat to read from HCatalog tables.
|
Modifier and Type | Class and Description |
---|---|
class |
HCatInputFormat<T>
A InputFormat to read from HCatalog tables.
|
Modifier and Type | Class and Description |
---|---|
class |
PythonCoGroup<IN1,IN2,OUT>
CoGroupFunction that uses a python script.
|
class |
PythonMapPartition<IN,OUT>
Multi-purpose class, usable by all operations using a python script with one input source and possibly differing
in-/output types.
|
Modifier and Type | Class and Description |
---|---|
class |
KeySelectorWithType<IN,K> |
Modifier and Type | Class and Description |
---|---|
class |
FlinkKafkaConsumer010<T>
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from
Apache Kafka 0.10.x.
|
class |
FlinkKafkaConsumer08<T>
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from
Apache Kafka 0.8.x.
|
class |
FlinkKafkaConsumer081<T>
Deprecated.
|
class |
FlinkKafkaConsumer082<T>
Deprecated.
|
class |
FlinkKafkaConsumer09<T>
The Flink Kafka Consumer is a streaming data source that pulls a parallel data stream from
Apache Kafka 0.9.x.
|
class |
FlinkKafkaConsumerBase<T>
Base class of all Flink Kafka Consumer data sources.
|
Modifier and Type | Class and Description |
---|---|
class |
RMQSource<OUT>
RabbitMQ source (consumer) which reads from a queue and acknowledges messages on checkpoints.
|
Modifier and Type | Class and Description |
---|---|
static class |
KeySelectorUtil.ArrayKeySelector<IN>
A key selector for selecting individual array fields as keys and returns them as a Tuple.
|
static class |
KeySelectorUtil.ComparableKeySelector<IN>
A key selector for selecting key fields via a TypeComparator.
|
Modifier and Type | Interface and Description |
---|---|
interface |
DeserializationSchema<T>
The deserialization schema describes how to turn the byte messages delivered by certain
data sources (for example Apache Kafka) into data types (Java/Scala objects) that are
processed by Flink.
|
interface |
KeyedDeserializationSchema<T>
The deserialization schema describes how to turn the byte key / value messages delivered by certain
data sources (for example Apache Kafka) into data types (Java/Scala objects) that are
processed by Flink.
|
Modifier and Type | Class and Description |
---|---|
class |
AbstractDeserializationSchema<T>
The deserialization schema describes how to turn the byte messages delivered by certain
data sources (for example Apache Kafka) into data types (Java/Scala objects) that are
processed by Flink.
|
class |
AvroRowDeserializationSchema
Deserialization schema from Avro bytes over
SpecificRecord to Row . |
class |
JSONDeserializationSchema
DeserializationSchema that deserializes a JSON String into an ObjectNode.
|
class |
JSONKeyValueDeserializationSchema
DeserializationSchema that deserializes a JSON String into an ObjectNode.
|
class |
JsonRowDeserializationSchema
Deserialization schema from JSON to
Row . |
class |
KeyedDeserializationSchemaWrapper<T>
A simple wrapper for using the DeserializationSchema with the KeyedDeserializationSchema
interface
|
class |
SimpleStringSchema
Very simple serialization schema for strings.
|
class |
TypeInformationKeyValueSerializationSchema<K,V>
A serialization and deserialization schema for Key Value Pairs that uses Flink's serialization stack to
transform typed from and to byte arrays.
|
class |
TypeInformationSerializationSchema<T>
A serialization and deserialization schema that uses Flink's serialization stack to
transform typed from and to byte arrays.
|
Modifier and Type | Class and Description |
---|---|
class |
CorrelateFlatMapRunner<IN,OUT> |
class |
CRowCorrelateProcessRunner
A CorrelateProcessRunner with
CRow input and CRow output. |
class |
CRowInputJavaTupleOutputMapRunner
Convert
CRow to a JTuple2 |
class |
CRowInputMapRunner<OUT>
MapRunner with
CRow input. |
class |
CRowInputScalaTupleOutputMapRunner
Convert
CRow to a Tuple2 |
class |
CRowOutputMapRunner
MapRunner with
CRow output. |
class |
CRowProcessRunner
ProcessRunner with
CRow input and CRow output. |
class |
FlatJoinRunner<IN1,IN2,OUT> |
class |
FlatMapRunner |
class |
MapJoinLeftRunner<IN1,IN2,OUT> |
class |
MapJoinRightRunner<IN1,IN2,OUT> |
class |
MapRunner<IN,OUT> |
class |
MapSideJoinRunner<IN1,IN2,SINGLE_IN,MULTI_IN,OUT> |
Modifier and Type | Class and Description |
---|---|
class |
DataSetSessionWindowAggregatePreProcessor
This wraps the aggregate logic inside of
GroupCombineOperator . |
class |
DataSetSlideTimeWindowAggFlatMapFunction
It is used for sliding windows on batch for time-windows.
|
class |
DataSetSlideTimeWindowAggReduceGroupFunction
It is used for sliding windows on batch for time-windows.
|
class |
DataSetWindowAggMapFunction
This map function only works for windows on batch tables.
|
Modifier and Type | Class and Description |
---|---|
class |
CRowValuesInputFormat |
class |
ValuesInputFormat |
Copyright © 2014–2018 The Apache Software Foundation. All rights reserved.