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

类 AbstractIncrementalDumper<P>

java.lang.Object

org.apache.shardingsphere.data.pipeline.api.executor.AbstractLifecycleExecutor

org.apache.shardingsphere.data.pipeline.core.ingest.dumper.AbstractIncrementalDumper<P>

类型参数:

P - generic type of IngestPosition

所有已实现的接口:

Runnable, LifecycleExecutor, Dumper, IncrementalDumper

public abstract class AbstractIncrementalDumper<P>
extends AbstractLifecycleExecutor
implements IncrementalDumper

Abstract incremental dumper.

构造器概要

构造器

构造器和说明
AbstractIncrementalDumper(DumperConfiguration dumperConfig, IngestPosition<P> position, PipelineChannel channel, PipelineTableMetaDataLoader metaDataLoader)

方法概要

从类继承的方法 org.apache.shardingsphere.data.pipeline.api.executor.AbstractLifecycleExecutor

doStart, doStop, isRunning, run, setRunning, start, stop

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

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

从接口继承的方法 org.apache.shardingsphere.data.pipeline.api.executor.LifecycleExecutor

start, stop

从接口继承的方法 java.lang.Runnable

run

构造器详细资料

AbstractIncrementalDumper

public AbstractIncrementalDumper(DumperConfiguration dumperConfig,
                                 IngestPosition<P> position,
                                 PipelineChannel channel,
                                 PipelineTableMetaDataLoader metaDataLoader)