| Package | Description | 
|---|---|
| org.apache.kudu.client | |
| org.apache.kudu.flume.sink | |
| org.apache.kudu.mapreduce | 
| Modifier and Type | Class and Description | 
|---|---|
| class  | DeleteClass of Operation for whole row removals. | 
| class  | InsertRepresents a single row insert. | 
| class  | UpdateOperation to update columns on an existing row. | 
| class  | UpsertRepresents a single row upsert. | 
| Modifier and Type | Method and Description | 
|---|---|
| Operation | PleaseThrottleException. getFailedRpc()The RPC that was made to fail with this exception. | 
| Operation | RowError. getOperation()Get the Operation that failed. | 
| Modifier and Type | Method and Description | 
|---|---|
| OperationResponse | KuduSession. apply(Operation operation)Apply a given  Operationto Kudu as part of this session. | 
| com.stumbleupon.async.Deferred<OperationResponse> | AsyncKuduSession. apply(Operation operation)Apply the given operation. | 
| Modifier and Type | Method and Description | 
|---|---|
| List<Operation> | AvroKuduOperationsProducer. getOperations(org.apache.flume.Event event) | 
| List<Operation> | RegexpKuduOperationsProducer. getOperations(org.apache.flume.Event event) | 
| List<Operation> | SimpleKeyedKuduOperationsProducer. getOperations(org.apache.flume.Event event) | 
| List<Operation> | KuduOperationsProducer. getOperations(org.apache.flume.Event event)Returns the operations that should be written to Kudu as a result of this event. | 
| List<Operation> | SimpleKuduOperationsProducer. getOperations(org.apache.flume.Event event) | 
| Modifier and Type | Method and Description | 
|---|---|
| org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.NullWritable,Operation> | KuduTableOutputFormat. getRecordWriter(org.apache.hadoop.mapreduce.TaskAttemptContext taskAttemptContext) | 
Copyright © 2018 The Apache Software Foundation. All rights reserved.