#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"
Go to the source code of this file.
|
| impala |
| This file contains type definitions that are used throughout the code base.
|
|
|
| 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.") |
|
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." |
|
|
) |
| |