package com.treelogic.proteus;

import com.treelogic.proteus.hdfs.HDFS;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;

import java.io.IOException;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
import java.util.concurrent.TimeUnit;
import java.util.logging.Level;
import java.util.stream.Stream;

/**
 * Created by ignacio.g.fernandez on 2/05/17.
 */
public class Runner {

    private static final Logger logger = LoggerFactory.getLogger(Runner.class);
    public static ExecutorService service = Executors.newFixedThreadPool(3); //Max parallelism = stream, hsm and flatness at once.

    public static void main(String[] args) throws Exception {
        ExecutorService service = Runner.service;
        String proteusHDFSFile = (String) ProteusData.get("hdfs.streamingPath");

        ProteusData.loadData();
        logger.info("Initial data loaded. Starting program.");

        service.submit(new ProteusStreamingTask<>(proteusHDFSFile));
        logger.info("Streaming service task has been submitted");


        // service.submit();
        //service.shutdown(); //Don't allow more submits
        //service.awaitTermination(1 , TimeUnit.SECONDS);
    }
}

@@ -29,48 +29,8 @@
 s;%0A%0A
-import com.treelogic.proteus.hdfs.HDFS;%0A
 impo
@@ -85,37 +85,8 @@
 ory;
-%0A%0Aimport java.io.IOException;
 %0Aimp
@@ -170,164 +170,9 @@
 rs;%0A
-import java.util.concurrent.TimeUnit;%0Aimport java.util.logging.Level;%0Aimport java.util.stream.Stream;%0A%0A/**%0A * Created by ignacio.g.fernandez on 2/05/17.%0A */
+%0A
 %0Apub
@@ -348,9 +348,10 @@
 ool(
-3
+15
 ); /
@@ -745,10 +745,8 @@
 Task
-%3C%3E
 (pro
@@ -828,17 +828,16 @@
 ted%22);%0A%0A
-%0A
         

Remove unused imports