org.apache.flink.table.gateway.rest.message.materializedtable.scheduler

Class CreateEmbeddedSchedulerWorkflowRequestBody

java.lang.Object

org.apache.flink.table.gateway.rest.message.materializedtable.scheduler.CreateEmbeddedSchedulerWorkflowRequestBody

All Implemented Interfaces:

org.apache.flink.runtime.rest.messages.RequestBody

public class CreateEmbeddedSchedulerWorkflowRequestBody
extends Object
implements org.apache.flink.runtime.rest.messages.RequestBody

RequestBody for create workflow in embedded scheduler.

Constructor Summary

Constructors

Constructor and Description
CreateEmbeddedSchedulerWorkflowRequestBody(String materializedTableIdentifier, String cronExpression, Map<String,String> initConfig, Map<String,String> executionConfig, String restEndpointUrl)

Method Summary

Modifier and Type	Method and Description
String	getCronExpression()
Map<String,String>	getExecutionConfig()
Map<String,String>	getInitConfig()
String	getMaterializedTableIdentifier()
String	getRestEndpointUrl()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

CreateEmbeddedSchedulerWorkflowRequestBody

public CreateEmbeddedSchedulerWorkflowRequestBody(String materializedTableIdentifier,
                                                  String cronExpression,
                                                  @Nullable
                                                  Map<String,String> initConfig,
                                                  @Nullable
                                                  Map<String,String> executionConfig,
                                                  String restEndpointUrl)

Method Detail

getMaterializedTableIdentifier

public String getMaterializedTableIdentifier()

getInitConfig

@Nullable
public Map<String,String> getInitConfig()

getExecutionConfig

@Nullable
public Map<String,String> getExecutionConfig()

getCronExpression

public String getCronExpression()

getRestEndpointUrl

public String getRestEndpointUrl()