package com.ruoshui.flink.streaming.web.common;

/**
 * @author xinjingruoshui
 * @Description:
 * @date 2021/3/7
 * @time 10:59
 */
public class FlinkConstants {

    public static final String EXACTLY_ONCE = "EXACTLY_ONCE";

    public static final String AT_LEAST_ONCE = "AT_LEAST_ONCE";

    public static final String DELETE_ON_CANCELLATION = "DELETE_ON_CANCELLATION";

    public static final String RETAIN_ON_CANCELLATION = "RETAIN_ON_CANCELLATION";


}
