| Package | Description |
|---|---|
| org.apache.kudu.client | |
| org.apache.kudu.flume.sink | |
| org.apache.kudu.mapreduce |
| Modifier and Type | Class and Description |
|---|---|
class |
Delete
Class of Operation for whole row removals.
|
class |
Insert
Represents a single row insert.
|
class |
Update
Operation to update columns on an existing row.
|
class |
Upsert
Represents 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)
Blocking call with a different behavior based on the flush mode.
|
com.stumbleupon.async.Deferred<OperationResponse> |
AsyncKuduSession.apply(Operation operation)
Apply the given operation.
|
| Modifier and Type | Method and Description |
|---|---|
List<Operation> |
KuduOperationsProducer.getOperations(org.apache.flume.Event event)
Returns the operations that should be written to Kudu as a result of this
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 © 2016 The Apache Software Foundation. All rights reserved.