Package org.teiid.deployers
Class EventDistributorImpl
- java.lang.Object
-
- org.teiid.deployers.EventDistributorImpl
-
- All Implemented Interfaces:
EventDistributor
public abstract class EventDistributorImpl extends Object implements EventDistributor
-
-
Constructor Summary
Constructors Constructor Description EventDistributorImpl()
-
Method Summary
All Methods Instance Methods Abstract Methods Concrete Methods Modifier and Type Method 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 eventsvoid
setColumnStats(String vdbName, int vdbVersion, String schemaName, String tableName, String columnName, ColumnStats stats)
Set the column statsvoid
setColumnStats(String vdbName, String vdbVersion, String schemaName, String tableName, String columnName, ColumnStats stats)
Set the column statsvoid
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 definitionvoid
setProcedureDefinition(String vdbName, String vdbVersion, String schema, String procName, String definition)
Set the procedure definitionvoid
setProperty(String vdbName, int vdbVersion, String uuid, String name, String value)
Set the given property valuevoid
setProperty(String vdbName, String vdbVersion, String uuid, String name, String value)
Set the given property valuevoid
setTableStats(String vdbName, int vdbVersion, String schemaName, String tableName, TableStats stats)
Set the table statsvoid
setTableStats(String vdbName, String vdbVersion, String schemaName, String tableName, TableStats stats)
Set the table statsvoid
setViewDefinition(String vdbName, int vdbVersion, String schema, String viewName, String definition)
Set the view definitionvoid
setViewDefinition(String vdbName, String vdbVersion, String schema, String viewName, String definition)
Set the view definitionvoid
unregister(EventListener listener)
Remove EventListenervoid
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.
-
-
-
Method Detail
-
getVdbRepository
public abstract VDBRepository getVdbRepository()
-
getDQPCore
public abstract DQPCore getDQPCore()
-
updateMatViewRow
public void updateMatViewRow(String vdbName, int vdbVersion, String schema, String viewName, List<?> tuple, boolean delete)
Description copied from interface:EventDistributor
Update the given materialized view row. The tuple is expected to be in table order, which has the primary key first. Deletes need to only send the key, not the entire row contents.- Specified by:
updateMatViewRow
in interfaceEventDistributor
-
updateMatViewRow
public void updateMatViewRow(String vdbName, String vdbVersion, String schema, String viewName, List<?> tuple, boolean delete)
Description copied from interface:EventDistributor
Update the given materialized view row. The tuple is expected to be in table order, which has the primary key first. Deletes need to only send the key, not the entire row contents.- Specified by:
updateMatViewRow
in interfaceEventDistributor
-
dataModification
public void dataModification(String vdbName, int vdbVersion, String schema, String... tableNames)
Description copied from interface:EventDistributor
Notify that the table data has changed.- Specified by:
dataModification
in interfaceEventDistributor
-
dataModification
public void dataModification(String vdbName, String vdbVersion, String schema, String... tableNames)
Description copied from interface:EventDistributor
Notify that the table data has changed.- Specified by:
dataModification
in interfaceEventDistributor
-
setColumnStats
public void setColumnStats(String vdbName, int vdbVersion, String schemaName, String tableName, String columnName, ColumnStats stats)
Description copied from interface:EventDistributor
Set the column stats- Specified by:
setColumnStats
in interfaceEventDistributor
-
setColumnStats
public void setColumnStats(String vdbName, String vdbVersion, String schemaName, String tableName, String columnName, ColumnStats stats)
Description copied from interface:EventDistributor
Set the column stats- Specified by:
setColumnStats
in interfaceEventDistributor
-
setTableStats
public void setTableStats(String vdbName, int vdbVersion, String schemaName, String tableName, TableStats stats)
Description copied from interface:EventDistributor
Set the table stats- Specified by:
setTableStats
in interfaceEventDistributor
-
setTableStats
public void setTableStats(String vdbName, String vdbVersion, String schemaName, String tableName, TableStats stats)
Description copied from interface:EventDistributor
Set the table stats- Specified by:
setTableStats
in interfaceEventDistributor
-
setInsteadOfTriggerDefinition
public void setInsteadOfTriggerDefinition(String vdbName, int vdbVersion, String schema, String viewName, Table.TriggerEvent triggerEvent, String triggerDefinition, Boolean enabled)
Description copied from interface:EventDistributor
Set the instead of trigger definition. Only one of either the triggerDefinition or enabled should be specified.- Specified by:
setInsteadOfTriggerDefinition
in interfaceEventDistributor
-
setInsteadOfTriggerDefinition
public void setInsteadOfTriggerDefinition(String vdbName, String vdbVersion, String schema, String viewName, Table.TriggerEvent triggerEvent, String triggerDefinition, Boolean enabled)
Description copied from interface:EventDistributor
Set the instead of trigger definition. Only one of either the triggerDefinition or enabled should be specified.- Specified by:
setInsteadOfTriggerDefinition
in interfaceEventDistributor
-
setProcedureDefinition
public void setProcedureDefinition(String vdbName, int vdbVersion, String schema, String procName, String definition)
Description copied from interface:EventDistributor
Set the procedure definition- Specified by:
setProcedureDefinition
in interfaceEventDistributor
-
setProcedureDefinition
public void setProcedureDefinition(String vdbName, String vdbVersion, String schema, String procName, String definition)
Description copied from interface:EventDistributor
Set the procedure definition- Specified by:
setProcedureDefinition
in interfaceEventDistributor
-
setViewDefinition
public void setViewDefinition(String vdbName, int vdbVersion, String schema, String viewName, String definition)
Description copied from interface:EventDistributor
Set the view definition- Specified by:
setViewDefinition
in interfaceEventDistributor
-
setViewDefinition
public void setViewDefinition(String vdbName, String vdbVersion, String schema, String viewName, String definition)
Description copied from interface:EventDistributor
Set the view definition- Specified by:
setViewDefinition
in interfaceEventDistributor
-
setProperty
public void setProperty(String vdbName, int vdbVersion, String uuid, String name, String value)
Description copied from interface:EventDistributor
Set the given property value- Specified by:
setProperty
in interfaceEventDistributor
-
setProperty
public void setProperty(String vdbName, String vdbVersion, String uuid, String name, String value)
Description copied from interface:EventDistributor
Set the given property value- Specified by:
setProperty
in interfaceEventDistributor
-
dataModification
public ResultsFuture<?> dataModification(String vdbName, String vdbVersion, String schema, String tableName, Object[] oldValues, Object[] newValues, String[] columnNames)
Description copied from interface:EventDistributor
Notify that the table data has changed.
For an insert only the newValues are provided.
For a delete only the oldValues are provided.
For an update both are provided.- Specified by:
dataModification
in interfaceEventDistributor
- Returns:
- a
ResultsFuture
if execution has started, or null if no execution has started
-
register
public void register(EventListener listener)
Description copied from interface:EventDistributor
Add EventListener for callback on events- Specified by:
register
in interfaceEventDistributor
-
unregister
public void unregister(EventListener listener)
Description copied from interface:EventDistributor
Remove EventListener- Specified by:
unregister
in interfaceEventDistributor
-
-