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)
EventDistributor
updateMatViewRow
in interface EventDistributor
public void updateMatViewRow(String vdbName, String vdbVersion, String schema, String viewName, List<?> tuple, boolean delete)
EventDistributor
updateMatViewRow
in interface EventDistributor
public void dataModification(String vdbName, int vdbVersion, String schema, String... tableNames)
EventDistributor
dataModification
in interface EventDistributor
public void dataModification(String vdbName, String vdbVersion, String schema, String... tableNames)
EventDistributor
dataModification
in interface EventDistributor
public void setColumnStats(String vdbName, int vdbVersion, String schemaName, String tableName, String columnName, ColumnStats stats)
EventDistributor
setColumnStats
in interface EventDistributor
public void setColumnStats(String vdbName, String vdbVersion, String schemaName, String tableName, String columnName, ColumnStats stats)
EventDistributor
setColumnStats
in interface EventDistributor
public void setTableStats(String vdbName, int vdbVersion, String schemaName, String tableName, TableStats stats)
EventDistributor
setTableStats
in interface EventDistributor
public void setTableStats(String vdbName, String vdbVersion, String schemaName, String tableName, TableStats stats)
EventDistributor
setTableStats
in interface EventDistributor
public void setInsteadOfTriggerDefinition(String vdbName, int vdbVersion, String schema, String viewName, Table.TriggerEvent triggerEvent, String triggerDefinition, Boolean enabled)
EventDistributor
setInsteadOfTriggerDefinition
in interface EventDistributor
public void setInsteadOfTriggerDefinition(String vdbName, String vdbVersion, String schema, String viewName, Table.TriggerEvent triggerEvent, String triggerDefinition, Boolean enabled)
EventDistributor
setInsteadOfTriggerDefinition
in interface EventDistributor
public void setProcedureDefinition(String vdbName, int vdbVersion, String schema, String procName, String definition)
EventDistributor
setProcedureDefinition
in interface EventDistributor
public void setProcedureDefinition(String vdbName, String vdbVersion, String schema, String procName, String definition)
EventDistributor
setProcedureDefinition
in interface EventDistributor
public void setViewDefinition(String vdbName, int vdbVersion, String schema, String viewName, String definition)
EventDistributor
setViewDefinition
in interface EventDistributor
public void setViewDefinition(String vdbName, String vdbVersion, String schema, String viewName, String definition)
EventDistributor
setViewDefinition
in interface EventDistributor
public void setProperty(String vdbName, int vdbVersion, String uuid, String name, String value)
EventDistributor
setProperty
in interface EventDistributor
public void setProperty(String vdbName, String vdbVersion, String uuid, String name, String value)
EventDistributor
setProperty
in interface EventDistributor
public ResultsFuture<?> dataModification(String vdbName, String vdbVersion, String schema, String tableName, Object[] oldValues, Object[] newValues, String[] columnNames)
EventDistributor
dataModification
in interface EventDistributor
ResultsFuture
if execution has started, or null if no execution has startedpublic void register(EventListener listener)
EventDistributor
register
in interface EventDistributor
public void unregister(EventListener listener)
EventDistributor
unregister
in interface EventDistributor
Copyright © 2019. All rights reserved.