package transformer
Ordering
- Alphabetic
Visibility
- Public
- All
Type Members
- class DelayFunction extends KeyedProcessFunction[String, ValueWithContext[String], ValueWithContext[AnyRef]]
- class DelayTransformer extends CustomStreamTransformer with ExplicitUidInOperatorsSupport with Serializable
- class FlinkBaseComponentProvider extends ComponentProvider
- class UnionMapFunction extends AbstractLazyParameterInterpreterFunction with FlatMapFunction[Context, ValueWithContext[AnyRef]]
-
class
UnionTransformer extends CustomStreamTransformer with LazyLogging with Serializable
It creates union of joined data streams.
It creates union of joined data streams. Produced variable will be of type of value expression
Value Members
- object DelayTransformer extends DelayTransformer
- object FlinkBaseComponentProvider
-
object
ForEachTransformer extends CustomStreamTransformer with Serializable
Transforms the stream in a way that succeeding nodes are executed multiple times - once for every value in the 'elements' list.
- object PreviousValueTransformer extends CustomStreamTransformer with ExplicitUidInOperatorsSupport with Product with Serializable
- object UnionTransformer extends UnionTransformer