Adds a bytes section from a byte array.

Get all RocksDB statistics from bucket metric groups for table-level and server-level aggregation. <p>This method dynamically collects statistics fro

Allocate bytes that is only for temporary usage, it should not be stored in somewhere else. Use a {@link ThreadLocal} to reuse bytes to avoid overhead

Add a record to the accumulator, return to append result. <p>The append result will contain the future metadata, and flag for whether the appended ba

Get a FlussSourceBuilder to build a {@link FlussSource}. @return a Fluss source builder.

Compares two objects based on their data type. @param x the first object @param y the second object @param type the data type root @return a negative

Creates a indexed WriteRecord as the DATA1_PHYSICAL_TABLE_PATH is registered as a INDEXED format , see {@link #updateCluster(List)}.

Creates a sink table with specified columns. @param tableName the name of the table @param columns the column definitions (e.g., "a1 int, c1 bigint,

Drop a partition from a partitioned table. <p>The following exceptions can be anticipated when calling {@code get()} on returned future. <ul> <li>

Equals two memory segment regions. @param seg2 Segment to equal this segment with @param offset1 Offset of this segment to start equaling @param offs

Creates an instance of {@link TimestampLtz} from micros.

Returns a reference to the {@link FileSystem} instance for accessing the file system identified by the given {@link URI}. @param uri the {@link URI}

Initialize the authenticator.

Get the last log offset in this record batch (inclusive). Just like {@link #baseLogOffset()}, the last offset always reflects the offset of the last r

List all tables in the given database in fluss cluster asynchronously. <p>The following exceptions can be anticipated when calling {@code get()} on r

Parses the given string as bytes. The supported expressions are listed under {@link MemorySize}. @param text The string to parse @return The parsed s

Processes an input element by passing it through to the output unchanged. <p>This operator does not modify, filter, or buffer any input elements. All

Registers a new producer offset snapshot with atomic "check and register" semantics. <p>This method uses ZooKeeper's version mechanism to handle conc

Schedule a task. @param name The name of this task @param task The task to run @param delayMs The number of milliseconds to wait before the first exe

Get the size in bytes of this batch, including the size of the record and the batch overhead. @return The size in bytes of this batch

Stop a tablet server.

Returns the table path. @return the table path

Convert Flink's RowType to Fluss' RowType.

Wait until all authorization are synchronized to all tablet servers. @param aclBindings aclBindings to be synchronized. @param exist whether aclBindi

Advance the internal clock, executing any tasks whose expiration has been reached within the duration of the passed wait time. @param waitMs the time

Creates a lake source instance for reading lakehouse data from the specified table path. The lake source provides capabilities for split planning and

Perform a url decode on the given value if specified. Return value by default;

Delete producer offset snapshot. <p>This method deletes the registered offset snapshot for a producer. This is typically called after the first check

This method must have the same result with JDK's String.getBytes.

Encode the {@code row} with a {@code schemaId} to a byte array value to be expected persisted to kv store. @param schemaId the schema id of the row @

Generates the challenge based on the client's token, then sends it back to the client. This method sets the server authentication status as complete i

Fetch log data from the specified table bucket. The request can send by the client scanner or other tablet server. @return the fetch response.

Gets the file system that stores the file state. @return The file system that stores the file state. @throws IOException Thrown if the file system ca

Returns the primary key indexes, if any, otherwise returns an empty array.

Get producer offset snapshot. <p>This method retrieves the registered offset snapshot for a producer. Returns null if no snapshot exists for the give

Gets the size in bytes of this binary data.

Check if the table is partitioned or not. @return true if the table is partitioned; otherwise, false

Get server and table metadata from server. @param request Get metadata request @return a future returns metadata

Return the number of delayed operations in the expiry queue.

Utility method to create an ordered {@link LinkedHashSet} containing the specified Java type classes. <p>The returned set maintains the insertion ord

Writes the given int value (32bit, 4 bytes) to the given position in little endian byte order. This method's speed depends on the system's native byte

Writes the given long value (64bit, 8 bytes) to the given position in little endian byte order. This method's speed depends on the system's native byt