public class RowUtils extends Object
Row
instances.Constructor and Description |
---|
RowUtils() |
Modifier and Type | Method and Description |
---|---|
static org.apache.flink.types.Row |
append(org.apache.flink.types.Row existing,
Object value)
Creates a new row with fields that are copied from the existing one, and appends a new filed
with the specific value.
|
static org.apache.flink.types.Row |
cloneWithReservedFields(org.apache.flink.types.Row existing,
int reservedFields)
Creates a new row with fields that are copied from the existing one, and reserves some empty
fields for further writing.
|
public static org.apache.flink.types.Row cloneWithReservedFields(org.apache.flink.types.Row existing, int reservedFields)
RowKind
of the first row determines the RowKind
of the result.existing
- The existing row to be cloned.reservedFields
- Num of fields to be reserved.public static org.apache.flink.types.Row append(org.apache.flink.types.Row existing, Object value)
existing
- The existing row to be cloned.value
- The value to be appended.Copyright © 2019–2023 The Apache Software Foundation. All rights reserved.