Class

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

OnDataSet

Related Doc: package acceptPartialFunctions

Permalink

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

T

The type of the data set items

Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. OnDataSet
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new OnDataSet(ds: DataSet[T])

    Permalink

    ds

    The wrapped data set

Value Members

  1. final def !=(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  2. final def ##(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  3. final def ==(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  4. final def asInstanceOf[T0]: T0

    Permalink
    Definition Classes
    Any
  5. def clone(): AnyRef

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  6. final def eq(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  7. def equals(arg0: Any): Boolean

    Permalink
    Definition Classes
    AnyRef → Any
  8. def filterWith(fun: (T) ⇒ Boolean): DataSet[T]

    Permalink

    Applies a predicate fun to each item of the data set, keeping only those for which the predicate holds

    Applies a predicate fun to each item of the data set, keeping only those for which the predicate holds

    fun

    The predicate to be tested on each item

    returns

    A dataset of R

    Annotations
    @PublicEvolving()
  9. def finalize(): Unit

    Permalink
    Attributes
    protected[java.lang]
    Definition Classes
    AnyRef
    Annotations
    @throws( classOf[java.lang.Throwable] )
  10. def flatMapWith[R](fun: (T) ⇒ TraversableOnce[R])(implicit arg0: TypeInformation[R], arg1: ClassTag[R]): DataSet[R]

    Permalink

    Applies a function fun to each item of the dataset, producing a collection of items that will be flattened in the resulting data set

    Applies a function fun to each item of the dataset, producing a collection of items that will be flattened in the resulting data set

    R

    The type of the items in the returned data set

    fun

    The function to be applied to each item

    returns

    A dataset of R

    Annotations
    @PublicEvolving()
  11. final def getClass(): Class[_]

    Permalink
    Definition Classes
    AnyRef → Any
  12. def groupingBy[K](fun: (T) ⇒ K)(implicit arg0: TypeInformation[K]): GroupedDataSet[T]

    Permalink

    Groups the items according to a grouping function fun

    Groups the items according to a grouping function fun

    K

    The return type of the grouping function, for which type information must be known

    fun

    The grouping function

    returns

    A grouped data set of Ts

    Annotations
    @PublicEvolving()
  13. def hashCode(): Int

    Permalink
    Definition Classes
    AnyRef → Any
  14. final def isInstanceOf[T0]: Boolean

    Permalink
    Definition Classes
    Any
  15. def mapPartitionWith[R](fun: (Stream[T]) ⇒ R)(implicit arg0: TypeInformation[R], arg1: ClassTag[R]): DataSet[R]

    Permalink

    Applies a function fun to a partition as a whole

    Applies a function fun to a partition as a whole

    R

    The type of the items in the returned data set

    fun

    The function to be applied on the whole partition

    returns

    A dataset of R

    Annotations
    @PublicEvolving()
  16. def mapWith[R](fun: (T) ⇒ R)(implicit arg0: TypeInformation[R], arg1: ClassTag[R]): DataSet[R]

    Permalink

    Applies a function fun to each item of the data set

    Applies a function fun to each item of the data set

    R

    The type of the items in the returned data set

    fun

    The function to be applied to each item

    returns

    A dataset of R

    Annotations
    @PublicEvolving()
  17. final def ne(arg0: AnyRef): Boolean

    Permalink
    Definition Classes
    AnyRef
  18. final def notify(): Unit

    Permalink
    Definition Classes
    AnyRef
  19. final def notifyAll(): Unit

    Permalink
    Definition Classes
    AnyRef
  20. def reduceGroupWith[R](fun: (Stream[T]) ⇒ R)(implicit arg0: TypeInformation[R], arg1: ClassTag[R]): DataSet[R]

    Permalink

    Applies a reducer fun to a grouped data set

    Applies a reducer fun to a grouped data set

    R

    The type of the items in the returned data set

    fun

    The function to be applied to the whole grouping

    returns

    A dataset of Rs

    Annotations
    @PublicEvolving()
  21. def reduceWith(fun: (T, T) ⇒ T): DataSet[T]

    Permalink

    Applies a reducer fun to the data set

    Applies a reducer fun to the data set

    fun

    The reducing function to be applied on the whole data set

    returns

    A data set of Rs

    Annotations
    @PublicEvolving()
  22. final def synchronized[T0](arg0: ⇒ T0): T0

    Permalink
    Definition Classes
    AnyRef
  23. def toString(): String

    Permalink
    Definition Classes
    AnyRef → Any
  24. final def wait(): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  25. final def wait(arg0: Long, arg1: Int): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )
  26. final def wait(arg0: Long): Unit

    Permalink
    Definition Classes
    AnyRef
    Annotations
    @throws( ... )

Inherited from AnyRef

Inherited from Any

Ungrouped