package com.flink.streaming.web.common;

/**
 * @author zhuhuipei
 * @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";

}
