org.apache.seatunnel.transform.sql

接口 SQLEngine

所有已知实现类:

ZetaSQLEngine

public interface SQLEngine

方法概要

限定符和类型	方法和说明
default void	close()
void	init(String inputTableName, String catalogTableName, SeaTunnelRowType inputRowType, String sql)
SeaTunnelRow	transformBySQL(SeaTunnelRow inputRow)
SeaTunnelRowType	typeMapping(List<String> inputColumnsMapping)

方法详细资料

init

void init(String inputTableName,
          String catalogTableName,
          SeaTunnelRowType inputRowType,
          String sql)

typeMapping

SeaTunnelRowType typeMapping(List<String> inputColumnsMapping)

transformBySQL

SeaTunnelRow transformBySQL(SeaTunnelRow inputRow)

close

default void close()