org.apache.flink.api.scala.extensions.impl

acceptPartialFunctions

package acceptPartialFunctions

Visibility
  1. Public
  2. All

Type Members

  1. class OnCoGroupDataSet[L, R] extends AnyRef

    Wraps a co-group data set, allowing to use anonymous partial functions to perform extraction of items in a tuple, case class instance or collection

  2. class OnCrossDataSet[L, R] extends AnyRef

    Wraps a cross data set, allowing to use anonymous partial functions to perform extraction of items in a tuple, case class instance or collection

  3. class OnDataSet[T] extends AnyRef

    Wraps a data set, allowing to use anonymous partial functions to perform extraction of items in a tuple, case class instance or collection

  4. class OnGroupedDataSet[T] extends AnyRef

    Wraps a grouped data set, allowing to use anonymous partial functions to perform extraction of items in a tuple, case class instance or collection

  5. class OnHalfUnfinishedKeyPairOperation[L, R, O] extends AnyRef

    Wraps an half unfinished key pair operation, allowing to use anonymous partial functions to perform extraction of items in a tuple, case class instance or collection

  6. class OnJoinFunctionAssigner[L, R] extends AnyRef

    Wraps a join function assigner, allowing to use anonymous partial functions to perform extraction of items in a tuple, case class instance or collection

  7. class OnUnfinishedKeyPairOperation[L, R, O] extends AnyRef

    Wraps an unfinished key pair operation, allowing to use anonymous partial functions to perform extraction of items in a tuple, case class instance or collection

Ungrouped