public static interface TransformationSinkProvider.Context
Modifier and Type | Method and Description |
---|---|
Transformation<RowData> |
getInputTransformation()
Input transformation to transform.
|
int |
getRowtimeIndex()
Returns the field index of the rowtime attribute, or
-1 otherwise. |
static TransformationSinkProvider.Context |
of(Transformation<RowData> inputTransformation,
int rowtimeIndex)
Helper method for creating the default implementation of
TransformationSinkProvider.Context . |
static TransformationSinkProvider.Context of(Transformation<RowData> inputTransformation, int rowtimeIndex)
TransformationSinkProvider.Context
.Transformation<RowData> getInputTransformation()
int getRowtimeIndex()
-1
otherwise.Copyright © 2014–2022 The Apache Software Foundation. All rights reserved.