| Package | Description | 
|---|---|
| org.apache.kudu.client | |
| org.apache.kudu.flume.sink | |
| org.apache.kudu.mapreduce | 
| Modifier and Type | Method and Description | 
|---|---|
KuduClient | 
KuduClient.KuduClientBuilder.build()
Creates a new client that connects to the masters. 
 | 
KuduClient | 
AsyncKuduClient.syncClient()
Returns a synchronous  
KuduClient which wraps this asynchronous client. | 
| Modifier and Type | Method and Description | 
|---|---|
static KuduScanner | 
KuduScanToken.deserializeIntoScanner(byte[] buf,
                      KuduClient client)
Deserializes a  
KuduScanToken into a KuduScanner. | 
KuduScanner | 
KuduScanToken.intoScanner(KuduClient client)
Creates a  
KuduScanner from this scan token. | 
static String | 
KuduScanToken.stringifySerializedToken(byte[] buf,
                        KuduClient client)
Formats the serialized token for debug printing. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
KuduClient | 
KuduSink.getClient()  | 
| Constructor and Description | 
|---|
KuduSink(KuduClient kuduClient)  | 
| Modifier and Type | Method and Description | 
|---|---|
KuduClient | 
CommandLineParser.getClient()
Get a client connected to the configured Master(s). 
 | 
| Modifier and Type | Method and Description | 
|---|---|
static void | 
KuduTableMapReduceUtil.addCredentialsToJob(KuduClient client,
                   org.apache.hadoop.mapreduce.Job job)
Export the credentials from a  
KuduClient and store them in the given MapReduce
 Job so that KuduClients created from within tasks of that job can
 authenticate to Kudu. | 
static void | 
KuduTableMapReduceUtil.importCredentialsFromCurrentSubject(KuduClient client)
Import credentials from the current thread's JAAS  
Subject into the provided
 KuduClient. | 
Copyright © 2017 The Apache Software Foundation. All rights reserved.