org.apache.paimon.table.sink

Class RowKindGenerator

java.lang.Object

org.apache.paimon.table.sink.RowKindGenerator

public class RowKindGenerator
extends Object

Generate row kind.

Constructor Summary

Constructors

Constructor and Description
RowKindGenerator(String field, RowType rowType)

Method Summary

Modifier and Type	Method and Description
static RowKindGenerator	create(TableSchema schema, CoreOptions options)
RowKind	generate(InternalRow row)
static RowKind	getRowKind(RowKindGenerator rowKindGenerator, InternalRow row)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

RowKindGenerator

public RowKindGenerator(String field,
                        RowType rowType)

Method Detail

generate

public RowKind generate(InternalRow row)

create

@Nullable
public static RowKindGenerator create(TableSchema schema,
                                                CoreOptions options)

getRowKind

public static RowKind getRowKind(@Nullable
                                 RowKindGenerator rowKindGenerator,
                                 InternalRow row)