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)
Apply a given
Operation to 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.