@Override
    public void open(Configuration parameters) throws Exception {
        RdbSideTableInfo tableInfo = (RdbSideTableInfo) sideInfo.getSideTableInfo();
        synchronized (AbstractRdbAllReqRow.class) {
            if (resourceCheck) {
                resourceCheck = false;
                JdbcResourceCheck.getInstance().checkResourceStatus(tableInfo.getCheckProperties());
            }
        }
        super.open(parameters);
        LOG.info("rdb dim table config info: {} ", tableInfo.toString());
    }
side operator with cache for all(period reload)
Date: 2018/11/26
Company: www.dtstack.com

@author maqi
rdb/rdb-side/src/main/java/com/dtstack/flink/sql/side/rdb/all/AbstractRdbAllReqRow.java