Inheritance diagram for com.mapd.parser.server.CalciteServerWrapper:

Collaboration diagram for com.mapd.parser.server.CalciteServerWrapper:

Public Member Functions
	CalciteServerWrapper ()

	CalciteServerWrapper (int calcitePort, int heavyDBPort, String dataDir, String extensionFunctionsAstFile, SockTransportProperties client_skT, SockTransportProperties server_skT)

	CalciteServerWrapper (int calcitePort, int heavyDBPort, String dataDir, String extensionFunctionsAstFile, SockTransportProperties client_skT, SockTransportProperties server_skT, String userDefinedFunctionsFile)

void	stopServer ()

void	run ()

Package Functions
boolean	shutdown ()

Private Member Functions
void	startServer (ai.heavy.thrift.calciteserver.CalciteServer.Processor processor)

Private Attributes
final CalciteServerHandler	handler

final Processor	processor

TServer	server

int	heavyDBPort = 6274

String	dataDir = ("data/")

int	calcitePort = 6279

boolean	shutdown = false

SockTransportProperties	server_skT_

Static Private Attributes
static final Logger	HEAVYDBLOGGER

Detailed Description

Definition at line 32 of file CalciteServerWrapper.java.

Constructor & Destructor Documentation

com.mapd.parser.server.CalciteServerWrapper.CalciteServerWrapper ( )

inline

Definition at line 44 of file CalciteServerWrapper.java.

References com.mapd.parser.server.CalciteServerWrapper.dataDir, com.mapd.parser.server.CalciteServerWrapper.handler, com.mapd.parser.server.CalciteServerWrapper.heavyDBPort, and com.mapd.parser.server.CalciteServerWrapper.processor.

                                 {
     handler = new CalciteServerHandler(heavyDBPort, dataDir, null, null, "");
     processor = new ai.heavy.thrift.calciteserver.CalciteServer.Processor(handler);
   }

com.mapd.parser.server.CalciteServerWrapper.CalciteServerWrapper	(	int	calcitePort,
		int	heavyDBPort,
		String	dataDir,
		String	extensionFunctionsAstFile,
		SockTransportProperties	client_skT,
		SockTransportProperties	server_skT
	)

inline

Definition at line 49 of file CalciteServerWrapper.java.

References com.mapd.parser.server.CalciteServerWrapper.calcitePort, com.mapd.parser.server.CalciteServerWrapper.handler, com.mapd.parser.server.CalciteServerWrapper.heavyDBPort, and com.mapd.parser.server.CalciteServerWrapper.processor.

                                               {
     handler = new CalciteServerHandler(
             heavyDBPort, dataDir, extensionFunctionsAstFile, client_skT, "");
     processor = new ai.heavy.thrift.calciteserver.CalciteServer.Processor(handler);
     this.calcitePort = calcitePort;
     this.heavyDBPort = heavyDBPort;
     this.server_skT_ = server_skT;
   }

com.mapd.parser.server.CalciteServerWrapper.CalciteServerWrapper	(	int	calcitePort,
		int	heavyDBPort,
		String	dataDir,
		String	extensionFunctionsAstFile,
		SockTransportProperties	client_skT,
		SockTransportProperties	server_skT,
		String	userDefinedFunctionsFile
	)

inline

Definition at line 63 of file CalciteServerWrapper.java.

References com.mapd.parser.server.CalciteServerWrapper.calcitePort, com.mapd.parser.server.CalciteServerWrapper.handler, com.mapd.parser.server.CalciteServerWrapper.heavyDBPort, and com.mapd.parser.server.CalciteServerWrapper.processor.

                                            {
     handler = new CalciteServerHandler(heavyDBPort,
             dataDir,
             extensionFunctionsAstFile,
             client_skT,
             userDefinedFunctionsFile);
     processor = new ai.heavy.thrift.calciteserver.CalciteServer.Processor(handler);
     this.calcitePort = calcitePort;
     this.heavyDBPort = heavyDBPort;
     this.server_skT_ = server_skT;
     try {
     } catch (Exception e) {
       e.printStackTrace();
     }
   }

Member Function Documentation

void com.mapd.parser.server.CalciteServerWrapper.run ( )

inline

Definition at line 112 of file CalciteServerWrapper.java.

References com.mapd.parser.server.CalciteServerWrapper.processor, and com.mapd.parser.server.CalciteServerWrapper.startServer().

                     {
     startServer(processor);
   }

Here is the call graph for this function:

boolean com.mapd.parser.server.CalciteServerWrapper.shutdown ( )

inlinepackage

Definition at line 116 of file CalciteServerWrapper.java.

