Package org.teiid.events
Interface EventDistributor
-
- All Known Implementing Classes:
EventDistributorImpl
public interface EventDistributor
Distributes events across the Teiid cluster
-
-
Method Summary
All Methods Instance Methods Abstract Methods Deprecated Methods Modifier and Type Method Description void
dataModification(String vdbName, int vdbVersion, String schema, String... tableNames)
Deprecated.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.void
register(EventListener listener)
Add EventListener for callback on eventsvoid
setColumnStats(String vdbName, int vdbVersion, String schemaName, String tableName, String columnName, ColumnStats stats)
Deprecated.void
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)
Deprecated.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)
Deprecated.void
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)
Deprecated.void
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)
Deprecated.void
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)
Deprecated.void
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)
Deprecated.void
updateMatViewRow(String vdbName, String vdbVersion, String schema, String viewName, List<?> tuple, boolean delete)
Update the given materialized view row.
-
-
-
Method Detail
-
updateMatViewRow
@Deprecated @Replicated(remoteOnly=true) void updateMatViewRow(String vdbName, int vdbVersion, String schema, String viewName, List<?> tuple, boolean delete)
Deprecated.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.- Parameters:
vdbName
-vdbVersion
-schema
-viewName
-tuple
-delete
-
-
updateMatViewRow
@Replicated(remoteOnly=true) void updateMatViewRow(String vdbName, String vdbVersion, String schema, String viewName, List<?> tuple, boolean delete)
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.- Parameters:
vdbName
-vdbVersion
-schema
-viewName
-tuple
-delete
-
-
dataModification
@Deprecated @Replicated(remoteOnly=true) void dataModification(String vdbName, int vdbVersion, String schema, String... tableNames)
Deprecated.Notify that the table data has changed.- Parameters:
vdbName
-vdbVersion
-schema
-tableNames
-
-
dataModification
@Replicated(remoteOnly=true) void dataModification(String vdbName, String vdbVersion, String schema, String... tableNames)
Notify that the table data has changed.- Parameters:
vdbName
-vdbVersion
-schema
-tableNames
-
-
setColumnStats
@Deprecated @Replicated(remoteOnly=true) void setColumnStats(String vdbName, int vdbVersion, String schemaName, String tableName, String columnName, ColumnStats stats)
Deprecated.Set the column stats- Parameters:
vdbName
-vdbVersion
-schemaName
-tableName
-columnName
-stats
-
-
setColumnStats
@Replicated(remoteOnly=true) void setColumnStats(String vdbName, String vdbVersion, String schemaName, String tableName, String columnName, ColumnStats stats)
Set the column stats- Parameters:
vdbName
-vdbVersion
-schemaName
-tableName
-columnName
-stats
-
-
setTableStats
@Deprecated @Replicated(remoteOnly=true) void setTableStats(String vdbName, int vdbVersion, String schemaName, String tableName, TableStats stats)
Deprecated.Set the table stats- Parameters:
vdbName
-vdbVersion
-schemaName
-tableName
-stats
-
-
setTableStats
@Replicated(remoteOnly=true) void setTableStats(String vdbName, String vdbVersion, String schemaName, String tableName, TableStats stats)
Set the table stats- Parameters:
vdbName
-vdbVersion
-schemaName
-tableName
-stats
-
-
setProperty
@Deprecated @Replicated(remoteOnly=true) void setProperty(String vdbName, int vdbVersion, String uuid, String name, String value)
Deprecated.Set the given property value- Parameters:
vdbName
-vdbVersion
-uuid
-name
-value
-
-
setProperty
@Replicated(remoteOnly=true) void setProperty(String vdbName, String vdbVersion, String uuid, String name, String value)
Set the given property value- Parameters:
vdbName
-vdbVersion
-uuid
-name
-value
-
-
setInsteadOfTriggerDefinition
@Deprecated @Replicated(remoteOnly=true) void setInsteadOfTriggerDefinition(String vdbName, int vdbVersion, String schema, String viewName, Table.TriggerEvent triggerEvent, String triggerDefinition, Boolean enabled)
Deprecated.Set the instead of trigger definition. Only one of either the triggerDefinition or enabled should be specified.- Parameters:
vdbName
-vdbVersion
-schema
-viewName
-triggerEvent
-triggerDefinition
-enabled
-
-
setInsteadOfTriggerDefinition
@Replicated(remoteOnly=true) void setInsteadOfTriggerDefinition(String vdbName, String vdbVersion, String schema, String viewName, Table.TriggerEvent triggerEvent, String triggerDefinition, Boolean enabled)
Set the instead of trigger definition. Only one of either the triggerDefinition or enabled should be specified.- Parameters:
vdbName
-vdbVersion
-schema
-viewName
-triggerEvent
-triggerDefinition
-enabled
-
-
setProcedureDefinition
@Deprecated @Replicated(remoteOnly=true) void setProcedureDefinition(String vdbName, int vdbVersion, String schema, String procName, String definition)
Deprecated.Set the procedure definition- Parameters:
vdbName
-vdbVersion
-schema
-procName
-definition
-
-
setProcedureDefinition
@Replicated(remoteOnly=true) void setProcedureDefinition(String vdbName, String vdbVersion, String schema, String procName, String definition)
Set the procedure definition- Parameters:
vdbName
-vdbVersion
-schema
-procName
-definition
-
-
setViewDefinition
@Deprecated @Replicated(remoteOnly=true) void setViewDefinition(String vdbName, int vdbVersion, String schema, String viewName, String definition)
Deprecated.Set the view definition- Parameters:
vdbName
-vdbVersion
-schema
-viewName
-definition
-
-
setViewDefinition
@Replicated(remoteOnly=true) void setViewDefinition(String vdbName, String vdbVersion, String schema, String viewName, String definition)
Set the view definition- Parameters:
vdbName
-vdbVersion
-schema
-viewName
-definition
-
-
register
void register(EventListener listener)
Add EventListener for callback on events- Parameters:
listener
-
-
unregister
void unregister(EventListener listener)
Remove EventListener- Parameters:
listener
-
-
dataModification
ResultsFuture<?> dataModification(String vdbName, String vdbVersion, String schema, String tableName, Object[] oldValues, Object[] newValues, String[] columnNames)
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.- Returns:
- a
ResultsFuture
if execution has started, or null if no execution has started
-
-