org.apache.shardingsphere.data.pipeline.core.ingest.position

类 DefaultPositionInitializer

java.lang.Object

org.apache.shardingsphere.data.pipeline.core.ingest.position.DefaultPositionInitializer

所有已实现的接口:

PositionInitializer, org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI, org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI

public final class DefaultPositionInitializer
extends Object
implements PositionInitializer

Default position initializer.

构造器概要

构造器

构造器和说明
DefaultPositionInitializer()

方法概要

限定符和类型	方法和说明
IngestPosition<?>	init(DataSource dataSource, String slotNameSuffix)
IngestPosition<?>	init(String data)
boolean	isDefault()

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

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

从接口继承的方法 org.apache.shardingsphere.data.pipeline.spi.ingest.position.PositionInitializer

destroy

从接口继承的方法 org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI

getType, getTypeAliases

构造器详细资料

DefaultPositionInitializer

public DefaultPositionInitializer()

方法详细资料

init

public IngestPosition<?> init(DataSource dataSource,
                              String slotNameSuffix)

指定者:

init 在接口中 PositionInitializer

init

public IngestPosition<?> init(String data)

指定者:

init 在接口中 PositionInitializer

isDefault

public boolean isDefault()

指定者:

isDefault 在接口中 org.apache.shardingsphere.infra.util.spi.type.required.RequiredSPI