Repository: lens Updated Branches: refs/heads/master 6e4d1860a -> fae2773cd
http://git-wip-us.apache.org/repos/asf/lens/blob/fae2773c/lens-server/src/test/java/org/apache/lens/server/scheduler/util/SchedulerTestUtils.java ---------------------------------------------------------------------- diff --git a/lens-server/src/test/java/org/apache/lens/server/scheduler/util/SchedulerTestUtils.java b/lens-server/src/test/java/org/apache/lens/server/scheduler/util/SchedulerTestUtils.java new file mode 100644 index 0000000..a36b2aa --- /dev/null +++ b/lens-server/src/test/java/org/apache/lens/server/scheduler/util/SchedulerTestUtils.java @@ -0,0 +1,70 @@ +/** + * Licensed to the Apache Software Foundation (ASF) under one + * or more contributor license agreements. See the NOTICE file + * distributed with this work for additional information + * regarding copyright ownership. The ASF licenses this file + * to you under the Apache License, Version 2.0 (the + * "License"); you may not use this file except in compliance + * with the License. You may obtain a copy of the License at + * <p> + * http://www.apache.org/licenses/LICENSE-2.0 + * <p> + * Unless required by applicable law or agreed to in writing, + * software distributed under the License is distributed on an + * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY + * KIND, either express or implied. See the License for the + * specific language governing permissions and limitations + * under the License. + */ +package org.apache.lens.server.scheduler.util; + +import java.util.GregorianCalendar; + +import javax.xml.datatype.DatatypeFactory; +import javax.xml.datatype.XMLGregorianCalendar; + +import org.apache.lens.api.scheduler.*; + +public class SchedulerTestUtils { + + private SchedulerTestUtils() { + + } + private static XTrigger getTestTrigger(String cron) { + XTrigger trigger = new XTrigger(); + XFrequency frequency = new XFrequency(); + frequency.setCronExpression(cron); + frequency.setTimezone("UTC"); + trigger.setFrequency(frequency); + return trigger; + } + + private static XExecution getTestExecution(String queryString) { + XExecution execution = new XExecution(); + XJobQuery query = new XJobQuery(); + query.setQuery(queryString); + execution.setQuery(query); + XSessionType sessionType = new XSessionType(); + sessionType.setDb("default"); + execution.setSession(sessionType); + return execution; + } + + public static XJob getTestJob(String cron, String query, long start, long end) throws Exception { + XJob job = new XJob(); + job.setTrigger(getTestTrigger(cron)); + job.setName("Test lens Job"); + GregorianCalendar startTime = new GregorianCalendar(); + startTime.setTimeInMillis(start); + XMLGregorianCalendar startCal = DatatypeFactory.newInstance().newXMLGregorianCalendar(startTime); + + GregorianCalendar endTime = new GregorianCalendar(); + endTime.setTimeInMillis(end); + XMLGregorianCalendar endCal = DatatypeFactory.newInstance().newXMLGregorianCalendar(endTime); + + job.setStartTime(startCal); + job.setEndTime(endCal); + job.setExecution(getTestExecution(query)); + return job; + } +}
