public static DataStream getSideJoinDataStream(DataStream inputStream, String sideType, String sqlRootDir, RowTypeInfo rowTypeInfo, JoinInfo joinInfo,
                                                   List<FieldInfo> outFieldInfoList, AbstractSideTableInfo sideTableInfo, String pluginLoadMode) throws Exception {
        BaseAllReqRow allReqRow = loadFlatMap(sideType, sqlRootDir, rowTypeInfo, joinInfo, outFieldInfoList, sideTableInfo, pluginLoadMode);
        return inputStream.flatMap(allReqRow).setParallelism(sideTableInfo.getParallelism());
    }
get plugin which implement from RichFlatMapFunction
Date: 2018/9/18
Company: www.dtstack.com

@author xuchao
core/src/main/java/com/dtstack/flink/sql/side/operator/SideWithAllCacheOperator.java