com.continuent.tungsten.replicator.storage
Interface ParallelStore

All Superinterfaces:

ReplicatorPlugin, Store

All Known Implementing Classes:

ParallelQueueStore, THLParallelQueue

public interface ParallelStore
extends Store

Denotes a storage component that partitions transactions into disjoint sets.

Version:

1.0

Author:

Robert Hodges

Method Summary

int	getMaxOfflineInterval() Returns the maximum number of seconds to do a clean shutdown.
java.lang.String	getPartitionerClass() Returns the class used for partitioning transactions across queues.
int	getPartitions() Returns the number of partitions for events, i.e., channels.
int	getSyncInterval() Returns the number of events between sync intervals.
void	insertStopEvent() Inserts stop control event after next complete transaction.
void	insertWatchSyncEvent(WatchPredicate<ReplDBMSHeader> predicate) Inserts watch synchronization event after next complete transaction that matches the provided predicate.
void	setMaxOfflineInterval(int maxOfflineInterval) Sets the maximum number of seconds for a clean shutdown.
void	setMaxSize(int size) Returns the maximum size of individual queues.
void	setPartitionerClass(java.lang.String partitionerClass) Sets the class used for partitioning transactions across queues.
void	setPartitions(int partitions) Sets the number of queue partitions, i.e., channels.
void	setSyncInterval(int syncInterval) Sets the number of events to process before generating an automatic control event if sync is enabled.

Methods inherited from interface com.continuent.tungsten.replicator.storage.Store

getMaxStoredSeqno, getMinStoredSeqno, getName, setName, status

Methods inherited from interface com.continuent.tungsten.replicator.plugin.ReplicatorPlugin

configure, prepare, release

Method Detail

setMaxSize

void setMaxSize(int size)

Returns the maximum size of individual queues.

setPartitions

void setPartitions(int partitions)

Sets the number of queue partitions, i.e., channels.

getPartitions

int getPartitions()

Returns the number of partitions for events, i.e., channels.

getPartitionerClass

java.lang.String getPartitionerClass()

Returns the class used for partitioning transactions across queues.

setPartitionerClass

void setPartitionerClass(java.lang.String partitionerClass)

Sets the class used for partitioning transactions across queues.

getSyncInterval

int getSyncInterval()

Returns the number of events between sync intervals.

setSyncInterval

void setSyncInterval(int syncInterval)

Sets the number of events to process before generating an automatic control event if sync is enabled.

getMaxOfflineInterval

int getMaxOfflineInterval()

Returns the maximum number of seconds to do a clean shutdown.

setMaxOfflineInterval

void setMaxOfflineInterval(int maxOfflineInterval)

Sets the maximum number of seconds for a clean shutdown.

insertStopEvent

void insertStopEvent()
                     throws java.lang.InterruptedException

Inserts stop control event after next complete transaction.

Throws:

java.lang.InterruptedException

insertWatchSyncEvent

void insertWatchSyncEvent(WatchPredicate<ReplDBMSHeader> predicate)
                          throws java.lang.InterruptedException

Inserts watch synchronization event after next complete transaction that matches the provided predicate.

Throws:

java.lang.InterruptedException