按session粒度进行数据聚合

6.2.1、 获取请求的taskid, 从数据库中查询到请求的参数

        // 创建需要使用的DAO组件
        ITaskDAO taskDAO = DAOFactory.getTaskDAO();

        // 首先得查询出来指定的任务，并获取任务的查询参数
        long taskid = 1L;
        Task task = taskDAO.findById(taskid);
        JSONObject taskParam = new  JSONObject(task.getTaskParam());

6.2.2、获取指定日期范围内的用户访问行为数据

    /**
     * 获取指定日期范围内的用户访问行为数据
     * @param sqlContext SQLContext
     * @param taskParam 任务参数
     * @return 行为数据RDD
     */
    private static JavaRDD getActionRDDByDateRange(
            SQLContext sqlContext, JSONObject taskParam) {
        //解析请求参数
        String startDate = ParamUtils.getParam(taskParam, Constants.PARAM_START_DATE);
        String endDate = ParamUtils.getParam(taskParam, Constants.PARAM_END_DATE);

        String sql = 
                "select * from user_visit_action "
                        + "where start>='" + startDate + "' "
                        + "and start