com.streambase.liveview.server.table.plugin

Class TableProviderManager

java.lang.Object

com.streambase.liveview.server.table.plugin.TableProviderManager

public class TableProviderManager
extends Object

Field Summary

Fields

Modifier and Type	Field and Description
static boolean	restartIsOK
protected PriorityBlockingQueue<TableProviderControlImpl>	restartQueue
protected Map<String,TableProviderControlImpl>	tableProviderMap

Method Summary

Modifier and Type	Method and Description
void	addDependentTable(CatalogedTable baseTable, String dependentTableName) It adds the dependent table name to the dependents maps that every table provider has.
void	addTableProvider(com.streambase.liveview.internal.protocol.jaxb.ExternalServerConnectionType externalServer, int retryCount) Connect to a TableProvider, which then allows for remote connections as if they were LiveView Tables
Map<String,AbstractConfigObject>	compileLVConfs(List<File> tableFiles, boolean buildYaml)
void	createTable(String name, LiveviewConfiguration conf, boolean saveInProject)
void	deleteTable(CatalogedTable catalogedTable)
void	dropTables(List<String> tables)
static TableProviderManager	get()
LiveViewServerConfig	getConfig()
File	getCreateTableDir(boolean create)
static String	getJavaClassname(com.streambase.liveview.internal.protocol.jaxb.ExternalServerConnectionType externalServer)
File	getProjectBin() Get the projectBin, which is the writable base directory where all stuff that we write should go.
static boolean	hasDangerousConnection(AbstractConfigObject configObject)
static void	initialize(LiveViewServer lvServer)
static void	initialize(TablesTable tt, TableColumnsTable tct, LiveViewServerConfig conf, StreamBaseConnectionPool sbConnPool)
CatalogedTable	registerFilteredTableAlias(CatalogedTable baseCatalogTable, String predicateFilter, String tableNameFormatter) The method is used to register filtered tables from the base table
void	registerNewTable(String name, DataTable dataTable, Table.TableStatus initialStatus, String statusMessage)
void	removeTableProvider(String id) Disconnect a previously-connected TableProvider.
void	saveLVConf(String name, LiveviewConfiguration conf, boolean saveInProject)
void	shutdown()
void	startTables(List<String> tables)
void	validateTablesContainers()

Methods inherited from class java.lang.Object

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

Field Detail

restartIsOK

public static boolean restartIsOK

tableProviderMap

protected Map<String,TableProviderControlImpl> tableProviderMap

restartQueue

protected PriorityBlockingQueue<TableProviderControlImpl> restartQueue

Method Detail

get

public static TableProviderManager get()

initialize

public static void initialize(LiveViewServer lvServer)

initialize

public static void initialize(TablesTable tt,
                              TableColumnsTable tct,
                              LiveViewServerConfig conf,
                              StreamBaseConnectionPool sbConnPool)

validateTablesContainers

public void validateTablesContainers()

getConfig

public LiveViewServerConfig getConfig()

Returns:

the config

addTableProvider

public void addTableProvider(com.streambase.liveview.internal.protocol.jaxb.ExternalServerConnectionType externalServer,
                             int retryCount)
                      throws LiveViewException

Connect to a TableProvider, which then allows for remote connections as if they were LiveView Tables

Parameters:

externalServer - id must be unique

retryCount - The number of failed tries we've already made.

Throws:

LiveViewException

Since:

LiveView 1.6

getJavaClassname

public static String getJavaClassname(com.streambase.liveview.internal.protocol.jaxb.ExternalServerConnectionType externalServer)

removeTableProvider

public void removeTableProvider(String id)
                         throws LiveViewException

Disconnect a previously-connected TableProvider. This is called from outside, so no part has happened, yet, and it shouldn't be requeued for restart

Parameters:

id -

Throws:

LiveViewException

Since:

LiveView 1.6

shutdown

public void shutdown()
              throws LiveViewException

Throws:

LiveViewException

dropTables

public void dropTables(List<String> tables)
                throws LiveViewException,
                       TupleException,
                       StreamBaseException

Parameters:

tables -

Throws:

LiveViewException

TupleException

StreamBaseException

startTables

public void startTables(List<String> tables)
                 throws LiveViewException,
                        StreamBaseException,
                        ConfigException,
                        TupleException,
                        NullValueException

Parameters:

tables -

Throws:

LiveViewException

StreamBaseException

ConfigException

TupleException

NullValueException

compileLVConfs

public Map<String,AbstractConfigObject> compileLVConfs(List<File> tableFiles,
                                                       boolean buildYaml)
                                                throws LiveViewException,
                                                       StreamBaseException

Throws:

LiveViewException

StreamBaseException

getCreateTableDir

public File getCreateTableDir(boolean create)

getProjectBin

public File getProjectBin()

Get the projectBin, which is the writable base directory where all stuff that we write should go.

Returns:

deleteTable

public void deleteTable(CatalogedTable catalogedTable)
                 throws TupleException,
                        StreamBaseException

Throws:

TupleException

StreamBaseException

createTable

public void createTable(String name,
                        LiveviewConfiguration conf,
                        boolean saveInProject)
                 throws JAXBException,
                        StreamBaseException

Parameters:

conf -

saveInProject - TODO

Throws:

JAXBException

StreamBaseException

saveLVConf

public void saveLVConf(String name,
                       LiveviewConfiguration conf,
                       boolean saveInProject)
                throws JAXBException,
                       LiveViewException

Throws:

JAXBException

LiveViewException

registerNewTable

public void registerNewTable(String name,
                             DataTable dataTable,
                             Table.TableStatus initialStatus,
                             String statusMessage)
                      throws LiveViewException

Throws:

LiveViewException

registerFilteredTableAlias

public CatalogedTable registerFilteredTableAlias(CatalogedTable baseCatalogTable,
                                                 String predicateFilter,
                                                 String tableNameFormatter)
                                          throws LiveViewException

The method is used to register filtered tables from the base table

Parameters:

baseCatalogTable -

predicateFilter -

tableNameFormatter -

Throws:

LiveViewException

hasDangerousConnection

public static boolean hasDangerousConnection(AbstractConfigObject configObject)

addDependentTable

public void addDependentTable(CatalogedTable baseTable,
                              String dependentTableName)

It adds the dependent table name to the dependents maps that every table provider has.

Parameters:

baseTable -

dependentTableName -