public class EmbeddedServer extends AbstractVDBDeployer implements EventDistributorFactory, ConnectorManagerRepository.ExecutionFactoryProvider
start(EmbeddedConfiguration)
Modifier and Type | Class and Description |
---|---|
static interface |
EmbeddedServer.ConnectionFactoryProvider<T> |
protected class |
EmbeddedServer.ProviderAwareConnectorManagerRepository |
static class |
EmbeddedServer.SimpleConnectionFactoryProvider<T> |
Modifier and Type | Field and Description |
---|---|
protected BufferServiceImpl |
bufferService |
protected ConnectorManagerRepository |
cmr |
protected DQPCore |
dqp |
protected AbstractEventDistributorFactoryService |
eventDistributorFactoryService |
protected LogonImpl |
logon |
protected MaterializationManager |
materializationMgr |
protected ObjectReplicator |
replicator |
protected VDBRepository |
repo
Custom vdb repository that will immediately throw exceptions for metadata validation errors
|
protected ScheduledExecutorService |
scheduler |
protected ClientServiceRegistryImpl |
services |
protected SessionServiceImpl |
sessionService |
protected boolean |
throwMetadataErrors |
protected TransactionServerImpl |
transactionService |
protected ArrayList<SocketListener> |
transports |
protected boolean |
useCallingThread |
protected boolean |
waitForLoad |
ALLOW_INFORMATION_SCHEMA, repositories
Constructor and Description |
---|
EmbeddedServer() |
addMetadataRepository, assignMetadataRepositories, createMetadataFactory, getConnectorManagers, loadMetadata
protected DQPCore dqp
protected VDBRepository repo
protected boolean throwMetadataErrors
protected SessionServiceImpl sessionService
protected ObjectReplicator replicator
protected BufferServiceImpl bufferService
protected TransactionServerImpl transactionService
protected boolean waitForLoad
protected ClientServiceRegistryImpl services
protected LogonImpl logon
protected ConnectorManagerRepository cmr
protected AbstractEventDistributorFactoryService eventDistributorFactoryService
protected boolean useCallingThread
protected ArrayList<SocketListener> transports
protected ScheduledExecutorService scheduler
protected MaterializationManager materializationMgr
public void addConnectionFactoryProvider(String name, EmbeddedServer.ConnectionFactoryProvider<?> connectionFactoryProvider)
EmbeddedServer.ConnectionFactoryProvider
with the given connection name to replace the default JNDI lookup strategy.name
- connectionFactoryProvider
- for a basic wrapper
public void addConnectionFactory(String name, Object connectionFactory)
name
- connectionFactory
- public void start(EmbeddedConfiguration config)
protected BufferService getBufferService()
protected MaterializationManager getMaterializationManager()
public void addTranslator(Class<? extends ExecutionFactory> clazz) throws TranslatorException
ExecutionFactory
using the default name either from the Translator
annotation or the class name.
Only ExecutionFactory
classes with a Translator
annotation can be referenced by addTranslator(String, String, Map)
clazz
- TranslatorException
public void addTranslator(String name, String type, Map<String,String> properties) throws TranslatorException
name
- type
- the name of an existing translator to overrideproperties
- TranslatorException
public void addTranslator(String name, ExecutionFactory<?,?> ef)
ExecutionFactory
. NOTE: Only this single instance will be shared for all usage.
See addTranslator(String, String, Map)
or addTranslator(Class)
name
- ef
- the already started ExecutionFactorypublic void deployVDB(String name, ModelMetaData... models) throws ConnectorManagerRepository.ConnectorManagerException, VirtualDatabaseException, TranslatorException
name
- models
- ConnectorManagerRepository.ConnectorManagerException
VirtualDatabaseException
TranslatorException
public void deployVDB(InputStream is) throws VirtualDatabaseException, ConnectorManagerRepository.ConnectorManagerException, TranslatorException, IOException
is
- which will be closed by this deploymentTranslatorException
ConnectorManagerRepository.ConnectorManagerException
VirtualDatabaseException
IOException
public void deployVDB(InputStream is, boolean ddl) throws VirtualDatabaseException, ConnectorManagerRepository.ConnectorManagerException, TranslatorException, IOException
is
- which will be closed by this deploymentddl
- true if the file contents are DDLTranslatorException
ConnectorManagerRepository.ConnectorManagerException
VirtualDatabaseException
IOException
public void deployVDBZip(URL url) throws VirtualDatabaseException, ConnectorManagerRepository.ConnectorManagerException, TranslatorException, IOException, URISyntaxException
protected boolean allowOverrideTranslators()
protected void deployVDB(VDBMetaData vdb, VDBResources resources) throws ConnectorManagerRepository.ConnectorManagerException, VirtualDatabaseException, TranslatorException
protected MetadataRepository<?,?> getMetadataRepository(String repoType) throws VirtualDatabaseException
getMetadataRepository
in class AbstractVDBDeployer
VirtualDatabaseException
protected void cacheMetadataFactory(VDBMetaData vdb, ModelMetaData model, MetadataFactory schema)
cacheMetadataFactory
in class AbstractVDBDeployer
protected MetadataFactory getCachedMetadataFactory(VDBMetaData vdb, ModelMetaData model)
getCachedMetadataFactory
in class AbstractVDBDeployer
protected void retryLoad(VDBMetaData vdb, ModelMetaData model, Runnable job)
retryLoad
in class AbstractVDBDeployer
protected void runMetadataJob(VDBMetaData vdb, ModelMetaData model, Runnable job) throws TranslatorException
runMetadataJob
in class AbstractVDBDeployer
TranslatorException
public void undeployVDB(String vdbName)
protected EmbeddedConfiguration getConfiguration()
public void stop()
public TeiidDriver getDriver()
public EventDistributor getEventDistributor()
getEventDistributor
in interface EventDistributorFactory
public ExecutionFactory<Object,Object> getExecutionFactory(String name) throws ConnectorManagerRepository.ConnectorManagerException
getExecutionFactory
in interface ConnectorManagerRepository.ExecutionFactoryProvider
ConnectorManagerRepository.ConnectorManagerException
protected VDBRepository getVDBRepository()
getVDBRepository
in class AbstractVDBDeployer
public String getSchemaDdl(String vdbName, String schemaName)
vdbName
- schemaName
- public int getPort(int transport)
transport
- protected TranslatorRepository getTranslatorRepository()
protected ConcurrentHashMap<String,EmbeddedServer.ConnectionFactoryProvider<?>> getConnectionFactoryProviders()
protected SessionAwareCache<CachedResults> getRsCache()
protected SessionAwareCache<PreparedPlan> getPpcCache()
public Admin getAdmin()
public static void createPreParser(VDBMetaData deployment) throws TeiidException
TeiidException
Copyright © 2019. All rights reserved.