org.teiid.common.buffer.impl

Class BufferManagerImpl

java.lang.Object

org.teiid.common.buffer.impl.BufferManagerImpl

All Implemented Interfaces:

BufferManager, StorageManager, TupleBufferCache, ReplicatedObject<String>

public class BufferManagerImpl
extends Object
implements BufferManager, ReplicatedObject<String>

Default implementation of BufferManager.

Responsible for creating/tracking TupleBuffers and providing access to the StorageManager.

TODO: add detection of pinned batches to prevent unnecessary purging of non-persistent batches - this is not necessary for already persistent batches, since we hold a weak reference TODO: add a pre-fetch for tuplebuffers or some built-in correlation logic with the queue.

Nested Class Summary

Nested classes/interfaces inherited from interface org.teiid.common.buffer.BufferManager

BufferManager.BufferReserveMode, BufferManager.TupleSourceType

Field Summary

Fields inherited from interface org.teiid.common.buffer.BufferManager

DEFAULT_MAX_PROCESSING_KB, DEFAULT_PROCESSOR_BATCH_SIZE, DEFAULT_RESERVE_BUFFER_KB

Constructor Summary

Constructors

Constructor and Description
BufferManagerImpl()
BufferManagerImpl(boolean sharedTimer)

Method Summary

Modifier and Type	Method and Description
void	addTupleBuffer(TupleBuffer tb)
FileStore	createFileStore(String name) Creates a new FileStore.
STree	createSTree(List<? extends Expression> elements, String groupName, int keyLength)
TupleBuffer	createTupleBuffer(List elements, String groupName, BufferManager.TupleSourceType tupleSourceType)
void	distributeTupleBuffer(String uuid, TupleBuffer tb)
void	droppedMembers(Collection<Serializable> addresses) Called when members are dropped
long	getActiveBatchBytes()
long	getBatchesAdded()
Cache	getCache()
int	getMaxProcessingSize() Return the max that can be temporarily held potentially across even a blocked exception.
int	getMaxReserveKB()
long	getMaxStorageSpace()
int	getMemoryCacheEntries()
Options	getOptions()
int	getProcessorBatchSize() Get processor batch size
int	getProcessorBatchSize(List<? extends Expression> schema) Get the batch size to use during query processing.
long	getReadAttempts()
long	getReadCount()
long	getReferenceHits()
long	getReserveBatchBytes()
int	getSchemaSize(List<? extends Expression> elements) Get the size estimate for the given schema.
void	getState(OutputStream ostream) Allows an application to write a state through a provided OutputStream.
void	getState(String state_id, OutputStream ostream) Allows an application to write a partial state through a provided OutputStream.
TupleBuffer	getTupleBuffer(String id)
long	getWriteCount()
boolean	hasState(String stateId) Return true if the object has the given state
void	initialize()
void	invalidCacheGroup(Long gid)
void	persistLob(Streamable<?> lob, FileStore store, byte[] bytes)
void	releaseBuffers(int count) Releases the buffers reserved by a call to BufferManager#reserveBuffers(int, boolean)
void	releaseOrphanedBuffers(long count)
int	reserveBuffers(int count, BufferManager.BufferReserveMode mode) Reserve up to count buffers for use.
int	reserveBuffersBlocking(int count, long[] val, boolean force)
void	setAddress(Serializable address) Allows the replicator to set the local address from the channel
void	setCache(Cache cache)
void	setInlineLobs(boolean inlineLobs)
void	setMaxActivePlans(int maxActivePlans) Set the maxActivePlans as a hint at determining the maxProcessing
void	setMaxProcessingKB(int maxProcessingKB)
void	setMaxReserveKB(int maxReserveBatchKB)
void	setMaxSessionBatchManagerSizeEstimate(long maxSessionBatchManagerSizeEstimate)
void	setOptions(Options options)
void	setProcessorBatchSize(int processorBatchSize)
void	setState(InputStream istream) Allows an application to read a state through a provided InputStream.
void	setState(String state_id, InputStream istream) Allows an application to read a partial state through a provided InputStream.
void	setStorageManager(StorageManager ssm)
void	setTargetBytesPerRow(int targetBytesPerRow)
void	setUseWeakReferences(boolean useWeakReferences)
void	shutdown()

Methods inherited from class java.lang.Object

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

Constructor Detail

BufferManagerImpl

public BufferManagerImpl()

BufferManagerImpl

public BufferManagerImpl(boolean sharedTimer)

Method Detail

getBatchesAdded

public long getBatchesAdded()

getReadCount

public long getReadCount()

getWriteCount

public long getWriteCount()

getReadAttempts

public long getReadAttempts()

getMaxProcessingSize

public int getMaxProcessingSize()

Description copied from interface: BufferManager

Return the max that can be temporarily held potentially across even a blocked exception.

Specified by:

getMaxProcessingSize in interface BufferManager

Returns:

getReserveBatchBytes

public long getReserveBatchBytes()

getProcessorBatchSize

public int getProcessorBatchSize()

Get processor batch size

Specified by:

getProcessorBatchSize in interface BufferManager

Returns:

Number of rows in a processor batch

setTargetBytesPerRow

public void setTargetBytesPerRow(int targetBytesPerRow)

setProcessorBatchSize

public void setProcessorBatchSize(int processorBatchSize)

createTupleBuffer

public TupleBuffer createTupleBuffer(List elements,
                                     String groupName,
                                     BufferManager.TupleSourceType tupleSourceType)

Specified by:

createTupleBuffer in interface BufferManager

createSTree

public STree createSTree(List<? extends Expression> elements,
                         String groupName,
                         int keyLength)

