public static void main()

in spark-utils/src/main/java/com/aliyun/odps/spark/CupidApplicationMetaExample.java [15:45]

• 21 lines of code
• 2 McCabe index (conditional complexity)

    public static void main(String[] args) throws Exception {
        CupidConf conf = new CupidConf();
        conf.set("odps.access.id", "");
        conf.set("odps.access.key", "");
        conf.set("odps.project.name", "");
        conf.set("odps.end.point", "");
        CupidSession session = new CupidSession(conf);

        /*
         * list application metas
         * yarnApplicationStates: https://hadoop.apache.org/docs/r2.7.3/api/org/apache/hadoop/yarn/api/records/YarnApplicationState.html
         * 注意：list开销较大，调用频率不建议太高
         */
        CupidTaskParamProtos.ApplicationMetaList applicationMetaList = ApplicationMetaUtil.listApplicationMeta(
                "SPARK",
                "5",
                session);
        List<CupidTaskParamProtos.ApplicationMeta> applicationMetas = applicationMetaList.getApplicationMetaListList()
                .stream()
                .collect(Collectors.toList());
        if (applicationMetas.size() > 0) {
            applicationMetas.forEach(System.out::println);
        }

        /*
         * get application meta by instanceid
         */
        String instanceId = "20211214074136554gqpk7659";
        CupidTaskParamProtos.ApplicationMeta applicationMeta= ApplicationMetaUtil.getCupidInstanceMeta(instanceId, session);
        System.out.println(applicationMeta.toString());
    }