Class EmbeddedRefreshHandler

  • All Implemented Interfaces:
    Serializable, org.apache.flink.table.refresh.RefreshHandler

    @PublicEvolving
    public class EmbeddedRefreshHandler
    extends Object
    implements org.apache.flink.table.refresh.RefreshHandler, Serializable
    A RefreshHandler instance for embedded workflow scheduler.
    See Also:
    Serialized Form
    • Constructor Detail

      • EmbeddedRefreshHandler

        public EmbeddedRefreshHandler​(String workflowName,
                                      String workflowGroup)
    • Method Detail

      • asSummaryString

        public String asSummaryString()
        Specified by:
        asSummaryString in interface org.apache.flink.table.refresh.RefreshHandler
      • getWorkflowName

        public String getWorkflowName()
      • getWorkflowGroup

        public String getWorkflowGroup()
      • hashCode

        public int hashCode()
        Overrides:
        hashCode in class Object