org.teiid.runtime

Class MaterializationManager

java.lang.Object

org.teiid.runtime.MaterializationManager

All Implemented Interfaces:

VDBLifeCycleListener, NodeTracker.NodeListener

public abstract class MaterializationManager
extends Object
implements VDBLifeCycleListener, NodeTracker.NodeListener

Constructor Summary

Constructors

Constructor and Description
MaterializationManager(ContainerLifeCycleListener shutdownListener)

Method Summary

Modifier and Type	Method and Description
void	added(String name, CompositeVDB cvdb)
void	beforeRemove(String name, CompositeVDB cvdb)
ResultsFuture<?>	executeAsynchQuery(VDBMetaData vdb, String command)
ResultsFuture<?>	executeAsynchQuery(VDBMetaData vdb, String command, DQPCore.ResultsListener listener)
List<Map<String,String>>	executeQuery(VDBMetaData vdb, String command)
void	finishedDeployment(String name, CompositeVDB cvdb)
abstract DQPCore	getDQP()
abstract Executor	getExecutor()
abstract ScheduledExecutorService	getScheduledExecutorService()
abstract VDBRepository	getVDBRepository()
void	nodeDropped(String nodeName)
void	nodeJoined(String nodeName)
void	removed(String name, CompositeVDB cvdb)
int	resetPendingJob(VDBMetaData vdb, Table table, String nodeName)
void	scheduleSnapshotJob(CompositeVDB vdb, Table table, long ttl, long delay, boolean oneTimeJob)

Methods inherited from class java.lang.Object

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

Constructor Detail

MaterializationManager

public MaterializationManager(ContainerLifeCycleListener shutdownListener)

Method Detail

getExecutor

public abstract Executor getExecutor()

getScheduledExecutorService

public abstract ScheduledExecutorService getScheduledExecutorService()

getDQP

public abstract DQPCore getDQP()

getVDBRepository

public abstract VDBRepository getVDBRepository()

added

public void added(String name,
                  CompositeVDB cvdb)

Specified by:

added in interface VDBLifeCycleListener

beforeRemove

public void beforeRemove(String name,
                         CompositeVDB cvdb)

Specified by:

beforeRemove in interface VDBLifeCycleListener

removed

public void removed(String name,
                    CompositeVDB cvdb)

Specified by:

removed in interface VDBLifeCycleListener

finishedDeployment

public void finishedDeployment(String name,
                               CompositeVDB cvdb)

Specified by:

finishedDeployment in interface VDBLifeCycleListener

resetPendingJob

public int resetPendingJob(VDBMetaData vdb,
                           Table table,
                           String nodeName)

scheduleSnapshotJob

public void scheduleSnapshotJob(CompositeVDB vdb,
                                Table table,
                                long ttl,
                                long delay,
                                boolean oneTimeJob)

executeAsynchQuery

public ResultsFuture<?> executeAsynchQuery(VDBMetaData vdb,
                                           String command)
                                    throws SQLException

Throws:

SQLException

executeAsynchQuery

public ResultsFuture<?> executeAsynchQuery(VDBMetaData vdb,
                                           String command,
                                           DQPCore.ResultsListener listener)
                                    throws SQLException

Throws:

SQLException

executeQuery

public List<Map<String,String>> executeQuery(VDBMetaData vdb,
                                             String command)
                                      throws SQLException

Throws:

SQLException

nodeJoined

public void nodeJoined(String nodeName)

Specified by:

nodeJoined in interface NodeTracker.NodeListener

nodeDropped

public void nodeDropped(String nodeName)

Specified by:

nodeDropped in interface NodeTracker.NodeListener