Returns the current dirty state (i.e reflecting in-progress mutations). Should only be called by a thread who previously called StartMutation().

Starts this Kudu cluster. @throws IOException if something went wrong in transit

Return the projection of this schema which contains only the key columns. TODO(todd): this should take a Schema* out-parameter to avoid an extra copy

Executed after the op has been applied and the Raft commit message has been appended to the log (though it might not be durable yet), or if the op was

Add binary data with the specified value. Note that the provided value must not be mutated after this. @param columnIndex the column's index in the sc

Adds a new flag to be passed to the Master daemons on start. @return this instance

@throws IllegalArgumentException if the column is null

Counts the partitions touched by a scan with optional primary key bounds. The table is assumed to have three INT8 columns as the primary key. @param

Converts a number of days since the Unix epoch to a {@link java.sql.Date}. @param days the number of days since the Unix epoch @return the correspond

@return the end partition key

Return the precision;

Sets the read mode, the default is to read the latest values. @param readMode a read mode for the scanner @return this instance

Returns the request PB associated with this op. May be NULL if the op's state has been reset.

Wrap an existing array with a vector. The array should not be modified after this call. @param data the initial data for the vector @return a vector w

Returns true if the given transaction should be considered committed in this snapshot. Calls to this should always return the same result assuming: -

Wait until the function has completed, and return the Status returned by the function.

Add the provided trace to this RPC's collection of traces. If this RPC has a parent RPC, it will also receive that trace. If this RPC has reached the

Removes all elements from the vector. No reallocation will be performed.

Creates a new vector. @return the new vector.

Returns the column index given the column ID. If no such column exists, returns kColumnNotFound.

Similar to KuduOnceDynamic, kMemOrderAcquire here and kMemOrderRelease in Init(), taken together, mean that threads can safely synchronize on ini_succ

Set the specified column to null @param columnIndex the column's index in the schema @throws IllegalArgumentException if the column doesn't exist or c

Automatically detach this gauge when the given 'detacher' destructs. After detaching, the metric will return 'value' in perpetuity.

Alias for consistency with Next64

Write 'size' bytes of data to a file, with a simple pattern stored in it.

Adds a predicate to the scan. @param predicate predicate to add @return this instance

Add a range partition split. The split row must fall in a range partition, and causes the range partition to split into two contiguous range partition

Return the number of bytes needed to represent a single row of this schema, without accounting for the null bitmap if the Schema contains nullable val

Return the allocated capacity of this string.

Sets the default value that will be read from the column. Null by default. @param defaultValue a Java object representation of the default value that'

Get the count of columns that are part of the primary key. @return count of primary key columns.

Increments the column at the given index, returning {@code false} if the value is already the maximum. @param index the column index to increment @re