public interface TableManagementService
Modifier and Type | Method and Description |
---|---|
void |
addTable(String tableName,
TableMetaData tableMetaData,
EPStatementInitServices services) |
Table |
allocateTable(TableMetaData metadata) |
TableInstance |
allocateTableInstance(Table table,
AgentInstanceContext agentInstanceContext) |
void |
destroyTable(String deploymentId,
String tableName) |
int |
getDeploymentCount() |
Table |
getTable(String deploymentId,
String tableName) |
TableExprEvaluatorContext |
getTableExprEvaluatorContext() |
TableSerdes |
getTableSerdes(Table table,
DataInputOutputSerde aggregationSerde,
StatementContext statementContext) |
void |
traverseTables(BiConsumer<String,Table> consumer) |
void addTable(String tableName, TableMetaData tableMetaData, EPStatementInitServices services)
int getDeploymentCount()
Table allocateTable(TableMetaData metadata)
TableSerdes getTableSerdes(Table table, DataInputOutputSerde aggregationSerde, StatementContext statementContext)
TableInstance allocateTableInstance(Table table, AgentInstanceContext agentInstanceContext)
TableExprEvaluatorContext getTableExprEvaluatorContext()
void traverseTables(BiConsumer<String,Table> consumer)
Copyright © 2005–2018. All rights reserved.