程序包 com.cnosdb.impl

类 BatchProcessor

java.lang.Object

com.cnosdb.impl.BatchProcessor

public final class BatchProcessor
extends Object

A BatchProcessor can be attached to a CnosDB Instance to collect single point writes and aggregates them to BatchPoints to get a better write performance.

作者:

stefan.majer [at] gmail.com

嵌套类概要

嵌套类

修饰符和类型	类	说明
static final class	BatchProcessor.Builder	The Builder to create a BatchProcessor instance.

字段概要

字段

修饰符和类型	字段	说明
protected final BlockingQueue<com.cnosdb.impl.BatchProcessor.AbstractBatchEntry>	queue

方法概要

修饰符和类型	方法	说明
static BatchProcessor.Builder	builder(CnosDB cnosDB)	Static method to create the Builder for this BatchProcessor.
CnosDB.ConsistencyLevel	getConsistencyLevel()
Consumer<Point>	getDroppedActionHandler()
TimeUnit	getPrecision()
boolean	isDropActionsOnQueueExhaustion()

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

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

字段详细资料

queue

protected final BlockingQueue<com.cnosdb.impl.BatchProcessor.AbstractBatchEntry> queue

方法详细资料

builder

public static BatchProcessor.Builder builder(CnosDB cnosDB)

Static method to create the Builder for this BatchProcessor.

参数:

cnosDB - the cnosdb database handle.

返回:

the Builder to create the BatchProcessor.

getConsistencyLevel

public CnosDB.ConsistencyLevel getConsistencyLevel()

getPrecision

public TimeUnit getPrecision()

isDropActionsOnQueueExhaustion

public boolean isDropActionsOnQueueExhaustion()

getDroppedActionHandler

public Consumer<Point> getDroppedActionHandler()