org.apache.paimon.flink.action.cdc.format

Interface RecordParserFactory

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public interface RecordParserFactory

Represents a factory for creating instances of AbstractRecordParser.

This interface provides a method to create a new RecordParser with specific configurations such as case sensitivity, table name conversion, and computed columns.

See Also:

AbstractRecordParser

Method Summary

Modifier and Type	Method and Description
AbstractRecordParser	createParser(TypeMapping typeMapping, List<ComputedColumn> computedColumns) Creates a new instance of AbstractRecordParser with the specified configurations.

Method Detail

createParser

AbstractRecordParser createParser(TypeMapping typeMapping,
                                  List<ComputedColumn> computedColumns)

Creates a new instance of AbstractRecordParser with the specified configurations.

Parameters:

typeMapping - Data type mapping options.

computedColumns - List of computed columns to be considered by the parser.

Returns:

A new instance of AbstractRecordParser.