Append this message set to the active segment of the local log, assigning offsets and Bucket Leader Epochs.

Creates a new {@link Scan} for this table to configure and create a scanner to scan data for this table. The scanner can be a log scanner to continuou

Increment the current count by 1.

Returns a string whose value is this string, with any leading and trailing whitespace removed. @return A string whose value is this string, with any

Returns the array value at the given position.

Read a {@link LakeSplit} into a closeable iterator. @return the closeable iterator of records @throws IOException if an I/O error occurs

Returns the double value at the given position.

Closes the given AutoCloseable. <p><b>Important:</b> This method is expected to never throw an exception.

Returns the decimal value at the given position. <p>The precision and scale are required to determine whether the decimal value was stored in a compa

Gets the start offset of this binary data in the {@link MemorySegment}s.

Lookups certain row from the given lookup key. <p>The lookup key must be a primary key if the lookuper is a Primary Key Lookuper (created by {@code t

Creates a new MetricGroup and adds it to this groups sub-groups. @param name name of the group @return the created group

Write the row's field in given pos with given value. @param pos the pos of the field to write. @param value the value of the field to write.

Sets the number of tablet servers.

Data type of a 2-byte signed integer with values from -32,768 to 32,767. @see SmallIntType

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

Starts building a new {@link ConfigOption}. @param key The key for the config option. @return The builder for the config option with the given key.

Returns the current time in milliseconds. <p>This refers to real world wall clock time, and it is typically derived from a system clock. It is subjec

Define the comment for this table.

Returns a {@link TableConfig} helper instance to easily get "table. " related configs from {@link #getProperties()}.

Parse the given string to a java {@link Duration}. The string is in format "{length value}{time unit label}", e.g. "123ms", "321 s". <p>Supported tim

Gets the total serialized byte array size of the message.

Creates a SUM aggregation function that computes the sum of numeric values. <p>Supported data types: TINYINT, SMALLINT, INT, BIGINT, FLOAT, DOUBLE, D

Tests if this BinaryString ends with the specified suffix. @param suffix the suffix. @return {@code true} if the bytes represented by the argument is

Reads the byte at the given position. @param index The position from which the byte will be read @return The byte at the given position. @throws Inde

Data type of a fixed-length character string {@code CHAR(n)} where {@code n} is the number of code points. {@code n} must have a value between 1 and {

Return the id of the partition the row belongs to. It'll try to update the metadata if the partition doesn't exist. If the partition doesn't exist yet

Get the partition keys of the table. This will be an empty set if the table is not partitioned. @return partition keys of the table

Writes the bytes data from this send to the provided channel. @param out The output channel to write out @throws IOException If the write fails

Data type of a date consisting of {@code year-month-day} with values ranging from {@code 0000-01-01} to {@code 9999-12-31}. <p>Compared to the SQL st

Data type of a time WITHOUT time zone {@code TIME} with no fractional seconds by default. <p>An instance consists of {@code hour:minute:second} with

Registers a new {@link Meter} with Fluss. @param name name of the meter @param meter meter to register @param <M> meter type @return the registered m

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

Returns the short value at the given position.

Creates a new {@link Append} to build a {@link AppendWriter} to append data to this table (requires to be a Log Table).

Sets the base cluster configuration for TabletServer and CoordinatorServer.

Data type of a variable-length binary string (=a sequence of bytes). @see BytesType

Closes this instance.

Get the bucket LeaderAndIsr in ZK.

Creates an instance of {@link GenericArray} with given field values.

Creates a {@link LogScanner} to continuously read log data for this scan. <p>Note: this API doesn't support pre-configured with {@link #limit(int)}.

Creates a new configuration that is initialized with the options of the given map.

Retrieve a new Admin client to administer a Fluss cluster.

Helper method to get the class loader used to load the plugin. This may be needed for some plugins that use dynamic class loading afterwards the plugi

Gets the scheme of the file system created by this plugin.

Get the size in bytes of this record. @return the size of the record in bytes

Returns the timestamp value at the given position. <p>The precision is required to determine whether the timestamp value was stored in a compact repr

Subscribe to the given table buckets from beginning dynamically. If the table bucket is already subscribed, the start offset will be updated. <p>It e

Returns the index within this string of the first occurrence of the specified substring, starting at the specified index. @param str the substring to

Returns the table bucket. @return the table bucket

Writes an <code>int</code> value, which is consisted of four bytes, to the output stream. The byte values to be written, in the little-endian order. T

Returns all relevant {@link Options} for parsing the command line arguments. @return Options to use for the parsing

Utility to create a {@link TableInfo} from a {@link TableDescriptor} and other metadata.