public abstract class EventDistributorImpl extends Object implements EventDistributor
| Constructor and Description |
|---|
EventDistributorImpl() |
| Modifier and Type | Method and Description |
|---|---|
void |
dataModification(String vdbName,
int vdbVersion,
String schema,
String... tableNames)
Notify that the table data has changed.
|
void |
dataModification(String vdbName,
String vdbVersion,
String schema,
String... tableNames)
Notify that the table data has changed.
|
ResultsFuture<?> |
dataModification(String vdbName,
String vdbVersion,
String schema,
String tableName,
Object[] oldValues,
Object[] newValues,
String[] columnNames)
Notify that the table data has changed.
|
abstract DQPCore |
getDQPCore() |
abstract VDBRepository |
getVdbRepository() |
void |
register(EventListener listener)
Add EventListener for callback on events
|
void |
setColumnStats(String vdbName,
int vdbVersion,
String schemaName,
String tableName,
String columnName,
ColumnStats stats)
Set the column stats
|
void |
setColumnStats(String vdbName,
String vdbVersion,
String schemaName,
String tableName,
String columnName,
ColumnStats stats)
Set the column stats
|
void |
setInsteadOfTriggerDefinition(String vdbName,
int vdbVersion,
String schema,
String viewName,
Table.TriggerEvent triggerEvent,
String triggerDefinition,
Boolean enabled)
Set the instead of trigger definition.
|
void |
setInsteadOfTriggerDefinition(String vdbName,
String vdbVersion,
String schema,
String viewName,
Table.TriggerEvent triggerEvent,
String triggerDefinition,
Boolean enabled)
Set the instead of trigger definition.
|
void |
setProcedureDefinition(String vdbName,
int vdbVersion,
String schema,
String procName,
String definition)
Set the procedure definition
|
void |
setProcedureDefinition(String vdbName,
String vdbVersion,
String schema,
String procName,
String definition)
Set the procedure definition
|
void |
setProperty(String vdbName,
int vdbVersion,
String uuid,
String name,
String value)
Set the given property value
|
void |
setProperty(String vdbName,
String vdbVersion,
String uuid,
String name,
String value)
Set the given property value
|
void |
setTableStats(String vdbName,
int vdbVersion,
String schemaName,
String tableName,
TableStats stats)
Set the table stats
|
void |
setTableStats(String vdbName,
String vdbVersion,
String schemaName,
String tableName,
TableStats stats)
Set the table stats
|
void |
setViewDefinition(String vdbName,
int vdbVersion,
String schema,
String viewName,
String definition)
Set the view definition
|
void |
setViewDefinition(String vdbName,
String vdbVersion,
String schema,
String viewName,
String definition)
Set the view definition
|
void |
unregister(EventListener listener)
Remove EventListener
|
void |
updateMatViewRow(String vdbName,
int vdbVersion,
String schema,
String viewName,
List<?> tuple,
boolean delete)
Update the given materialized view row.
|
void |
updateMatViewRow(String vdbName,
String vdbVersion,
String schema,
String viewName,
List<?> tuple,
boolean delete)
Update the given materialized view row.
|
public abstract VDBRepository getVdbRepository()
public abstract DQPCore getDQPCore()
public void updateMatViewRow(String vdbName, int vdbVersion, String schema, String viewName, List<?> tuple, boolean delete)
EventDistributorupdateMatViewRow in interface EventDistributorpublic void updateMatViewRow(String vdbName, String vdbVersion, String schema, String viewName, List<?> tuple, boolean delete)
EventDistributorupdateMatViewRow in interface EventDistributorpublic void dataModification(String vdbName, int vdbVersion, String schema, String... tableNames)
EventDistributordataModification in interface EventDistributorpublic void dataModification(String vdbName, String vdbVersion, String schema, String... tableNames)
EventDistributordataModification in interface EventDistributorpublic void setColumnStats(String vdbName, int vdbVersion, String schemaName, String tableName, String columnName, ColumnStats stats)
EventDistributorsetColumnStats in interface EventDistributorpublic void setColumnStats(String vdbName, String vdbVersion, String schemaName, String tableName, String columnName, ColumnStats stats)
EventDistributorsetColumnStats in interface EventDistributorpublic void setTableStats(String vdbName, int vdbVersion, String schemaName, String tableName, TableStats stats)
EventDistributorsetTableStats in interface EventDistributorpublic void setTableStats(String vdbName, String vdbVersion, String schemaName, String tableName, TableStats stats)
EventDistributorsetTableStats in interface EventDistributorpublic void setInsteadOfTriggerDefinition(String vdbName, int vdbVersion, String schema, String viewName, Table.TriggerEvent triggerEvent, String triggerDefinition, Boolean enabled)
EventDistributorsetInsteadOfTriggerDefinition in interface EventDistributorpublic void setInsteadOfTriggerDefinition(String vdbName, String vdbVersion, String schema, String viewName, Table.TriggerEvent triggerEvent, String triggerDefinition, Boolean enabled)
EventDistributorsetInsteadOfTriggerDefinition in interface EventDistributorpublic void setProcedureDefinition(String vdbName, int vdbVersion, String schema, String procName, String definition)
EventDistributorsetProcedureDefinition in interface EventDistributorpublic void setProcedureDefinition(String vdbName, String vdbVersion, String schema, String procName, String definition)
EventDistributorsetProcedureDefinition in interface EventDistributorpublic void setViewDefinition(String vdbName, int vdbVersion, String schema, String viewName, String definition)
EventDistributorsetViewDefinition in interface EventDistributorpublic void setViewDefinition(String vdbName, String vdbVersion, String schema, String viewName, String definition)
EventDistributorsetViewDefinition in interface EventDistributorpublic void setProperty(String vdbName, int vdbVersion, String uuid, String name, String value)
EventDistributorsetProperty in interface EventDistributorpublic void setProperty(String vdbName, String vdbVersion, String uuid, String name, String value)
EventDistributorsetProperty in interface EventDistributorpublic ResultsFuture<?> dataModification(String vdbName, String vdbVersion, String schema, String tableName, Object[] oldValues, Object[] newValues, String[] columnNames)
EventDistributordataModification in interface EventDistributorResultsFuture if execution has started, or null if no execution has startedpublic void register(EventListener listener)
EventDistributorregister in interface EventDistributorpublic void unregister(EventListener listener)
EventDistributorunregister in interface EventDistributorCopyright © 2019. All rights reserved.