| 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 © 2018 The Apache Software Foundation. All rights reserved.