Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
impala::InProcessStatestore Class Reference

An in-process statestore, with webserver and metrics. More...

#include <in-process-servers.h>

Collaboration diagram for impala::InProcessStatestore:

Public Member Functions

 InProcessStatestore (int statestore_port, int webserver_port)
 Constructs but does not start the statestore. More...
 
Status Start ()
 Starts the statestore server, and the processing thread. More...
 
uint32_t port ()
 

Private Attributes

boost::scoped_ptr< Webserverwebserver_
 Websever object to serve debug pages through. More...
 
boost::scoped_ptr< MetricGroupmetrics_
 MetricGroup object. More...
 
uint32_t statestore_port_
 Port to start the statestore on. More...
 
boost::scoped_ptr< Statestorestatestore_
 The statestore instance. More...
 
boost::scoped_ptr< ThriftServerstatestore_server_
 Statestore Thrift server. More...
 
boost::scoped_ptr< Threadstatestore_main_loop_
 

Detailed Description

An in-process statestore, with webserver and metrics.

Definition at line 95 of file in-process-servers.h.

Constructor & Destructor Documentation

InProcessStatestore::InProcessStatestore ( int  statestore_port,
int  webserver_port 
)

Constructs but does not start the statestore.

Definition at line 84 of file in-process-servers.cc.

References impala::AddDefaultUrlCallbacks(), statestore_, and webserver_.

Member Function Documentation

uint32_t impala::InProcessStatestore::port ( )
inline

Definition at line 103 of file in-process-servers.h.

References statestore_port_.

Status InProcessStatestore::Start ( )

Starts the statestore server, and the processing thread.

Definition at line 93 of file in-process-servers.cc.

References impala::Statestore::MainLoop(), metrics_, RETURN_IF_ERROR, statestore_, statestore_main_loop_, statestore_port_, statestore_server_, impala::WaitForServer(), and webserver_.

Referenced by impala::TEST().

Member Data Documentation

boost::scoped_ptr<MetricGroup> impala::InProcessStatestore::metrics_
private

MetricGroup object.

Definition at line 110 of file in-process-servers.h.

Referenced by Start().

boost::scoped_ptr<Statestore> impala::InProcessStatestore::statestore_
private

The statestore instance.

Definition at line 116 of file in-process-servers.h.

Referenced by InProcessStatestore(), and Start().

boost::scoped_ptr<Thread> impala::InProcessStatestore::statestore_main_loop_
private

Definition at line 121 of file in-process-servers.h.

Referenced by Start().

uint32_t impala::InProcessStatestore::statestore_port_
private

Port to start the statestore on.

Definition at line 113 of file in-process-servers.h.

Referenced by port(), and Start().

boost::scoped_ptr<ThriftServer> impala::InProcessStatestore::statestore_server_
private

Statestore Thrift server.

Definition at line 119 of file in-process-servers.h.

Referenced by Start().

boost::scoped_ptr<Webserver> impala::InProcessStatestore::webserver_
private

Websever object to serve debug pages through.

Definition at line 107 of file in-process-servers.h.

Referenced by InProcessStatestore(), and Start().


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