Packages

package transformer

Ordering
  1. Alphabetic
Visibility
  1. Public
  2. Protected

Package Members

  1. package aggregate
  2. package join

Type Members

  1. case class GenericState(value: AnyRef) extends Product with Serializable
  2. class MapAscendingTimestampExtractor extends SerializableTimestampAssigner[AnyRef]
  3. class PeriodicFunction extends SourceFunction[Unit]
    Annotations
    @silent("deprecated")
  4. class PeriodicSourceFactory extends SourceFactory with UnboundedStreamComponent
  5. class TransformStateFunction[T] extends LatelyEvictableStateFunction[ValueWithContext[T], ValueWithContext[AnyRef], GenericState] with LazyParameterInterpreterFunction
  6. class UnionMemoFunction extends LatelyEvictableStateFunction[ValueWithContext[StringKeyedValue[Map[String, AnyRef]]], ValueWithContext[Map[String, AnyRef]], Map[String, AnyRef]]
  7. class UnionWithMemoTransformer extends CustomStreamTransformer with UnboundedStreamComponent with Serializable with ExplicitUidInOperatorsSupport

Value Members

  1. object MapAscendingTimestampExtractor extends Serializable
  2. object PeriodicSourceFactory extends PeriodicSourceFactory
  3. 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 }

  4. object UnionWithMemoTransformer extends UnionWithMemoTransformer

Ungrouped