TraceExecutor.java
538 Bytes
package com.yoho.trace.offline;
import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaSparkContext;
import properties.PropertiesFactory;
/**
* Created by xjipeng on 2017/10/4.
*/
public class TraceExecutor {
public static void main(String[] args) throws Exception {
SparkConf sparkConf = new SparkConf().setAppName("TraceExecutor");
JavaSparkContext jsc = new JavaSparkContext(sparkConf);
AnalyzeHandleFactory.start(jsc);
Thread.sleep(600000);
jsc.stop();
}
}