Returns the byte value at the given position.

Returns the float value at the given position.

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

Create a row merger based on the given configuration. @param tableConf the table configuration @param kvFormat the kv format @param schemaGetter the

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

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

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

Returns the number of nanoseconds (the nanoseconds within the milliseconds). <p>The value range is from 0 to 999,999.

Please check the java doc of {@link #getRawValueFromOption(ConfigOption)}. If no keys are found in {@link Configuration}, default value of the given o

Returns the comment/description of the table.

Only get the inSync replicas which have been committed to ZK.

The offset of this record in the log. @return the offset

Reads four input bytes and returns an {@code int} value. This method is suitable for reading bytes written by the {@link OutputView#writeInt(int)}. @

Delete a key-value pair by the given key.

Returns the binary value at the given position with fixed length.

Returns a new scan from this that will read the given limited row number. @param rowNumber the limited row number to read

Writes the given byte into this buffer at the given position. @param index The index at which the byte will be written. @param b The byte value to be

Initializes the authorizer. This method should be called before any other methods are used. @throws Exception if an error occurs during initializatio

Returns the FileSystem that owns this Path. @return the FileSystem that owns this Path @throws IOException thrown if the file system could not be ret

Get the table path for this table id.

Creates a new {@link Lookup} for this table to configure and create a {@link Lookuper} to lookup data for this table by primary key or a prefix of pri

Configures this reporter. <p>If the reporter was instantiated generically and hence parameter-less, this method is the place where the reporter sets

@return Remote log start offset of this segment (inclusive).

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

Return a future which succeeds only if all the ACLs deletions succeed, and which contains all the deleted ACLs. Note that it if the filters don't matc

Get the coordinator epoch of the event. @return the coordinator epoch of the event.

Returns the parent of a path, i.e., everything that precedes the last separator or <code>null </code> if at root. @return the parent of a path or <co

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

Unpacks an {@link ExecutionException} and returns its cause. Otherwise the given Throwable is returned. @param throwable to unpack if it is an Execut

Data type of a fixed-length binary string (=a sequence of bytes) {@code BINARY(n)} where {@code n} is the number of bytes. {@code n} must have a value

Creates a {@link Lookuper} instance to lookup rows of a primary key table by the specified lookup columns. By default, the lookup columns are the prim

Returns the bucket this record was written to. @return the bucket, or null if not available

Creates a {@link BinaryString} instance from the given UTF-8 bytes.

Returns the unique identifier for the table within the cluster. <p>Each table is assigned a globally unique table ID when it is created. This ID is i

Returns the version of the serializer. @return the version of the serializer

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

Deserialize a byte array to a value with the specified json deserializer.

Converts this {@link TimestampLtz} object to a {@link Instant}.

Returns the bucket id for this data split. Any data split in lake must belong to a Fluss bucket. The bucket id is used to aggregate splits that in sam

Compare two cluster model stats and determine which stats is preferred. @param stats1 the first stats @param stats2 the second stats @return Positive

Create an empty cluster instance with no nodes and no table-buckets.

Convert a Fluss field object of {@link InternalRow} to the Flink's internal data structure object. @param flussField A single field of a {@link Inter

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

Gets an iterable to traverse over the primitive entries contained in this map. As an optimization, the {@link PrimitiveEntry}s returned by the {@link

Creates an instance of {@link TimestampNtz} from an instance of {@link LocalDateTime}. @param dateTime an instance of {@link LocalDateTime}

Gets the aggregation function for a specific column. @param columnName the column name @return the aggregation function, or empty if not configured

The error code for the exception.

Finally, complete write to set real size to binary.

Creates a source table with specified schema and options. @param tableName the name of the table @param columns column definitions (e.g., "a1 int, b1

Returns a new scan from this that will read the given data columns. @param projectedColumns the selected column indexes

Set the bootstrap server for the sink.

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