作者:立案whan_597 | 来源:互联网 | 2023-08-26 18:10
本文整理了Java中org.apache.kylin.common.KylinConfig.getTimeZone()
方法的一些代码示例,展示了KylinConfig.getTimeZone()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。KylinConfig.getTimeZone()
方法的具体详情如下:
包路径:org.apache.kylin.common.KylinConfig
类名称:KylinConfig
方法名:getTimeZone
KylinConfig.getTimeZone介绍
暂无
代码示例
代码示例来源:origin: apache/kylin
/**
* @return the timeZone
*/
public String getTimeZone() {
return config.getTimeZone();
}
代码示例来源:origin: apache/kylin
@SuppressWarnings("unchecked")
@Override
public void afterPropertiesSet() throws Exception {
String timeZOne= getConfig().getTimeZone();
TimeZone tzOne= TimeZone.getTimeZone(timeZone);
TimeZone.setDefault(tzone);
final KylinConfig kylinCOnfig= KylinConfig.getInstanceFromEnv();
final Scheduler scheduler = (Scheduler) SchedulerFactory
.scheduler(kylinConfig.getSchedulerType());
scheduler.init(new JobEngineConfig(kylinConfig), new ZookeeperJobLock());
Runtime.getRuntime().addShutdownHook(new Thread(new Runnable() {
@Override
public void run() {
try {
scheduler.shutdown();
} catch (SchedulerException e) {
logger.error("error occurred to shutdown scheduler", e);
}
}
}));
}
代码示例来源:origin: apache/kylin
private static LookupSnapshotBuildJob initJob(CubeInstance cube, String tableName, String submitter,
KylinConfig kylinConfig) {
List projList = ProjectManager.getInstance(kylinConfig).findProjects(cube.getType(),
cube.getName());
if (projList == null || projList.size() == 0) {
throw new RuntimeException("Cannot find the project containing the cube " + cube.getName() + "!!!");
} else if (projList.size() >= 2) {
String msg = "Find more than one project containing the cube " + cube.getName()
+ ". It does't meet the uniqueness requirement!!! ";
throw new RuntimeException(msg);
}
LookupSnapshotBuildJob result = new LookupSnapshotBuildJob();
SimpleDateFormat format = new SimpleDateFormat("z yyyy-MM-dd HH:mm:ss", Locale.ROOT);
format.setTimeZone(TimeZone.getTimeZone(kylinConfig.getTimeZone()));
result.setDeployEnvName(kylinConfig.getDeployEnv());
result.setProjectName(projList.get(0).getName());
CubingExecutableUtil.setCubeName(cube.getName(), result.getParams());
result.setName(JOB_TYPE + " CUBE - " + cube.getName() + " - " + " TABLE - " + tableName + " - "
+ format.format(new Date(System.currentTimeMillis())));
result.setSubmitter(submitter);
result.setNotifyList(cube.getDescriptor().getNotifyList());
return result;
}
代码示例来源:origin: KylinOLAP/Kylin
/**
* @return the timeZone
*/
public String getTimeZone() {
return config.getTimeZone();
}
代码示例来源:origin: org.apache.kylin/kylin-core-job
/**
* @return the timeZone
*/
public String getTimeZone() {
return config.getTimeZone();
}
代码示例来源:origin: org.apache.kylin/kylin-job
/**
* @return the timeZone
*/
public String getTimeZone() {
return config.getTimeZone();
}
代码示例来源:origin: org.apache.kylin/kylin-engine-mr
private static LookupSnapshotBuildJob initJob(CubeInstance cube, String tableName, String submitter,
KylinConfig kylinConfig) {
List projList = ProjectManager.getInstance(kylinConfig).findProjects(cube.getType(),
cube.getName());
if (projList == null || projList.size() == 0) {
throw new RuntimeException("Cannot find the project containing the cube " + cube.getName() + "!!!");
} else if (projList.size() >= 2) {
String msg = "Find more than one project containing the cube " + cube.getName()
+ ". It does't meet the uniqueness requirement!!! ";
throw new RuntimeException(msg);
}
LookupSnapshotBuildJob result = new LookupSnapshotBuildJob();
SimpleDateFormat format = new SimpleDateFormat("z yyyy-MM-dd HH:mm:ss", Locale.ROOT);
format.setTimeZone(TimeZone.getTimeZone(kylinConfig.getTimeZone()));
result.setDeployEnvName(kylinConfig.getDeployEnv());
result.setProjectName(projList.get(0).getName());
CubingExecutableUtil.setCubeName(cube.getName(), result.getParams());
result.setName(JOB_TYPE + " CUBE - " + cube.getName() + " - " + " TABLE - " + tableName + " - "
+ format.format(new Date(System.currentTimeMillis())));
result.setSubmitter(submitter);
result.setNotifyList(cube.getDescriptor().getNotifyList());
return result;
}