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 Description static DateTimeFormatterDEFAULT_DATETIME_FORMATTERstatic StringQUARTZ_JOB_GROUPstatic StringQUARTZ_JOB_PREFIXstatic StringSCHEDULE_TIME_FORMATstatic StringUNDERLINEstatic StringWORKFLOW_INFO
-
Constructor Summary
Constructors Constructor Description QuartzSchedulerUtils()
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static StringdateToString(Date date)static <T> TfromJson(String json, Class<T> clazz)static org.quartz.JobKeygetJobKey(String materializedTableIdentifier)static PropertiesinitializeQuartzSchedulerConfig()This method is used for initializing the quartz scheduler config, the related options copy from quartz.properties, but we override the optionorg.quartz.threadPool.threadCountto 1 for minimizing the thread impact to SqlGateway.static <T> StringtoJson(T t)
-
-
-
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
-
-
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 optionorg.quartz.threadPool.threadCountto 1 for minimizing the thread impact to SqlGateway.
-
getJobKey
public static org.quartz.JobKey getJobKey(String materializedTableIdentifier)
-
toJson
public static <T> String toJson(T t)
-
-