Reads a value using the metadata included in {@link ConfigOption}. Returns the {@link ConfigOption#defaultValue()} if value key not present in the con

Performs the asynchronous part of one snapshot and returns the snapshot result. @param snapshotCloseableRegistry A registry for io tasks to close on

Returns the number of key-value mappings in this map.

Put a key-value pair.

Add a new task to this executor. It will be executed after the task's delay (beginning from the time of submission). @param timerTask the task to add

Defines that the option's type should be a list of previously defined atomic type.

Declares a column that is appended to this schema. <p>Columns are regular columns known from databases. They define the names, the types, and the ord

Creates a key encoder based on the datalake format. <p>Internal use only. This method should be private, but Java 8 doesn't support private static me

Gets the key for this entry.

Data type of a variable-length character string. @see StringType

@param entry entry to be converted into string. @return String representation of the given entry.

Data type of a 4-byte signed integer with values from -2,147,483,648 to 2,147,483,647. @see IntType

Returns the class associated with the given key as a string. @param <T> The type of the class to return. @param key The key pointing to the associate

Puts the given entry into the map. @param key the key of the entry. @param value the value of the entry. @return the previous value for this key or {

Indicates whether some other object is "equal to" this one. Two {@code RowWithOp} objects are considered equal if their internal rows and operation ty

Returns the integer value at the given position.

Returns the binary value at the given position.

Builder for configuring and creating instances of {@link Schema}.

A table change to add the column at last. <p>It is equal to the following statement: <pre> ALTER TABLE &lt;table_name&gt; ADD &lt;column_definiti

Create a new table asynchronously. <p>The following exceptions can be anticipated when calling {@code get()} on returned future. <ul> <li>{@link D

Sets the field value at the given position. <p>Note: The given field value must be an internal data structures. Otherwise, the {@link GenericRow} is

Ensures that the given object reference is not null. Upon violation, a {@code NullPointerException} with no message is thrown. @param reference The o

Calculates and returns the measured value. @return calculated value

Adds the given key/value pair to the configuration object. @param key the key of the key/value pair to be added @param value the value of the key/val

Returns the string value at the given position.

Define the schema of the {@link TableDescriptor}.

Get the key of the kv record. @return the key of the kv record.

Collect all rows from the iterator and close it. @return return a list of rows

Data type of an 8-byte signed integer with values from -9,223,372,036,854,775,808 to 9,223,372,036,854,775,807. @see BigIntType

Creates a builder for building table descriptor.

Retrieve a new Table client to operate data in table.

Returns the default value, or null, if there is no default value. @return The default value, or null.

Close the connection and release all resources.

Returns all the log segments in base offset ascending order.

Creates an instance of {@link TimestampLtz} from milliseconds. <p>The nanos-of-millisecond field will be set to zero. @param milliseconds the number

Creates a new config option, using this option's key and default value, and adding the given description. The given description is used when generatio

Sets table property on the table. <p>Table properties are controlled by Fluss and will change the behavior of the table.

Test based on the specific input row. @return return true when hit, false when not hit.

Declares a primary key constraint for a set of given columns. Primary key uniquely identify a row in a table. Neither of columns in a primary can be n

A simplified formatting method. Similar to {@link String#format(String, Object...)}, but with lower overhead (only String parameters, no locale, no fo

Creates an instance of {@link TimestampNtz} from milliseconds. <p>The nanos-of-millisecond field will be set to zero. @param milliseconds the number

Apply the supplied function to each of tasks in this list.

Returns the keys of all key/value pairs stored inside this configuration object. @return the keys of all key/value pairs stored inside this configura

Define the distribution of the table. If the bucket keys are defined, it implies a hash distribution on the bucket keys. Otherwise, it is a random dis

@param value string representation of an entry. @return entry converted from the given string representation if possible. {@link Optional#empty()}

Get the table bucket of the event. @return the table bucket of the event.

Creates an instance of {@link GenericRow} with given field values. <p>Note: All fields of the row must be internal data structures.

hash segments to int. @param segments Source segments. @param offset Source segments offset. @param numBytes the number bytes to hash.

Waits until {@link OneShotLatch#trigger()} is called. Once {@code trigger()} has been called this call will always return immediately. @throws Interr

Get the row of the kv record. If the row is null, it means the record is a delete record. @return the row of the kv record, which is BinaryRow.

Returns true if and only if this BinaryString contains the specified sequence of bytes values. @param s the sequence to search for @return true if th

Execute the given assertion. If it throws an assert error, retry. Repeat until no error is thrown or the time limit elapses. <p>Note: use {@code retr

Returns true if the element is null at the given position.

Indicates whether or not this map contains a value for the specified key.

Creates a new tuple and assigns the given values to the tuple's fields. This is more convenient than using the constructor, because the compiler can i

Creates an instance of {@link Decimal} from a {@link BigDecimal} and the given precision and scale. <p>The returned decimal value may be rounded to h

Returns the long value at the given position.

Finally, complete write to set real size to binary.

Append a record into a Log Table. @param record the record to append. @return A {@link CompletableFuture} that always returns append result when comp

Returns the number of fields in this row. <p>The number does not include {@link ChangeType}. It is kept separately.

Writes to the output stream all the bytes in array <code>b</code>. If <code>b</code> is <code>null</code>, a <code>NullPointerException</code> is thro

Create a KvRecord with give key and value. If the given value is null, it means to create a kv record for deletion.

@param offset the segment to be checked @return true if a segment exists at the provided offset, false otherwise.

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

Returns the final component of this path, i.e., everything that follows the last separator. @return the final component of the path

Remove the snapshot handle for the given snapshot id of the given table bucket. @param tableBucket the table bucket the snapshot belongs to @param sn

Check whether this node is empty, which may be the case if noNode() is used as a placeholder in a response payload with an error. @return true if it