org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory

类 MemoryPipelineChannelCreator

java.lang.Object

org.apache.shardingsphere.data.pipeline.core.ingest.channel.memory.MemoryPipelineChannelCreator

所有已实现的接口:

PipelineChannelCreator, ShardingSphereAlgorithm, org.apache.shardingsphere.infra.util.spi.lifecycle.SPIPostProcessor, org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI

public final class MemoryPipelineChannelCreator
extends Object
implements PipelineChannelCreator

Memory implementation of pipeline channel creator.

字段概要

字段

限定符和类型	字段和说明
static int	BLOCK_QUEUE_SIZE_DEFAULT_VALUE
static String	BLOCK_QUEUE_SIZE_KEY
static String	TYPE

构造器概要

构造器

构造器和说明
MemoryPipelineChannelCreator()

方法概要

限定符和类型	方法和说明
PipelineChannel	createPipelineChannel(int outputConcurrency, AckCallback ackCallback)
String	getType()
void	init(Properties props)

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

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

从接口继承的方法 org.apache.shardingsphere.infra.config.algorithm.ShardingSphereAlgorithm

getProps

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

getTypeAliases

字段详细资料

TYPE

public static final String TYPE

另请参阅:

常量字段值

BLOCK_QUEUE_SIZE_DEFAULT_VALUE

public static final int BLOCK_QUEUE_SIZE_DEFAULT_VALUE

另请参阅:

常量字段值

BLOCK_QUEUE_SIZE_KEY

public static final String BLOCK_QUEUE_SIZE_KEY

另请参阅:

常量字段值

构造器详细资料

MemoryPipelineChannelCreator

public MemoryPipelineChannelCreator()

方法详细资料

init

public void init(Properties props)

指定者:

init 在接口中 org.apache.shardingsphere.infra.util.spi.lifecycle.SPIPostProcessor

createPipelineChannel

public PipelineChannel createPipelineChannel(int outputConcurrency,
                                             AckCallback ackCallback)

指定者:

createPipelineChannel 在接口中 PipelineChannelCreator

getType

public String getType()

指定者:

getType 在接口中 org.apache.shardingsphere.infra.util.spi.type.typed.TypedSPI