org.apache.seatunnel.transform.common

类 AbstractSeaTunnelTransform

java.lang.Object

org.apache.seatunnel.transform.common.AbstractSeaTunnelTransform

所有已实现的接口:

Serializable, PluginIdentifierInterface, SeaTunnelPluginLifeCycle, SeaTunnelJobAware, SeaTunnelTransform<SeaTunnelRow>

直接已知子类:

AbstractCatalogSupportTransform

public abstract class AbstractSeaTunnelTransform
extends Object
implements SeaTunnelTransform<SeaTunnelRow>

另请参阅:

序列化表格

字段概要

字段

限定符和类型	字段和说明
protected SeaTunnelRowType	inputRowType
protected String	inputTableName
protected SeaTunnelRowType	outputRowType
protected String	outputTableName

构造器概要

构造器

构造器和说明
AbstractSeaTunnelTransform()

方法概要

限定符和类型	方法和说明
CatalogTable	getProducedCatalogTable()
SeaTunnelDataType<SeaTunnelRow>	getProducedType()
SeaTunnelRow	map(SeaTunnelRow row)
void	prepare(org.apache.seatunnel.shade.com.typesafe.config.Config pluginConfig)
protected abstract void	setConfig(org.apache.seatunnel.shade.com.typesafe.config.Config pluginConfig)
void	setTypeInfo(SeaTunnelDataType<SeaTunnelRow> inputDataType)
protected abstract SeaTunnelRow	transformRow(SeaTunnelRow inputRow) Outputs transformed row data.
protected abstract SeaTunnelRowType	transformRowType(SeaTunnelRowType inputRowType) Outputs transformed row type.

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

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

从接口继承的方法 org.apache.seatunnel.api.transform.SeaTunnelTransform

close, open

从接口继承的方法 org.apache.seatunnel.api.common.PluginIdentifierInterface

getPluginName

从接口继承的方法 org.apache.seatunnel.api.source.SeaTunnelJobAware

setJobContext

字段详细资料

inputTableName

protected String inputTableName

inputRowType

protected SeaTunnelRowType inputRowType

outputTableName

protected String outputTableName

outputRowType

protected SeaTunnelRowType outputRowType

构造器详细资料

AbstractSeaTunnelTransform

public AbstractSeaTunnelTransform()

方法详细资料

prepare

public void prepare(org.apache.seatunnel.shade.com.typesafe.config.Config pluginConfig)
             throws PrepareFailException

指定者:

prepare 在接口中 SeaTunnelPluginLifeCycle

抛出:

PrepareFailException

setTypeInfo

public void setTypeInfo(SeaTunnelDataType<SeaTunnelRow> inputDataType)

指定者:

setTypeInfo 在接口中 SeaTunnelTransform<SeaTunnelRow>

getProducedType

public SeaTunnelDataType<SeaTunnelRow> getProducedType()

指定者:

getProducedType 在接口中 SeaTunnelTransform<SeaTunnelRow>

map

public SeaTunnelRow map(SeaTunnelRow row)

指定者:

map 在接口中 SeaTunnelTransform<SeaTunnelRow>

setConfig

protected abstract void setConfig(org.apache.seatunnel.shade.com.typesafe.config.Config pluginConfig)

transformRowType

protected abstract SeaTunnelRowType transformRowType(SeaTunnelRowType inputRowType)

Outputs transformed row type.

参数:

inputRowType - upstream input row type

返回:

transformRow

protected abstract SeaTunnelRow transformRow(SeaTunnelRow inputRow)

Outputs transformed row data.

参数:

inputRow - upstream input row data

返回:

getProducedCatalogTable

public CatalogTable getProducedCatalogTable()

指定者:

getProducedCatalogTable 在接口中 SeaTunnelTransform<SeaTunnelRow>