Interface EventDistributor

  • All Known Implementing Classes:
    EventDistributorImpl

    public interface EventDistributor
    Distributes events across the Teiid cluster
    • 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 -
      • 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

        @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