Package | Description |
---|---|
org.apache.flink.table.runtime.operators.sink |
Constructor and Description |
---|
SinkOperator(SinkFunction<RowData> sinkFunction,
int rowtimeFieldIndex,
SinkNotNullEnforcer enforcer) |
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.