TachyonHelper

package tach_demo;

import java.net.InetSocketAddress;

import tachyon.org.apache.thrift.TProcessor;
import tachyon.org.apache.thrift.server.TServer;
import tachyon.org.apache.thrift.server.TThreadedSelectorServer;
import tachyon.org.apache.thrift.transport.TNonblockingServerSocket;
import tachyon.org.apache.thrift.transport.TTransportException;

import tachyon.master.MasterServiceHandler;
import tachyon.thrift.MasterService;

public class TachyonHelper {

    private TachyonHelper() {};

    public static TServer createServer() throws Exception {
      return new TThreadedSelectorServer(args());
    }

    private static TThreadedSelectorServer.Args args() throws Exception {
      MasterService.Processor<MasterServiceHandler> p =
      //TProcessor p =
        new MasterService.Processor<MasterServiceHandler>(new MasterServiceHandler(null));
      InetSocketAddress address = new InetSocketAddress(12345);
      return new TThreadedSelectorServer.Args(new TNonblockingServerSocket(address))
        .processor(p)
        .selectorThreads(10)
        .acceptQueueSizePerThread(10)
        .workerThreads(10);
    }

}