org.apache.kudu.client

Class Operation

java.lang.Object

org.apache.kudu.client.KuduRpc<OperationResponse>

org.apache.kudu.client.Operation

Direct Known Subclasses:

Delete, DeleteIgnore, Insert, InsertIgnore, Update, UpdateIgnore, Upsert, UpsertIgnore

@InterfaceAudience.Public
 @InterfaceStability.Evolving
public abstract class Operation
extends org.apache.kudu.client.KuduRpc<OperationResponse>

Base class for the RPCs that related to WriteRequestPB. It contains almost all the logic and knows how to serialize its child classes. TODO(todd): this should not extend KuduRpc. Rather, we should make single-operation writes just use a Batch instance with a single operation in it.

Field Summary

Fields inherited from class org.apache.kudu.client.KuduRpc

MASTER_SERVICE_NAME, TABLET_SERVER_SERVICE_NAME, TXN_MANAGER_SERVICE_NAME

Method Summary

Modifier and Type	Method and Description
PartialRow	getRow() Get the underlying row to modify.
byte[]	partitionKey() Returns the partition key this RPC is for, or null if the RPC is not tablet specific.
void	setRow(PartialRow row) Set the underlying row.

Methods inherited from class org.apache.kudu.client.KuduRpc

getExternalConsistencyMode, getTable, setExternalConsistencyMode, setPropagatedTimestamp, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Method Detail

partitionKey

public byte[] partitionKey()

Description copied from class: org.apache.kudu.client.KuduRpc

Returns the partition key this RPC is for, or null if the RPC is not tablet specific.

DO NOT MODIFY THE CONTENTS OF THE RETURNED ARRAY.

Overrides:

partitionKey in class org.apache.kudu.client.KuduRpc<OperationResponse>

getRow

public PartialRow getRow()

Get the underlying row to modify.

Returns:

a partial row that will be sent with this Operation

setRow

public void setRow(PartialRow row)

Set the underlying row. Note: The schema of the underlying row and the table must be equal by reference. To ensure they are equal, create the partial row from the table's schema.

   KuduTable table = client.openTable("my-table");
   PartialRow row = table.getSchema().newPartialRow();
   ...
   Operation op = table.newInsert();
   op.setRow(row);
 

Parameters:

row - the row to set