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

类 DefaultInventoryDumper

java.lang.Object

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

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

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

所有已实现的接口:

Runnable, LifecycleExecutor, Dumper, InventoryDumper

public final class DefaultInventoryDumper
extends AbstractInventoryDumper

Default inventory dumper.

构造器概要

构造器

构造器和说明
DefaultInventoryDumper(InventoryDumperConfiguration inventoryDumperConfig, PipelineChannel channel, DataSource dataSource, PipelineTableMetaDataLoader metaDataLoader)

方法概要

限定符和类型	方法和说明
protected PreparedStatement	createPreparedStatement(Connection connection, String sql)

从类继承的方法 org.apache.shardingsphere.data.pipeline.core.ingest.dumper.AbstractInventoryDumper

doStart, doStop

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

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

构造器详细资料

DefaultInventoryDumper

public DefaultInventoryDumper(InventoryDumperConfiguration inventoryDumperConfig,
                              PipelineChannel channel,
                              DataSource dataSource,
                              PipelineTableMetaDataLoader metaDataLoader)

方法详细资料

createPreparedStatement

protected PreparedStatement createPreparedStatement(Connection connection,
                                                    String sql)
                                             throws SQLException

指定者:

createPreparedStatement 在类中 AbstractInventoryDumper

抛出:

SQLException