Safely parses the specified string as a long and returns the value. If a NumberFormatException occurs while parsing the long, an error is logged and -

Reads and returns one input byte. The byte is treated as a signed value in the range {@code -128} through {@code 127}, inclusive. This method is suita

Return a slice of records from this instance, which is a view into this set starting from the given position and with the given size limit. <p>If the

Start a new tablet server.

try to append one write record to the record batch. @param writeRecord the record to write @param callback the callback to send back to writer @retur

Atomically stores a new producer offset snapshot. <p>This method first writes offset files to remote storage, then attempts to atomically create the

Create a new RPC client that can be used to send requests to the {@link RpcServer}. @param conf The configuration to use. @param clientMetricGroup Th

Drop the database with the given name asynchronously. <p>The following exceptions can be anticipated when calling {@code get()} on returned future.

Return an exception if the ACL delete was not successful or null if it was.

Returns the column ID of the auto-increment column that associated with this auto-increment ID range.

Returns the value associated with the given config option as an integer. @param configOption The configuration option @return the (default) value ass

Returns the current count of open leases.

Gets the URI that represents the local file system. That URI is {@code "file:/"} on Windows platforms and {@code "file:///"} on other UNIX family plat

Returns the value associated with the given config option as a string. @param configOption The configuration option @return the (default) value assoc

Hash unsafe bytes, length must be aligned to 4 bytes. @param base base unsafe object @param offset offset for unsafe object @param lengthInBytes leng

Check whether the checksum of this batch is correct. @return true If so, false otherwise

Initialization method for the schema. It is called before the actual working methods {@link #serialize} and thus suitable for one time setup work. <p

Put kv records to leader replicas of the buckets, the kv data will write to kv tablet and the response callback need to wait for the cdc log to be rep

Get a list of nodes whose buckets are ready to be sent. <p>Also return the flag for whether there are any unknown leaders for the accumulated bucket

Roll the local log over to a new active segment starting with the expectedNextOffset (when provided), or localLog.logEndOffset otherwise. This will tr

Append the given messages starting with the given offset. Add an entry to the index if needed. <p>It is assumed this method is being called from with

Determines recovery strategy and returns filtered recovery offsets.

The {@link LogRecordBatch batch} of {@link LogRecord records} is converted to a {@link List list} of {@link ScanRecord scan records} and returned. @p

Returns a map of all variables and their associated value, for example {@code {"table"="table-1", "bucket_id"="1"}}. @return map of all variables and

Returns metadata describing the latest known schema.

Get the number of buckets of the table.

Extracts the database name and table name from the given zookeeper path. If the given path is not a valid {@link TableZNode} path, returns null.

Returns the <i>precision</i> of this {@link Decimal}. <p>The precision is the number of digits in the unscaled value.

A shortcut to set error code and nullable error message.

Subscribe to the given table bucket in given offset dynamically. If the table bucket is already subscribed, the offset will be updated. <p>Please use

Check if the operation can be completed, if not watch it based on the given watch keys. <p>Note that a delayed operation can be watched on multiple k

Wait until the given condition is met or timeout. <p>Note: use {@code #waitUntil(ThrowingSupplier, Duration, String)} if waiting test to reach a cond

Return the total size of watch lists the manager contains. Since an operation may be watched on multiple lists, and some of its watched entries may st

Creates a new config option, using this option's key and default value, and adding the given deprecated keys. <p>When obtaining a value from the conf

Write data to multiple buckets in a single commit, creating one snapshot. @param fileStoreTable the FileStoreTable instance @param bucketRows map of

Creates a MAX aggregation function that selects the maximum value. <p>Supported data types: CHAR, STRING, TINYINT, SMALLINT, INT, BIGINT, FLOAT, DOUB