@Override
    protected JobPo getJob(String taskTrackerNodeGroup, String jobId) {
        String tableName = JobQueueUtils.getExecutableQueueName(taskTrackerNodeGroup);
        Query<JobPo> query = template.createQuery(tableName, JobPo.class);
        query.field("jobId").equal(jobId).
                field("taskTrackerNodeGroup").equal(taskTrackerNodeGroup);
        return query.get();
    }
@author Robert HG (254963746@qq.com) on 8/13/15.
lts-core/src/main/java/com/github/ltsopensource/queue/mongo/MongoPreLoader.java