public static String getSqlSideClassName(String pluginTypeName, String type, String operatorType){
        String pluginClassName = upperCaseFirstChar(pluginTypeName) + operatorType + "ReqRow";
        return CLASS_PRE_STR  + "." + type.toLowerCase() + "." +  pluginTypeName + "." + pluginClassName;
    }
Reason:
Date: 2018/6/27
Company: www.dtstack.com
@author xuchao
core/src/main/java/com/dtstack/flink/sql/util/PluginUtil.java