Get the {@link TableInfo} for this table. <p>Note: the table info of this {@link Table} is set during the creation of this {@link Table} and will not

Read the given byte buffer from its current position to its limit into a byte array. @param buffer The buffer to read from

Returns the field value at the given position. <p>Note: The returned value is in internal data structure. See {@link InternalRow} for more informatio

Removes the entry with the specified key. @param key the key for the entry to be removed from this map. @return the previous value for the key, or {@

Get the row type of the schema id. The returned row type is projected if the record batch is a projected {@link LogRecordBatch}. @param schemaId The

Parses the given string as as MemorySize. @param text The string to parse @return The parsed MemorySize @throws IllegalArgumentException Thrown, if t

Returns a binary string that is a substring of this binary string. The substring begins at the specified {@code beginIndex} and extends to the charact

Creates an instance of {@link Decimal} from an unscaled long value and the given precision and scale.

Data type of a boolean with a (possibly) three-valued logic of {@code TRUE, FALSE, UNKNOWN}. @see BooleanType

Returns the corresponding Path to the FileStatus. @return the corresponding Path to the FileStatus

The node id of this node. Note: coordinator server may have conflict node id with tablet server.

Inserts a record into Fluss table if it does not already exist, or updates it if it does. @param record the record to upsert. @return A {@link Comple

Returns the root of this type. It is an essential description without additional parameters.

Performs this operation on the given arguments. @param s first argument @param t second argument @param u third argument @param v fourth argument

Checks the given boolean condition, and throws an {@code IllegalStateException} if the condition is not met (evaluates to {@code false}). @param cond

Gets a result. @return a result @throws E if unable to supply a result

@return The name of this goal. Name of a goal provides an identification for the goal in human-readable format.

Registers a new {@link Gauge} with Fluss. @param name name of the gauge @param gauge gauge to register @param <T> return type of the gauge @return th

Creates a new RPC server that can bind to the given address and port and uses the given {@link RpcGatewayService} to handle incoming requests. @param

Data type of an 8-byte double precision floating point number. @see DoubleType

Data type of a timestamp WITHOUT time zone {@code TIMESTAMP} with 6 digits of fractional seconds by default. <p>An instance consists of {@code year-m

Copy the bytes of the row to the destination memory, beginning at the given offset. @return The copied row.

Data type of a sequence of fields. A field consists of a field name, field type, and an optional description. The most specific type of a row of a tab

Returns whether a value of this type can be {@code null}.

Finally, complete write to set real size to row.

Poll log data from tablet server. <p>On each poll, scanner will try to use the last scanned offset as the starting offset and fetch sequentially. The

Create a new {@link AppendWriter} to write data to a Log Table using InternalRow.

Tests if this BinaryString starts with the specified prefix. @param prefix the prefix. @return {@code true} if the bytes represented by the argument

Alter a table with the given {@code tableChanges}. <p>The following exceptions can be anticipated when calling {@code get()} on returned future. <ul

Returns the number of elements in this array.

Complete the batch exceptionally. The provided exception will be used for each record future contained in the batch.

Synchronously obtains the {@link Schema} associated with the given {@code schemaId}. <p>This method may block while fetching or deserializing the sch

The size of these records in bytes. @return The size in bytes of the records

Defines that the value of the option should be of {@link String} type.

Flush data written that have not yet been sent to the server, forcing the client to send the requests to server and blocks on the completion of the re

Get zookeeper client to store authorization information.

Put the KvRecordBatch into the kv storage with default DEFAULT mode. <p>This is a convenience method that calls {@link #putAsLeader(KvRecordBatch, in

Data type of an array of elements with same subtype. <p>Compared to the SQL standard, the maximum cardinality of an array cannot be specified but is

Creates a new {@link Upsert} to build a {@link UpsertWriter} to upsert and delete data to this table (requires to be a Primary Key Table).

Shutdown the timer service. leaving pending tasks un-executed.

Starts the RPC server by binding to the configured bind address and port (blocking).

Creates a ConfigOption without a default value. @return The config option without a default value.

Data type of a decimal number with fixed precision and scale {@code DECIMAL(p, s)} where {@code p} is the number of digits in a number (=precision) an

Data type of a 1-byte signed integer with values from -128 to 127. @see TinyIntType

Check if exists. @param f source file

Defines that the value of the option should be of {@link Integer} type.

Converts this {@link Decimal} into an instance of {@link BigDecimal}.

Flush the written key-value pair.

Returns the number of milliseconds since {@code 1970-01-01 00:00:00}.

Returns the boolean value at the given position.

Run a single iteration of sending.

Creates a new {@link Builder} for {@link FlussClusterExtension}.

Define which columns this table is partitioned by.

Get the log record's {@link ChangeType}. @return the record's {@link ChangeType}.

Advances the time by the given duration. Time can also move backwards by supplying a negative value. This method performs no overflow check.

Data type of a 4-byte single precision floating point number. @see FloatType

Creates a new {@link Connection} to the Fluss cluster. The given configuration at least needs to contain "bootstrap.servers" to discover the Fluss clu

Data type of a timestamp WITH time zone {@code TIMESTAMP WITH TIME ZONE} with 6 digits of fractional seconds by default. <p>An instance consists of {