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

类 MultiplexMemoryPipelineChannel

java.lang.Object

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

所有已实现的接口:

PipelineChannel

public final class MultiplexMemoryPipelineChannel
extends Object
implements PipelineChannel

Multiplex memory pipeline channel.

构造器概要

构造器

构造器和说明
MultiplexMemoryPipelineChannel()
MultiplexMemoryPipelineChannel(AckCallback ackCallback)
MultiplexMemoryPipelineChannel(int blockQueueSize, AckCallback ackCallback)
MultiplexMemoryPipelineChannel(int channelNumber, int blockQueueSize, AckCallback ackCallback)

方法概要

限定符和类型	方法和说明
void	ack(List<Record> records)
void	close()
List<Record>	fetchRecords(int batchSize, int timeoutSeconds)
void	pushRecord(Record record)

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

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

构造器详细资料

MultiplexMemoryPipelineChannel

public MultiplexMemoryPipelineChannel()

MultiplexMemoryPipelineChannel

public MultiplexMemoryPipelineChannel(AckCallback ackCallback)

MultiplexMemoryPipelineChannel

public MultiplexMemoryPipelineChannel(int blockQueueSize,
                                      AckCallback ackCallback)

MultiplexMemoryPipelineChannel

public MultiplexMemoryPipelineChannel(int channelNumber,
                                      int blockQueueSize,
                                      AckCallback ackCallback)

方法详细资料

pushRecord

public void pushRecord(Record record)

指定者:

pushRecord 在接口中 PipelineChannel

fetchRecords

public List<Record> fetchRecords(int batchSize,
                                 int timeoutSeconds)

指定者:

fetchRecords 在接口中 PipelineChannel

ack

public void ack(List<Record> records)

指定者:

ack 在接口中 PipelineChannel

close

public void close()

指定者:

close 在接口中 PipelineChannel