transformer

Ordering

Visibility

class DelayFunction extends KeyedProcessFunction[String, ValueWithContext[String], ValueWithContext[AnyRef]]
class DelayTransformer extends CustomStreamTransformer with ExplicitUidInOperatorsSupport
class FlinkBaseComponentProvider extends ComponentProvider
case class GenericState(value: AnyRef) extends Product with Serializable
class MapAscendingTimestampExtractor extends SerializableTimestampAssigner[AnyRef]
class PeriodicFunction extends SourceFunction[Unit]
class PeriodicSourceFactory extends SourceFactory
class TransformStateFunction[T] extends LatelyEvictableStateFunction[ValueWithContext[T], ValueWithContext[AnyRef], GenericState] with LazyParameterInterpreterFunction
class UnionMapFunction extends AbstractLazyParameterInterpreterFunction with FlatMapFunction[Context, ValueWithContext[AnyRef]]
class UnionMemoFunction extends LatelyEvictableStateFunction[ValueWithContext[StringKeyedValue[(String, AnyRef)]], ValueWithContext[AnyRef], Map[String, AnyRef]]
class UnionTransformer extends CustomStreamTransformer with LazyLogging
It creates union of joined data streams.
It creates union of joined data streams. Produced variable will be of type of value expression
class UnionWithMemoTransformer extends CustomStreamTransformer with ExplicitUidInOperatorsSupport

object DelayTransformer extends DelayTransformer
object ForEachTransformer extends CustomStreamTransformer
Transforms the stream in a way that succeeding nodes are executed multiple times - once for every value in the 'elements' list.
object MapAscendingTimestampExtractor extends Serializable
object PeriodicSourceFactory extends PeriodicSourceFactory
object PreviousValueTransformer extends CustomStreamTransformer with ExplicitUidInOperatorsSupport with Product with Serializable
object TransformStateTransformer extends CustomStreamTransformer with ExplicitUidInOperatorsSupport
This is general usage state transformation.
This is general usage state transformation. It takes previous value of state and transform it using newValue lambda parameter (having previous as a parameter). Transformation is done only when transformWhen expression is satisfied. States has Time-To-Leave defined by stateTimeoutSeconds parameter. So it is generally doing something like this: newStateValue = if (transformWhen) { newValue(previous) } else { previous }
object UnionTransformer extends UnionTransformer with Product with Serializable
object UnionWithMemoTransformer extends UnionWithMemoTransformer

Packages