org.apache.flink.table.gateway.workflow.scheduler

Class QuartzSchedulerUtils

java.lang.Object

org.apache.flink.table.gateway.workflow.scheduler.QuartzSchedulerUtils

public class QuartzSchedulerUtils
extends Object

Utility class for quartz scheduler.

Field Summary

Fields

Modifier and Type	Field and Description
static DateTimeFormatter	DEFAULT_DATETIME_FORMATTER
static String	QUARTZ_JOB_GROUP
static String	QUARTZ_JOB_PREFIX
static String	SCHEDULE_TIME_FORMAT
static String	UNDERLINE
static String	WORKFLOW_INFO

Constructor Summary

Constructors

Constructor and Description
QuartzSchedulerUtils()

Method Summary

Modifier and Type	Method and Description
static String	dateToString(Date date)
static <T> T	fromJson(String json, Class<T> clazz)
static org.quartz.JobKey	getJobKey(String materializedTableIdentifier)
static Properties	initializeQuartzSchedulerConfig() This method is used for initializing the quartz scheduler config, the related options copy from quartz.properties, but we override the option org.quartz.threadPool.threadCount to 1 for minimizing the thread impact to SqlGateway.
static <T> String	toJson(T t)

Methods inherited from class java.lang.Object

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

Field Detail

SCHEDULE_TIME_FORMAT

public static final String SCHEDULE_TIME_FORMAT

See Also:

Constant Field Values

DEFAULT_DATETIME_FORMATTER

public static final DateTimeFormatter DEFAULT_DATETIME_FORMATTER

QUARTZ_JOB_PREFIX

public static final String QUARTZ_JOB_PREFIX

See Also:

Constant Field Values

QUARTZ_JOB_GROUP

public static final String QUARTZ_JOB_GROUP

See Also:

Constant Field Values

UNDERLINE

public static final String UNDERLINE

See Also:

Constant Field Values

WORKFLOW_INFO

public static final String WORKFLOW_INFO

See Also:

Constant Field Values

Constructor Detail

QuartzSchedulerUtils

public QuartzSchedulerUtils()

Method Detail

initializeQuartzSchedulerConfig

public static Properties initializeQuartzSchedulerConfig()

This method is used for initializing the quartz scheduler config, the related options copy from quartz.properties, but we override the option org.quartz.threadPool.threadCount to 1 for minimizing the thread impact to SqlGateway.

getJobKey

public static org.quartz.JobKey getJobKey(String materializedTableIdentifier)

fromJson

public static <T> T fromJson(String json,
                             Class<T> clazz)

toJson

public static <T> String toJson(T t)

dateToString

public static String dateToString(Date date)