org.apache.seatunnel.transform.common

类 MultipleFieldOutputTransform

java.lang.Object

org.apache.seatunnel.transform.common.AbstractSeaTunnelTransform

org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform

org.apache.seatunnel.transform.common.MultipleFieldOutputTransform

所有已实现的接口:

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

直接已知子类:

CopyFieldTransform, SplitTransform

public abstract class MultipleFieldOutputTransform
extends AbstractCatalogSupportTransform

另请参阅:

序列化表格

字段概要

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

inputCatalogTable, outputCatalogTable

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

inputRowType, inputTableName, outputRowType, outputTableName

构造器概要

构造器

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

方法概要

限定符和类型	方法和说明
protected abstract Column[]	getOutputColumns()
protected abstract SeaTunnelDataType[]	getOutputFieldDataTypes() Outputs new fields datatype
protected abstract String[]	getOutputFieldNames() Outputs new fields
protected abstract Object[]	getOutputFieldValues(SeaTunnelRowAccessor inputRow) Outputs new fields 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

构造器详细资料

MultipleFieldOutputTransform

public MultipleFieldOutputTransform(@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.

getOutputFieldNames

protected abstract String[] getOutputFieldNames()

Outputs new fields

返回:

getOutputFieldDataTypes

protected abstract SeaTunnelDataType[] getOutputFieldDataTypes()

Outputs new fields datatype

返回:

getOutputFieldValues

protected abstract Object[] getOutputFieldValues(SeaTunnelRowAccessor inputRow)

Outputs new fields value

参数:

inputRow - The inputRow of upstream input.

返回:

transformTableSchema

protected TableSchema transformTableSchema()

指定者:

transformTableSchema 在类中 AbstractCatalogSupportTransform

transformTableIdentifier

protected TableIdentifier transformTableIdentifier()

指定者:

transformTableIdentifier 在类中 AbstractCatalogSupportTransform

getOutputColumns

protected abstract Column[] getOutputColumns()