org.apache.seatunnel.transform.replace

类 ReplaceTransform

java.lang.Object

org.apache.seatunnel.transform.common.AbstractSeaTunnelTransform

org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform

org.apache.seatunnel.transform.common.SingleFieldOutputTransform

org.apache.seatunnel.transform.replace.ReplaceTransform

所有已实现的接口:

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

@AutoService(value=org.apache.seatunnel.api.transform.SeaTunnelTransform.class)
public class ReplaceTransform
extends SingleFieldOutputTransform

另请参阅:

序列化表格

字段概要

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

inputCatalogTable, outputCatalogTable

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

inputRowType, inputTableName, outputRowType, outputTableName

构造器概要

构造器

构造器和说明
ReplaceTransform(@NonNull ReadonlyConfig config, @NonNull CatalogTable inputCatalogTable)

方法概要

限定符和类型	方法和说明
protected Column	getOutputColumn()
protected SeaTunnelDataType	getOutputFieldDataType() Outputs new field datatype
protected String	getOutputFieldName() Outputs new field
protected Object	getOutputFieldValue(SeaTunnelRowAccessor inputRow) Outputs new field value
String	getPluginName()
protected void	setConfig(org.apache.seatunnel.shade.com.typesafe.config.Config pluginConfig)
protected void	setInputRowType(SeaTunnelRowType rowType) Set the data type info of input data.

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

transformRow, transformRowType, transformTableIdentifier, transformTableSchema

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

getProducedCatalogTable, getProducedType

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

map, prepare, 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.source.SeaTunnelJobAware

setJobContext

构造器详细资料

ReplaceTransform

public ReplaceTransform(@NonNull
                        @NonNull ReadonlyConfig config,
                        @NonNull
                        @NonNull CatalogTable inputCatalogTable)

方法详细资料

getPluginName

public String getPluginName()

setConfig

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

指定者:

setConfig 在类中 AbstractSeaTunnelTransform

setInputRowType

protected void setInputRowType(SeaTunnelRowType rowType)

从类复制的说明: SingleFieldOutputTransform

Set the data type info of input data.

指定者:

setInputRowType 在类中 SingleFieldOutputTransform

参数:

rowType - The data type info of upstream input.

getOutputFieldName

protected String getOutputFieldName()

从类复制的说明: SingleFieldOutputTransform

Outputs new field

指定者:

getOutputFieldName 在类中 SingleFieldOutputTransform

返回:

getOutputFieldDataType

protected SeaTunnelDataType getOutputFieldDataType()

从类复制的说明: SingleFieldOutputTransform

Outputs new field datatype

指定者:

getOutputFieldDataType 在类中 SingleFieldOutputTransform

返回:

getOutputFieldValue

protected Object getOutputFieldValue(SeaTunnelRowAccessor inputRow)

从类复制的说明: SingleFieldOutputTransform

Outputs new field value

指定者:

getOutputFieldValue 在类中 SingleFieldOutputTransform

参数:

inputRow - The inputRow of upstream input.

返回:

getOutputColumn

protected Column getOutputColumn()

指定者:

getOutputColumn 在类中 SingleFieldOutputTransform