Value Members

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

   Definition Classes

   AnyRef → Any

2.  final def ##(): Int

   Definition Classes

   AnyRef → Any

3.  final def ==(arg0: Any): Boolean

   Definition Classes

   AnyRef → Any

4.  def add(values: Expr*): RelationalOperator[T]
5.  def addInto(valueIntos: (Expr, Expr)*): RelationalOperator[T]
6.  def alias(aliases: Set[AliasExpr]): RelationalOperator[T]
7.  def alias(aliases: AliasExpr*): RelationalOperator[T]
8.  def alignColumnNames(targetHeader: RecordHeader): RelationalOperator[T]

   Ensures that the column names are aligned with the target header.

   Ensures that the column names are aligned with the target header.

   targetHeader

   the header with which the column names should be aligned with

   returns

   operator with aligned column names

   Note

   All expressions in the operator header must be present in the target header.

9.  def alignColumnsWithReturnItems: RelationalOperator[T]

   Renames physical columns to given header expression names.

   Renames physical columns to given header expression names. Ensures that there is a physical column for each return item, i.e. aliases lead to duplicate physical columns.

10.  def alignExpressions(inputVar: Var, targetVar: Var, targetHeader: RecordHeader): RelationalOperator[T]

    Aligns a single element within the operator with the given target element in the target header.

    Aligns a single element within the operator with the given target element in the target header.

    inputVar

    the variable of the element that should be aligned

    targetVar

    the variable of the reference element

    targetHeader

    the header describing the desired state

    returns

    operator with aligned element

11.  def alignWith(inputElement: Var, targetElement: Var, targetHeader: RecordHeader): RelationalOperator[T]
12.  final def asInstanceOf[T0]: T0

    Definition Classes

    Any

13.  def assignScanName(mapping: Map[Var, Var]): RelationalOperator[T]
14.  def clone(): AnyRef

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @native() @throws( ... )

15.  def dropExprSet[E <: Expr](expressions: Set[E]): RelationalOperator[T]
16.  def dropExpressions[E <: Expr](expressions: E*): RelationalOperator[T]
17.  def elementTable: ElementTable[T]
18.  final def eq(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

19.  def equals(arg0: Any): Boolean

    Definition Classes

    AnyRef → Any

20.  def filter(expression: Expr): RelationalOperator[T]
21.  def finalize(): Unit

    Attributes

    protected[java.lang]

    Definition Classes

    AnyRef

    Annotations

    @throws( classOf[java.lang.Throwable] )

22.  final def getClass(): Class[_]

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

23.  def graphUnionAll(other: RelationalOperator[T]): RelationalOperator[T]
24.  def hashCode(): Int

    Definition Classes

    AnyRef → Any

    Annotations

    @native()

25.  final def isInstanceOf[T0]: Boolean

    Definition Classes

    Any

26.  def join(other: RelationalOperator[T], joinExprs: Seq[(Expr, Expr)], joinType: JoinType): RelationalOperator[T]
27.  final def ne(arg0: AnyRef): Boolean

    Definition Classes

    AnyRef

28.  final def notify(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

29.  final def notifyAll(): Unit

    Definition Classes

    AnyRef

    Annotations

    @native()

30.  def prefixVariableId(v: Var, prefix: GraphIdPrefix): RelationalOperator[T]
31.  def renameColumns(columnRenames: Map[Expr, String]): RelationalOperator[T]
32.  def select(expressions: Expr*): RelationalOperator[T]
33.  def singleElement: Var
34.  def switchContext(context: RelationalRuntimeContext[T]): RelationalOperator[T]
35.  final def synchronized[T0](arg0: ⇒ T0): T0

    Definition Classes

    AnyRef

36.  def toString(): String

    Definition Classes

    AnyRef → Any

37.  def unionAll(other: RelationalOperator[T]): RelationalOperator[T]
38.  final def wait(): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

39.  final def wait(arg0: Long, arg1: Int): Unit

    Definition Classes

    AnyRef

    Annotations

    @throws( ... )

40.  final def wait(arg0: Long): Unit

    Definition Classes

    AnyRef

    Annotations

    @native() @throws( ... )

41.  def withDisjointColumnNames(otherHeader: RecordHeader): RelationalOperator[T]

    Returns an operator with renamed columns such that the operators columns do not overlap with the other header's columns.

    Returns an operator with renamed columns such that the operators columns do not overlap with the other header's columns.

    otherHeader

    header from which the column names should be disjoint

    returns

    operator with disjoint column names