ÔÚFlinkµ±Îª¶àÌõ¼þ×éºÏµÄʱºò£¬ÊÇÔÚÕâ¸öÀàÀïÃæдºÃÂð£¿

ÔÚFlinkÖÐ，µ±ÐèҪΪ¶àÌõ¼þ×éºÏʱ，¿ÉÒÔÔÚConditionÀàÖж¨ÒåÏàÓ¦µÄ×ֶκͷ½·¨¡£ÒÔÏÂÊÇÒ»¸öʾÀý：

public class Condition {
    private String type; // Ìõ¼þÀàÐÍ
    private String className; // ˈ̞

    public Condition(String type, String className) {
        this.type = type;
        this.className = className;
    }

    public String getType() {
        return type;
    }

    public void setType(String type) {
        this.type = type;
    }

    public String getClassName() {
        return className;
    }

    public void setClassName(String className) {
        this.className = className;
    }

    // ¸ù¾ÝÌõ¼þÀàÐͺÍÀàÃû´´½¨ÏàÓ¦µÄʵÀý
    public static Object createInstance(String type, String className) throws Exception {
        Class<?> clazz = Class.forName(className);
        if (type.equals("Class")) {
            return clazz.newInstance();
        } else {
            throw new Exception("²»Ö§³ÖµÄÌõ¼þÀàÐÍ");
        }
    }
}

ÔÚÕâ¸öʾÀýÖÐ，ÎÒÃǶ¨ÒåÁËÒ»¸öConditionÀà，ÆäÖаüº¬ÁËtypeºÍclassNameÁ½¸ö×ֶΡ£ÎÒÃÇ»¹ÌṩÁËÒ»¸ö¾²Ì¬·½·¨createInstance，ÓÃÓÚ¸ù¾ÝÌõ¼þÀàÐͺÍÀàÃû´´½¨ÏàÓ¦µÄʵÀý¡£