AJ-433: support ThreadPooledClient(int threadCount);

Author: chengyitian

src/com/xxdb/multithreadedtablewriter/MultithreadedTableWriter.java

@@ -357,6 +357,7 @@ public MultithreadedTableWriter(String hostName, int port, String userId, String
         init(hostName,port,userId, password,dbName, tableName, useSSL,enableHighAvailability,highAvailabilitySites,
                 batchSize, throttle,threadCount,partitionCol,compressTypes, Mode.M_Append, null, callbackHandler);
     }
+
     private void init(String hostName, int port, String userId, String password,
                       String dbName, String tableName, boolean useSSL,
                       boolean enableHighAvailability, String[] highAvailabilitySites,

src/com/xxdb/streaming/client/ThreadPooledClient.java

@@ -37,6 +37,10 @@ public ThreadPooledClient() throws SocketException {
         this("", DEFAULT_PORT, CORES);
     }
 
+    public ThreadPooledClient(int threadCount) throws SocketException {
+        this("", 0, threadCount);
+    }
+
     public ThreadPooledClient(int subscribePort, int threadCount) throws SocketException {
         this("", subscribePort, threadCount);
     }