Package org.apache.flink.table.gateway.workflow

Class WorkflowInfo

java.lang.Object

org.apache.flink.table.gateway.workflow.WorkflowInfo

public class WorkflowInfo
extends Object

The WorkflowInfo represents the required information of one materialized table background workflow. It is used by EmbeddedSchedulerJob when trigger the execution of workflow.

Note: All member variables need be able to be serialized as json string.

Constructor Summary

Constructors

Constructor	Description
WorkflowInfo(String materializedTableIdentifier, Map<String,String> dynamicOptions, Map<String,String> initConfig, Map<String,String> executionConfig, String restEndpointUrl)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
Map<String,String>	getDynamicOptions()
Map<String,String>	getExecutionConfig()
Map<String,String>	getInitConfig()
String	getMaterializedTableIdentifier()
String	getRestEndpointUrl()
int	hashCode()
String	toString()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Detail

WorkflowInfo

public WorkflowInfo(String materializedTableIdentifier,
                    Map<String,String> dynamicOptions,
                    Map<String,String> initConfig,
                    Map<String,String> executionConfig,
                    String restEndpointUrl)

Method Detail

getMaterializedTableIdentifier

public String getMaterializedTableIdentifier()

getDynamicOptions

public Map<String,String> getDynamicOptions()

getInitConfig

public Map<String,String> getInitConfig()

getExecutionConfig

public Map<String,String> getExecutionConfig()

getRestEndpointUrl

public String getRestEndpointUrl()

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object