Package org.teiid.events

Interface EventDistributor

All Known Implementing Classes:

EventDistributorImpl

public interface EventDistributor

Distributes events across the Teiid cluster

Method Summary

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 events
void	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 stats
void	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 definition
void	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 value
void	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 stats
void	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 definition
void	unregister(EventListener listener)	Remove EventListener
void	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