org.apache.seatunnel.transform.common

类 SingleFieldOutputTransform

java.lang.Object

org.apache.seatunnel.transform.common.AbstractSeaTunnelTransform

org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform

org.apache.seatunnel.transform.common.SingleFieldOutputTransform

所有已实现的接口:

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

直接已知子类:

ReplaceTransform

public abstract class SingleFieldOutputTransform
extends AbstractCatalogSupportTransform

另请参阅:

序列化表格

字段概要

从类继承的字段 org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform

inputCatalogTable, outputCatalogTable

从类继承的字段 org.apache.seatunnel.transform.common.AbstractSeaTunnelTransform

inputRowType, inputTableName, outputRowType, outputTableName

构造器概要

构造器

构造器和说明
SingleFieldOutputTransform(@NonNull CatalogTable inputCatalogTable)

方法概要

限定符和类型	方法和说明
protected abstract Column	getOutputColumn()
protected abstract SeaTunnelDataType	getOutputFieldDataType() Outputs new field datatype
protected abstract String	getOutputFieldName() Outputs new field
protected abstract Object	getOutputFieldValue(SeaTunnelRowAccessor inputRow) Outputs new field value
protected abstract void	setInputRowType(SeaTunnelRowType inputRowType) Set the data type info of input data.
protected SeaTunnelRow	transformRow(SeaTunnelRow inputRow) Outputs transformed row data.
protected SeaTunnelRowType	transformRowType(SeaTunnelRowType inputRowType) Outputs transformed row type.
protected TableIdentifier	transformTableIdentifier()
protected TableSchema	transformTableSchema()

从类继承的方法 org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform

getProducedCatalogTable, getProducedType

从类继承的方法 org.apache.seatunnel.transform.common.AbstractSeaTunnelTransform

map, prepare, setConfig, setTypeInfo

从类继承的方法 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

构造器详细资料

SingleFieldOutputTransform

public SingleFieldOutputTransform(@NonNull
                                  @NonNull CatalogTable inputCatalogTable)

方法详细资料

transformRowType

protected SeaTunnelRowType transformRowType(SeaTunnelRowType inputRowType)

从类复制的说明: AbstractSeaTunnelTransform

Outputs transformed row type.

指定者:

transformRowType 在类中 AbstractSeaTunnelTransform

参数:

inputRowType - upstream input row type

返回:

transformRow

protected SeaTunnelRow transformRow(SeaTunnelRow inputRow)

从类复制的说明: AbstractSeaTunnelTransform

Outputs transformed row data.

指定者:

transformRow 在类中 AbstractSeaTunnelTransform

参数:

inputRow - upstream input row data

返回:

setInputRowType

protected abstract void setInputRowType(SeaTunnelRowType inputRowType)

Set the data type info of input data.

参数:

inputRowType - The data type info of upstream input.

getOutputFieldName

protected abstract String getOutputFieldName()

Outputs new field

返回:

getOutputFieldDataType

protected abstract SeaTunnelDataType getOutputFieldDataType()

Outputs new field datatype

返回:

getOutputFieldValue

protected abstract Object getOutputFieldValue(SeaTunnelRowAccessor inputRow)

Outputs new field value

参数:

inputRow - The inputRow of upstream input.

返回:

transformTableSchema

protected TableSchema transformTableSchema()

指定者:

transformTableSchema 在类中 AbstractCatalogSupportTransform

transformTableIdentifier

protected TableIdentifier transformTableIdentifier()

指定者:

transformTableIdentifier 在类中 AbstractCatalogSupportTransform

getOutputColumn

protected abstract Column getOutputColumn()