TraceAnalyzerTest.java 585 Bytes
package com.yoho.trace.online;

import com.yoho.trace.offline.AnalyzeHandleFactory;
import org.apache.spark.SparkConf;
import org.apache.spark.api.java.JavaSparkContext;
import properties.PropertiesFactory;


/**
 * Created by xjipeng on 2017/10/4.
 */


public class TraceAnalyzerTest {

    public static void main(String[] args) throws Exception {

        SparkConf sparkConf = new SparkConf().setAppName("TraceExecutor").setMaster("local[4]");
        JavaSparkContext jsc = new JavaSparkContext(sparkConf);

        AnalyzeHandleFactory.start(jsc);

        jsc.stop();
    }

}