org.apache.seatunnel.transform.split

类 SplitTransform

java.lang.Object

org.apache.seatunnel.transform.common.AbstractSeaTunnelTransform

org.apache.seatunnel.transform.common.AbstractCatalogSupportTransform

org.apache.seatunnel.transform.common.MultipleFieldOutputTransform

org.apache.seatunnel.transform.split.SplitTransform

所有已实现的接口:

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

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

另请参阅:

序列化表格

字段概要

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

inputCatalogTable, outputCatalogTable

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

inputRowType, inputTableName, outputRowType, outputTableName

构造器概要

构造器

构造器和说明
SplitTransform(@NonNull SplitTransformConfig splitTransformConfig, @NonNull CatalogTable catalogTable)

方法概要

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

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

构造器详细资料

SplitTransform

public SplitTransform(@NonNull
                      @NonNull SplitTransformConfig splitTransformConfig,
                      @NonNull
                      @NonNull CatalogTable catalogTable)

方法详细资料

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)

从类复制的说明: MultipleFieldOutputTransform

Set the data type info of input data.

指定者:

setInputRowType 在类中 MultipleFieldOutputTransform

参数:

rowType - The data type info of upstream input.

getOutputFieldNames

protected String[] getOutputFieldNames()

从类复制的说明: MultipleFieldOutputTransform

Outputs new fields

指定者:

getOutputFieldNames 在类中 MultipleFieldOutputTransform

返回:

getOutputFieldDataTypes

protected SeaTunnelDataType[] getOutputFieldDataTypes()

从类复制的说明: MultipleFieldOutputTransform

Outputs new fields datatype

指定者:

getOutputFieldDataTypes 在类中 MultipleFieldOutputTransform

返回:

getOutputFieldValues

protected Object[] getOutputFieldValues(SeaTunnelRowAccessor inputRow)

从类复制的说明: MultipleFieldOutputTransform

Outputs new fields value

指定者:

getOutputFieldValues 在类中 MultipleFieldOutputTransform

参数:

inputRow - The inputRow of upstream input.

返回:

getOutputColumns

protected Column[] getOutputColumns()

指定者:

getOutputColumns 在类中 MultipleFieldOutputTransform