Impala
Impalaistheopensource,nativeanalyticdatabaseforApacheHadoop.
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros
statestore-subscriber.cc File Reference
#include "statestore/statestore-subscriber.h"
#include <sstream>
#include <utility>
#include <boost/algorithm/string/join.hpp>
#include <boost/foreach.hpp>
#include <boost/date_time/posix_time/posix_time.hpp>
#include <boost/thread/shared_mutex.hpp>
#include <gutil/strings/substitute.h>
#include "common/logging.h"
#include "common/status.h"
#include "statestore/failure-detector.h"
#include "gen-cpp/StatestoreService_types.h"
#include "rpc/rpc-trace.h"
#include "rpc/thrift-util.h"
#include "util/time.h"
#include "util/debug-util.h"
#include "common/names.h"
Include dependency graph for statestore-subscriber.cc:

Go to the source code of this file.

Classes

class  impala::StatestoreSubscriberThriftIf
 

Namespaces

 impala
 This file contains type definitions that are used throughout the code base.
 

Typedefs

typedef ClientConnection
< StatestoreServiceClient > 
impala::StatestoreConnection
 

Functions

 DEFINE_int32 (statestore_subscriber_timeout_seconds, 30,"The amount of time (in seconds)"" that may elapse before the connection with the statestore is considered lost.")
 
 DEFINE_int32 (statestore_subscriber_cnxn_attempts, 10,"The number of times to retry an ""RPC connection to the statestore. A setting of 0 means retry indefinitely")
 
 DEFINE_int32 (statestore_subscriber_cnxn_retry_interval_ms, 3000,"The interval, in ms, ""to wait between attempts to make an RPC connection to the statestore.")
 

Variables

const string impala::STATESTORE_ID = "STATESTORE"
 
const string impala::CALLBACK_METRIC_PATTERN = "statestore-subscriber.topic-$0.processing-time-s"
 
const int32_t impala::SLEEP_INTERVAL_MS = 5000
 

Function Documentation

DEFINE_int32 ( statestore_subscriber_timeout_seconds  ,
30  ,
"The amount of time (in seconds)"" that may elapse before the connection with the statestore is considered lost."   
)
DEFINE_int32 ( statestore_subscriber_cnxn_attempts  ,
10  ,
"The number of times to retry an ""RPC connection to the statestore. A setting of 0 means retry indefinitely"   
)
DEFINE_int32 ( statestore_subscriber_cnxn_retry_interval_ms  ,
3000  ,
"The  interval,
in  ms,
""to wait between attempts to make an RPC connection to the statestore."   
)