public static void createOdpsShipper()

in src/main/java/com/aliyun/openservices/log/sample/ShipperSample.java [28:73]
39 lines of code
3 McCabe index (conditional complexity)

    public static void createOdpsShipper() throws LogException {
        String shipperName = "odpsshipper";
        String odpsEndPoint = "";
        String odpsProject = "odps_project";
        String odpsTable = "odps_table";
        List<String> logFieldsList = new ArrayList<String>();
        logFieldsList.add("__topic__");
        logFieldsList.add("__time__");
        logFieldsList.add("a");
        logFieldsList.add("b");
        logFieldsList.add("b");

        List<String> partitionColumn = new ArrayList<String>();
        partitionColumn.add("p_a");
        partitionColumn.add("__PARTITION_TIME__");
        String partitionTimeFormat = "yyyy_MM_dd_HH_mm";

        ShipperConfig shipConfig = new OdpsShipperConfig(odpsEndPoint,
                odpsProject, odpsTable, logFieldsList, partitionColumn,
                partitionTimeFormat);

        client.CreateShipper(project, logStore, shipperName, shipConfig);

        GetShipperResponse res = client.GetShipperConfig(project, logStore,
                shipperName);
        System.out.println(res.GetConfig().GetShipperType());
        System.out.println(res.GetConfig().GetJsonObj());

        try {
            Thread.sleep(5 * 1000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }

        int startTime = (int) (System.currentTimeMillis() / 1000.0 - 7200);
        int endTime = (int) (System.currentTimeMillis() / 1000.0);
        GetShipperTasksResponse taskRes = client.GetShipperTasks(project, logStore, shipperName, startTime, endTime, "", 0, 10);
        System.out.println(taskRes.GetTotalTask());
        for (ShipperTask shipperTask : taskRes.GetShipperTasks()) {
            System.out.println(shipperTask.GetTaskCreateTime());
            System.out.println(shipperTask.GetTaskFinishTime());
            System.out.println(shipperTask.GetTaskDataLines());
        }

        client.DeleteShipper(project, logStore, shipperName);
    }