Applies this function to the given arguments. @param s the first function argument @param t the second function argument @return the function result

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

Commits the given committable object. @param committable the committable object @param snapshotProperties the properties that lake supported to store

Get the latest row count. Returns -1 if this table doesn't support row count.

Set the database for the sink.

Set the table name for the sink.

Wait until all the replicas are ready if we have multi replica for one table bucket.

Divide two integers and round up to the nearest integer value.

Creates multiple ACL entries in a single atomic operation. <p>1. Validates the user has 'alter' permission on the resource. 2. Creates the ACL entrie

Delete a certain record from the Fluss table. The input must contain the primary key fields. @param record the record to delete. @return A {@link Com

Get the coordinator server node. @return the coordinator server node

Returns the map value at the given position.

Point to the bytes of the row. @param segment The memory segment. @param offset The offset in the memory segment. @param sizeInBytes The size of the

Reads eight input bytes and returns a {@code long} value. This method is suitable for reading bytes written by the {@link OutputView#writeLong(long)}.

The work method. @throws E Exceptions may be thrown.

set long from segments. @param segments target segments. @param offset value offset.

Update the histogram with the given value. @param value Value to update the histogram with

Writes a <code>long</code> value, which is consisted of eight bytes, to the output stream. The byte values to be written, in the little-endian order.

Serialize the given value to a byte array with the specified json serializer. It potentially reuses byte array for writing efficiently. The implementa

Creates assertions for {@link LogRecords}.

Get the record batches. Note that the signature allows subclasses to return a more specific batch type. @return An iterator over the record batches o

Returns a list of all the completed snapshots in this store. Note this doesn't include the snapshots that are still in use but have been moved out of

get long from segments. @param segments target segments. @param offset value offset.

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

Get the position to place the column at the first.

Make the given file and all non-existent parents into directories. Has the semantics of Unix 'mkdir -p'. Existence of the directory hierarchy is not a

Converts all of the characters in this {@code BinaryString} to lower case. @return the {@code BinaryString}, converted to lowercase.

Data type of an associative array that maps keys (including {@code NULL}) to values (including {@code NULL}). A map cannot contain duplicate keys; eac

Get all remote log segment metadata.

Creates an accessor for getting elements in an internal row data structure at the given position. @param fieldType the element type of the row @param

Fetch records from a replica. Currently, we will return the fetched records immediately. <p>The callback function will be triggered when required fet

Get the bucket keys of the table. This will be an empty set if the table is not bucketed.

Gets the error code of the message. @throws IllegalStateException if the error code is not set.

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

Plans and generates a list of readable data splits in parallel. @return the list of readable data splits @throws IOException if an I/O error occurs

Gets the value for this entry.

Returns an array view of the values contained in this map. <p>A key-value pair has the same index in the key array and value array.

Return a map from acl filters to futures which can be used to check the status of the deletions by each filter.

Copies the bytes of the row to the destination memory, beginning at the given offset. @param dst The memory into which the bytes will be copied. @par

The number of records for all buckets.

Returns the distribution of the table if the {@code DISTRIBUTED} clause is defined.

Returns the database name and table name of the table that represented by this table path. A table path is unique in a Fluss cluster and can be used t

Returns whether the decimal value is small enough to be stored in a long.

Create assertion for {@link java.util.concurrent.CompletableFuture}. @param actual the actual value. @param <T> the type of the value contained in th

Finish write the row, return the written row. @return the written row.

Gets the value in the map with the specified key. @param key the key whose associated value is to be returned. @return the value or {@code null} if t

Returns the schema ID of the table. The schema ID is a 0-based index that is incremented each time the table's schema is modified, such as when a new

Reset writer to prepare next write.

Start to write a new row.

Converts all of the characters in this {@code BinaryString} to upper case. @return the {@code BinaryString}, converted to uppercase.

read bit. @param segment target segment. @param baseOffset bits base offset. @param index bit index from base offset.

Creates an accessor for getting elements in an internal array data structure at the given position. @param fieldType the element type of the array

Adds a new exception as a {@link Throwable#addSuppressed(Throwable) suppressed exception} to a prior exception, or returns the new exception, if no pr

Create an empty {@link ProjectedRow} starting from a {@code projection} array. <p>The array represents the mapping of the fields of the original {@li

Gets the error message of the message. @throws IllegalStateException if the error message is not set.