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 KuduClient s created from within tasks of that job can
authenticate to Kudu. |
Copyright © 2017 The Apache Software Foundation. All rights reserved.