Specified by:

createSTree in interface BufferManager

createFileStore

public FileStore createFileStore(String name)

Description copied from interface: BufferManager

Creates a new FileStore. See FileStore#setCleanupReference(Object) to automatically cleanup the underlying resources.

Specified by:

createFileStore in interface BufferManager

Specified by:

createFileStore in interface StorageManager

getMaxStorageSpace

public long getMaxStorageSpace()

Specified by:

getMaxStorageSpace in interface StorageManager

getCache

public Cache getCache()

setMaxActivePlans

public void setMaxActivePlans(int maxActivePlans)

Description copied from interface: BufferManager

Set the maxActivePlans as a hint at determining the maxProcessing

Specified by:

setMaxActivePlans in interface BufferManager

setMaxProcessingKB

public void setMaxProcessingKB(int maxProcessingKB)

setMaxReserveKB

public void setMaxReserveKB(int maxReserveBatchKB)

initialize

public void initialize()
                throws TeiidComponentException

Specified by:

initialize in interface StorageManager

Throws:

TeiidComponentException

releaseOrphanedBuffers

public void releaseOrphanedBuffers(long count)

Specified by:

releaseOrphanedBuffers in interface BufferManager

releaseBuffers

public void releaseBuffers(int count)

Description copied from interface: BufferManager

Releases the buffers reserved by a call to BufferManager#reserveBuffers(int, boolean)

Specified by:

releaseBuffers in interface BufferManager

reserveBuffers

public int reserveBuffers(int count,
                          BufferManager.BufferReserveMode mode)

Description copied from interface: BufferManager

Reserve up to count buffers for use.

Specified by:

reserveBuffers in interface BufferManager

Returns:

reserveBuffersBlocking

public int reserveBuffersBlocking(int count,
                                  long[] val,
                                  boolean force)
                           throws BlockedException

Specified by:

reserveBuffersBlocking in interface BufferManager

Throws:

BlockedException

getProcessorBatchSize

public int getProcessorBatchSize(List<? extends Expression> schema)

Description copied from interface: BufferManager

Get the batch size to use during query processing.

Specified by:

getProcessorBatchSize in interface BufferManager

Returns:

Batch size (# of rows)

getSchemaSize

public int getSchemaSize(List<? extends Expression> elements)

Description copied from interface: BufferManager

Get the size estimate for the given schema.

Specified by:

getSchemaSize in interface BufferManager

shutdown

public void shutdown()

addTupleBuffer

public void addTupleBuffer(TupleBuffer tb)

Specified by:

addTupleBuffer in interface BufferManager

distributeTupleBuffer

public void distributeTupleBuffer(String uuid,
                                  TupleBuffer tb)

Specified by:

distributeTupleBuffer in interface TupleBufferCache

getTupleBuffer

public TupleBuffer getTupleBuffer(String id)

Specified by:

getTupleBuffer in interface TupleBufferCache

setUseWeakReferences

public void setUseWeakReferences(boolean useWeakReferences)

getState

public void getState(OutputStream ostream)

Description copied from interface: ReplicatedObject

Allows an application to write a state through a provided OutputStream.

Specified by:

getState in interface ReplicatedObject<String>

Parameters:

ostream - the OutputStream

getState

public void getState(String state_id,
                     OutputStream ostream)

Description copied from interface: ReplicatedObject

Allows an application to write a partial state through a provided OutputStream.

Specified by:

getState in interface ReplicatedObject<String>

Parameters:

state_id - id of the partial state requested

ostream - the OutputStream

setState

public void setState(InputStream istream)

Description copied from interface: ReplicatedObject

Allows an application to read a state through a provided InputStream.

Specified by:

setState in interface ReplicatedObject<String>

Parameters:

istream - the InputStream

setState

public void setState(String state_id,
                     InputStream istream)

Description copied from interface: ReplicatedObject

Allows an application to read a partial state through a provided InputStream.

Specified by:

setState in interface ReplicatedObject<String>

Parameters:

state_id - id of the partial state requested

istream - the InputStream

setAddress

public void setAddress(Serializable address)

Description copied from interface: ReplicatedObject

Allows the replicator to set the local address from the channel

Specified by:

setAddress in interface ReplicatedObject<String>

droppedMembers

public void droppedMembers(Collection<Serializable> addresses)

Description copied from interface: ReplicatedObject

Called when members are dropped

Specified by:

droppedMembers in interface ReplicatedObject<String>

setInlineLobs

public void setInlineLobs(boolean inlineLobs)

getMaxReserveKB

public int getMaxReserveKB()

setCache

public void setCache(Cache cache)

getMemoryCacheEntries

public int getMemoryCacheEntries()

getActiveBatchBytes

public long getActiveBatchBytes()

hasState

public boolean hasState(String stateId)

Description copied from interface: ReplicatedObject

Return true if the object has the given state

Specified by:

hasState in interface ReplicatedObject<String>

Returns:

getReferenceHits

public long getReferenceHits()

persistLob

public void persistLob(Streamable<?> lob,
                       FileStore store,
                       byte[] bytes)
                throws TeiidComponentException

Specified by:

persistLob in interface BufferManager

Throws:

TeiidComponentException

invalidCacheGroup

public void invalidCacheGroup(Long gid)

setOptions

public void setOptions(Options options)

Specified by:

setOptions in interface BufferManager

getOptions

public Options getOptions()

Specified by:

getOptions in interface BufferManager

setStorageManager

public void setStorageManager(StorageManager ssm)

setMaxSessionBatchManagerSizeEstimate

public void setMaxSessionBatchManagerSizeEstimate(long maxSessionBatchManagerSizeEstimate)