public class DefaultValueAssigner extends Object
Modifier and Type | Method and Description |
---|---|
RecordReader<InternalRow> |
assignFieldsDefaultValue(RecordReader<InternalRow> reader)
assign default value for column which value is null.
|
static DefaultValueAssigner |
create(TableSchema schema) |
Predicate |
handlePredicate(Predicate filters) |
DefaultValueAssigner |
handleReadRowType(RowType readRowType) |
boolean |
needToAssign() |
public DefaultValueAssigner handleReadRowType(RowType readRowType)
public boolean needToAssign()
public RecordReader<InternalRow> assignFieldsDefaultValue(RecordReader<InternalRow> reader)
public static DefaultValueAssigner create(TableSchema schema)
Copyright © 2023–2024 The Apache Software Foundation. All rights reserved.