| Package | Description |
|---|---|
| org.apache.kudu.client | |
| org.apache.kudu.flume.sink | |
| org.apache.kudu.mapreduce |
| Modifier and Type | Method and Description |
|---|---|
KuduTable |
KuduClient.createTable(String name,
Schema schema,
CreateTableOptions builder)
Create a table on the cluster with the specified name, schema, and table configurations.
|
KuduTable |
KuduClient.openTable(String name)
Open the table with the given name.
|
| Modifier and Type | Method and Description |
|---|---|
com.stumbleupon.async.Deferred<KuduTable> |
AsyncKuduClient.createTable(String name,
Schema schema,
CreateTableOptions builder)
Create a table on the cluster with the specified name, schema, and table configurations.
|
com.stumbleupon.async.Deferred<KuduTable> |
AsyncKuduClient.openTable(String name)
Open the table with the given name.
|
| Modifier and Type | Method and Description |
|---|---|
KuduScanner.KuduScannerBuilder |
KuduClient.newScannerBuilder(KuduTable table)
Creates a new
KuduScanner.KuduScannerBuilder for a particular table. |
AsyncKuduScanner.AsyncKuduScannerBuilder |
AsyncKuduClient.newScannerBuilder(KuduTable table)
Creates a new
AsyncKuduScanner.AsyncKuduScannerBuilder for a particular table. |
KuduScanToken.KuduScanTokenBuilder |
KuduClient.newScanTokenBuilder(KuduTable table)
Creates a new
KuduScanToken.KuduScanTokenBuilder for a particular table. |
| Modifier and Type | Method and Description |
|---|---|
void |
AvroKuduOperationsProducer.initialize(KuduTable table) |
void |
RegexpKuduOperationsProducer.initialize(KuduTable table) |
void |
SimpleKeyedKuduOperationsProducer.initialize(KuduTable table) |
void |
KuduOperationsProducer.initialize(KuduTable table)
Initializes the operations producer.
|
void |
SimpleKuduOperationsProducer.initialize(KuduTable table) |
| Modifier and Type | Method and Description |
|---|---|
static KuduTable |
KuduTableOutputFormat.getKuduTable(String multitonKey) |
static KuduTable |
KuduTableMapReduceUtil.getTableFromContext(org.apache.hadoop.mapreduce.TaskInputOutputContext context)
Use this method when setting up a task to get access to the KuduTable in order to create
Inserts, Updates, and Deletes.
|
Copyright © 2018 The Apache Software Foundation. All rights reserved.