Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
|
An in-process statestore, with webserver and metrics. More...
#include <in-process-servers.h>
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< Webserver > | webserver_ |
Websever object to serve debug pages through. More... | |
boost::scoped_ptr< MetricGroup > | metrics_ |
MetricGroup object. More... | |
uint32_t | statestore_port_ |
Port to start the statestore on. More... | |
boost::scoped_ptr< Statestore > | statestore_ |
The statestore instance. More... | |
boost::scoped_ptr< ThriftServer > | statestore_server_ |
Statestore Thrift server. More... | |
boost::scoped_ptr< Thread > | statestore_main_loop_ |
An in-process statestore, with webserver and metrics.
Definition at line 95 of file in-process-servers.h.
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_.
|
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().
|
private |
|
private |
The statestore instance.
Definition at line 116 of file in-process-servers.h.
Referenced by InProcessStatestore(), and Start().
|
private |
Definition at line 121 of file in-process-servers.h.
Referenced by Start().
|
private |
Port to start the statestore on.
Definition at line 113 of file in-process-servers.h.
|
private |
Statestore Thrift server.
Definition at line 119 of file in-process-servers.h.
Referenced by Start().
|
private |
Websever object to serve debug pages through.
Definition at line 107 of file in-process-servers.h.
Referenced by InProcessStatestore(), and Start().