Package | Description |
---|---|
org.apache.flink.cep.operator | |
org.apache.flink.storm.wrappers | |
org.apache.flink.streaming.api.collector.selector | |
org.apache.flink.streaming.api.datastream | |
org.apache.flink.streaming.api.functions.windowing | |
org.apache.flink.streaming.api.graph | |
org.apache.flink.streaming.api.operators | |
org.apache.flink.streaming.api.operators.co | |
org.apache.flink.streaming.api.transformations | |
org.apache.flink.streaming.runtime.io | |
org.apache.flink.streaming.runtime.operators |
This package contains the operators that perform the stream transformations.
|
org.apache.flink.streaming.runtime.operators.windowing |
This package contains the operators that implement the various window operations
on data streams.
|
org.apache.flink.streaming.runtime.tasks |
This package contains classes that realize streaming tasks.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
StreamOperator
Basic interface for stream operators.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
StreamOperator
Basic interface for stream operators.
|
TimestampedCollector |
Class and Description |
---|
Output
A
StreamOperator is supplied with an object
of this interface that can be used to emit elements and other messages, such as barriers
and watermarks, from an operator. |
Class and Description |
---|
OneInputStreamOperator
Interface for stream operators with one input.
|
StreamSink |
StreamSource
StreamOperator for streaming sources. |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
OutputTypeConfigurable
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
Class and Description |
---|
StreamOperator
Basic interface for stream operators.
|
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined
function.
|
ChainingStrategy
Defines the chaining scheme for the operator.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
Output
A
StreamOperator is supplied with an object
of this interface that can be used to emit elements and other messages, such as barriers
and watermarks, from an operator. |
OutputTypeConfigurable
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
StreamingRuntimeContext
Implementation of the
RuntimeContext ,
for streaming operators. |
StreamOperator
Basic interface for stream operators.
|
StreamSource
StreamOperator for streaming sources. |
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined
function.
|
OutputTypeConfigurable
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
StreamOperator
Basic interface for stream operators.
|
TimestampedCollector |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
ChainingStrategy
Defines the chaining scheme for the operator.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
StreamSink |
StreamSource
StreamOperator for streaming sources. |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
OneInputStreamOperator
Interface for stream operators with one input.
|
Output
A
StreamOperator is supplied with an object
of this interface that can be used to emit elements and other messages, such as barriers
and watermarks, from an operator. |
TwoInputStreamOperator
Interface for stream operators with two inputs.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined
function.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
OutputTypeConfigurable
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
StreamOperator
Basic interface for stream operators.
|
Class and Description |
---|
AbstractStreamOperator
Base class for all stream operators.
|
AbstractUdfStreamOperator
This is used as the base class for operators that have a user-defined
function.
|
OneInputStreamOperator
Interface for stream operators with one input.
|
OutputTypeConfigurable
Stream operators can implement this interface if they need access to the output type information
at
StreamGraph generation. |
StreamOperator
Basic interface for stream operators.
|
TimestampedCollector |
Class and Description |
---|
Output
A
StreamOperator is supplied with an object
of this interface that can be used to emit elements and other messages, such as barriers
and watermarks, from an operator. |
StreamOperator
Basic interface for stream operators.
|
StreamSource
StreamOperator for streaming sources. |
Copyright © 2014–2017 The Apache Software Foundation. All rights reserved.