public class SinkNotNullEnforcer extends Object implements FilterFunction<RowData>
Constructor and Description |
---|
SinkNotNullEnforcer(ExecutionConfigOptions.NotNullEnforcer notNullEnforcer,
int[] notNullFieldIndices,
String[] allFieldNames) |
Modifier and Type | Method and Description |
---|---|
boolean |
filter(RowData row)
The filter function that evaluates the predicate.
|
public SinkNotNullEnforcer(ExecutionConfigOptions.NotNullEnforcer notNullEnforcer, int[] notNullFieldIndices, String[] allFieldNames)
public boolean filter(RowData row)
FilterFunction
IMPORTANT: The system assumes that the function does not modify the elements on which the predicate is applied. Violating this assumption can lead to incorrect results.
filter
in interface FilterFunction<RowData>
row
- The value to be filtered.Copyright © 2014–2023 The Apache Software Foundation. All rights reserved.