Package | Description |
---|---|
org.apache.flink.api.java.io | |
org.apache.flink.api.scala.operators | |
org.apache.flink.streaming.api.functions.sink | |
org.apache.flink.streaming.connectors.fs | |
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
Modifier and Type | Class and Description |
---|---|
class |
CsvOutputFormat<T extends Tuple>
This is an OutputFormat to serialize
Tuple s to text. |
class |
LocalCollectionOutputFormat<T>
An output format that writes record into collection
|
class |
TypeSerializerOutputFormat<T>
Stores elements by serializing them with their type serializer.
|
Modifier and Type | Class and Description |
---|---|
class |
ScalaCsvOutputFormat<T extends scala.Product>
This is an OutputFormat to serialize Scala Tuples to text.
|
Modifier and Type | Class and Description |
---|---|
class |
OutputFormatSinkFunction<IN>
Simple implementation of the SinkFunction writing tuples in the specified
OutputFormat format.
|
Modifier and Type | Class and Description |
---|---|
class |
RollingSink<T>
Sink that emits its input elements to rolling
FileSystem files. |
class |
SequenceFileWriter<K extends org.apache.hadoop.io.Writable,V extends org.apache.hadoop.io.Writable>
A
Writer that writes the bucket files as Hadoop SequenceFiles . |
Modifier and Type | Class and Description |
---|---|
class |
EvictingNonKeyedWindowOperator<IN,ACC,OUT,W extends Window>
Evicting window operator for non-keyed windows.
|
class |
EvictingWindowOperator<K,IN,OUT,W extends Window>
A
WindowOperator that also allows an Evictor to be used. |
class |
NonKeyedWindowOperator<IN,ACC,OUT,W extends Window>
Window operator for non-keyed windows.
|
class |
WindowOperator<K,IN,ACC,OUT,W extends Window>
An operator that implements the logic for windowing based on a
WindowAssigner and
Trigger . |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.