| Package | Description | 
|---|---|
| org.apache.kudu.client | |
| org.apache.kudu.mapreduce | 
| Modifier and Type | Class and Description | 
|---|---|
class  | 
PleaseThrottleException
This exception notifies the application to throttle its use of Kudu. 
 | 
| Modifier and Type | Method and Description | 
|---|---|
AlterTableResponse | 
KuduClient.alterTable(String name,
          AlterTableOptions ato)
Alter a table on the cluster as specified by the builder. 
 | 
OperationResponse | 
KuduSession.apply(Operation operation)
Apply a given  
Operation to Kudu as part of this session. | 
com.stumbleupon.async.Deferred<OperationResponse> | 
AsyncKuduSession.apply(Operation operation)
Apply the given operation. 
 | 
List<OperationResponse> | 
KuduSession.close()
Blocking call that flushes the buffers (see  
KuduSession.flush() and closes the sessions. | 
RowResultIterator | 
KuduScanner.close()
Closes this scanner (don't forget to call this when you're done with it!). 
 | 
void | 
KuduClient.close()
Analogous to  
KuduClient.shutdown(). | 
KuduTable | 
KuduClient.createTable(String name,
           Schema schema,
           CreateTableOptions builder)
Create a table on the cluster with the specified name, schema, and table configurations. 
 | 
DeleteTableResponse | 
KuduClient.deleteTable(String name)
Delete a table on the cluster with the specified name. 
 | 
byte[] | 
KuduClient.exportAuthenticationCredentials()
Export serialized authentication data that may be passed to a different
 client instance and imported to provide that client the ability to connect
 to the cluster. 
 | 
List<OperationResponse> | 
KuduSession.flush()
Blocking call that force flushes this session's buffers. 
 | 
ListTablesResponse | 
KuduClient.getTablesList()
Get the list of all the tables. 
 | 
ListTablesResponse | 
KuduClient.getTablesList(String nameFilter)
Get a list of table names. 
 | 
boolean | 
KuduClient.isAlterTableDone(String name)
Helper method that checks and waits until the completion of an alter command. 
 | 
ListTabletServersResponse | 
KuduClient.listTabletServers()
Get the list of running tablet servers. 
 | 
RowResultIterator | 
KuduScanner.nextRows()
Scans a number of rows. 
 | 
KuduTable | 
KuduClient.openTable(String name)
Open the table with the given name. 
 | 
void | 
KuduClient.shutdown()
Performs a graceful shutdown of this instance. 
 | 
boolean | 
KuduClient.tableExists(String name)
Test if a table exists. 
 | 
| 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. | 
Copyright © 2017 The Apache Software Foundation. All rights reserved.