org.apache.seatunnel.transform.sql.zeta

类 ZetaSQLEngine

java.lang.Object

org.apache.seatunnel.transform.sql.zeta.ZetaSQLEngine

所有已实现的接口:

SQLEngine

public class ZetaSQLEngine
extends Object
implements SQLEngine

构造器概要

构造器

构造器和说明
ZetaSQLEngine()

方法概要

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

从类继承的方法 java.lang.Object

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

从接口继承的方法 org.apache.seatunnel.transform.sql.SQLEngine

close

构造器详细资料

ZetaSQLEngine

public ZetaSQLEngine()

方法详细资料

init

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

指定者:

init 在接口中 SQLEngine

typeMapping

public SeaTunnelRowType typeMapping(List<String> inputColumnsMapping)

指定者:

typeMapping 在接口中 SQLEngine

transformBySQL

public SeaTunnelRow transformBySQL(SeaTunnelRow inputRow)

指定者:

transformBySQL 在接口中 SQLEngine