diff options
Diffstat (limited to 'contrib/native/client/src/include')
-rw-r--r-- | contrib/native/client/src/include/drill/common.hpp | 9 | ||||
-rw-r--r-- | contrib/native/client/src/include/drill/drillClient.hpp | 7 |
2 files changed, 14 insertions, 2 deletions
diff --git a/contrib/native/client/src/include/drill/common.hpp b/contrib/native/client/src/include/drill/common.hpp index bb8e2b4a3..a617dc71f 100644 --- a/contrib/native/client/src/include/drill/common.hpp +++ b/contrib/native/client/src/include/drill/common.hpp @@ -45,6 +45,11 @@ #define MEM_CHUNK_SIZE 64*1024; // 64K #define MAX_MEM_ALLOC_SIZE 256*1024*1024; // 256 MB +#define MAX_BATCH_SIZE 65536; // see RecordBatch.java +#define ENABLE_CONNECTION_POOL_ENV "DRILL_ENABLE_CONN_POOL" +#define DEFAULT_MAX_CONCURRENT_CONNECTIONS 10 +#define MAX_CONCURRENT_CONNECTIONS_ENV "DRILL_MAX_CONN" + #ifdef _DEBUG #define EXTRA_DEBUGGING #define CODER_DEBUGGING @@ -110,7 +115,9 @@ typedef enum{ CONN_HOSTNAME_RESOLUTION_ERROR=6, CONN_AUTH_FAILED=7, CONN_BAD_RPC_VER=8, - CONN_DEAD=9 + CONN_DEAD=9, + CONN_NOTCONNECTED=10, + CONN_ALREADYCONNECTED=11 } connectionStatus_t; typedef enum{ diff --git a/contrib/native/client/src/include/drill/drillClient.hpp b/contrib/native/client/src/include/drill/drillClient.hpp index 4568ca1fc..a74f4bdc7 100644 --- a/contrib/native/client/src/include/drill/drillClient.hpp +++ b/contrib/native/client/src/include/drill/drillClient.hpp @@ -53,6 +53,7 @@ namespace exec{ namespace Drill{ //struct UserServerEndPoint; +class DrillClientImplBase; class DrillClientImpl; class DrillClientQueryResult; class FieldMetadata; @@ -340,6 +341,10 @@ class DECLSPEC_DRILL_CLIENT DrillClient{ std::string& getError(); /* + * Returns the error message associated with the query handle + */ + const std::string& getError(QueryHandle_t handle); + /* * Applications using the async query submit method can register a listener for schema changes * */ @@ -369,7 +374,7 @@ class DECLSPEC_DRILL_CLIENT DrillClient{ static DrillClientInitializer s_init; static DrillClientConfig s_config; - DrillClientImpl * m_pImpl; + DrillClientImplBase * m_pImpl; }; } // namespace Drill |