Interface TransformationSinkProvider.Context

    • Method Detail

      • getInputTransformation

        Transformation<RowData> getInputTransformation()
        Input transformation to transform.
      • getRowtimeIndex

        int getRowtimeIndex()
        Returns the field index of the rowtime attribute, or -1 otherwise.