org.apache.ignite.internal.processors.cache.query.continuous

Class CacheContinuousQueryEventBuffer

java.lang.Object

org.apache.ignite.internal.processors.cache.query.continuous.CacheContinuousQueryEventBuffer

public class CacheContinuousQueryEventBuffer
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static int	MAX_PENDING_BUFF_SIZE Maximum size of buffer for pending events.

Method Summary

Modifier and Type	Method and Description
protected long	currentPartitionCounter(boolean backup)

Methods inherited from class java.lang.Object

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

Field Detail

MAX_PENDING_BUFF_SIZE

public static final int MAX_PENDING_BUFF_SIZE

Maximum size of buffer for pending events. Default value is 10_000.

Method Detail

currentPartitionCounter

protected long currentPartitionCounter(boolean backup)

Parameters:

backup - True if backup context.

Returns:

Initial partition counter.