Referenced by com.mapd.parser.server.CalciteServerWrapper.startServer(), and com.mapd.parser.server.CalciteServerWrapper.stopServer().

                      {
     return shutdown;
   }

Here is the caller graph for this function:

void com.mapd.parser.server.CalciteServerWrapper.startServer ( ai.heavy.thrift.calciteserver.CalciteServer.Processor processor )

inlineprivate

Definition at line 85 of file CalciteServerWrapper.java.

References com.mapd.parser.server.CalciteServerWrapper.calcitePort, com.mapd.parser.server.CalciteServerWrapper.heavyDBPort, com.mapd.parser.server.CalciteServerWrapper.processor, com.mapd.parser.server.CalciteServerWrapper.server, and com.mapd.parser.server.CalciteServerWrapper.shutdown().

Referenced by com.mapd.parser.server.CalciteServerWrapper.run().

                                                                            {
     try {
       TServerTransport serverTransport = server_skT_.openServerTransport(calcitePort);
       server = new TThreadPoolServer(
               new TThreadPoolServer.Args(serverTransport).processor(processor));
 
       HEAVYDBLOGGER.debug("Starting a threaded pool server... Listening on port "
               + calcitePort + " HEAVY.AI on port " + heavyDBPort);
       handler.setServer(server);
       server.serve();
       // we have been told to shut down (only way to get to this piece of code
       shutdown = true;
 
     } catch (Exception e) {
       e.printStackTrace();
       HEAVYDBLOGGER.error(" Calcite server Failed to start ");
       shutdown = true;
     }
   }

Here is the call graph for this function:

Here is the caller graph for this function:

void com.mapd.parser.server.CalciteServerWrapper.stopServer ( )

inline

Definition at line 106 of file CalciteServerWrapper.java.

References com.mapd.parser.server.CalciteServerWrapper.shutdown().

                            {
     server.stop();
     shutdown = true;
   }

Here is the call graph for this function:

Member Data Documentation

int com.mapd.parser.server.CalciteServerWrapper.calcitePort = 6279

private

Definition at line 40 of file CalciteServerWrapper.java.

Referenced by com.mapd.parser.server.CalciteServerWrapper.CalciteServerWrapper(), and com.mapd.parser.server.CalciteServerWrapper.startServer().

String com.mapd.parser.server.CalciteServerWrapper.dataDir = ("data/")

private

Definition at line 39 of file CalciteServerWrapper.java.

Referenced by com.mapd.parser.server.CalciteServerWrapper.CalciteServerWrapper().

final CalciteServerHandler com.mapd.parser.server.CalciteServerWrapper.handler

private

Definition at line 35 of file CalciteServerWrapper.java.

Referenced by com.mapd.parser.server.CalciteServerWrapper.CalciteServerWrapper().

final Logger com.mapd.parser.server.CalciteServerWrapper.HEAVYDBLOGGER

staticprivate

Initial value:

=

LoggerFactory.getLogger(CalciteServerWrapper.class)

Definition at line 33 of file CalciteServerWrapper.java.

int com.mapd.parser.server.CalciteServerWrapper.heavyDBPort = 6274

private

Definition at line 38 of file CalciteServerWrapper.java.

Referenced by com.mapd.parser.server.CalciteServerWrapper.CalciteServerWrapper(), and com.mapd.parser.server.CalciteServerWrapper.startServer().

final Processor com.mapd.parser.server.CalciteServerWrapper.processor

private

Definition at line 36 of file CalciteServerWrapper.java.

Referenced by com.mapd.parser.server.CalciteServerWrapper.CalciteServerWrapper(), com.mapd.parser.server.CalciteServerWrapper.run(), and com.mapd.parser.server.CalciteServerWrapper.startServer().

TServer com.mapd.parser.server.CalciteServerWrapper.server

private

Definition at line 37 of file CalciteServerWrapper.java.

Referenced by com.mapd.parser.server.CalciteServerWrapper.startServer().

SockTransportProperties com.mapd.parser.server.CalciteServerWrapper.server_skT_

private

Definition at line 42 of file CalciteServerWrapper.java.

boolean com.mapd.parser.server.CalciteServerWrapper.shutdown = false

private

Definition at line 41 of file CalciteServerWrapper.java.

Referenced by com.mapd.parser.server.CalciteServerCaller.doWork().

The documentation for this class was generated from the following file:

/home/jenkins-slave/workspace/core-os-doxygen/java/calcite/src/main/java/com/mapd/parser/server/CalciteServerWrapper.java

Public Member Functions

Package Functions

Private Member Functions

Private Attributes

Static Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation