Assign a bucket according to the bucket key byte array. @param bucketKey the bucket key byte array @param numBuckets the number of buckets @return th

Check if some delayed operations can be completed with the given watch key, and if yes complete them. @return the number of completed operations duri

Copy segments to a new byte[]. @param segments Source segments. @param offset Source segments offset. @param numBytes the number bytes to copy.

Creates a proxy for the given gateway class. The proxy will forward all method calls to the remote gateway service.

Returns true if the request is failed.

Gets the number of Futures in the conjunction that are already complete. @return The number of Futures in the conjunction that are already complete

Get the log record's row. @return the log record's row

Creates a re-occurring task which obtains new tokens.

Wait until the default number of partitions is created. Return the map from partition id to partition name.

Writes to the output stream the eight low-order bits of the argument <code>v</code>. The 24 high-order bits of <code>v</code> are ignored. The byte wr

Compute the CRC32C (Castagnoli) of the segment of the byte array given by the specified size and offset. @param bytes The bytes to checksum @param of

Create an empty writer state. @return an empty writer state

Defines that the value of the option should be of {@link Enum} type. @param enumClass Concrete type of the expected enum.

Returns whether the error code is set.

List offset for the specified buckets. This operation enables to find the beginning offset, end offset as well as the offset matching a timestamp in b

Sets the context class loader to the given ClassLoader and returns a resource that sets it back to the current context ClassLoader when the resource i

Replaces the underlying {@link InternalRow} backing this {@link ProjectedRow}. <p>This method replaces the row data in place and does not return a ne

Take a snapshot at the current end offset if one does not already exist with syncing the change to the device.

Converts the path object to a {@link URI}. @return the {@link URI} object converted from the path object

Wait until the default number of partitions is created. Return the map from partition id to partition name.

Wait until all the table assignments buckets are ready for table.

Returns a new TableDescriptor instance that is a copy of this TableDescriptor with a new properties.

Creates a new table. @param request the request to create table.

Adopts all columns from the given list. <p>This method directly uses the columns as-is, preserving their existing column IDs and all nested field IDs

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

Returns the data class for the given {@link DataType}.

Return the data lake format of the table. It'll be the datalake format configured in Fluss whiling creating the table. Return empty if no datalake for

Gets the offset snapshot metadata for a producer.

Initializes the shared file system settings. <p>The given configuration is passed to each file system plugin to initialize the respective file system

Returns whether the timestamp data is small enough to be stored in a long of milliseconds.

Returns whether the timestamp data is small enough to be stored in a long of milliseconds.

Merge the old value with the new value. @param oldValue the old value, or null if this is a first insert (no existing row) @param newValue the new ro

Reads one input byte and returns {@code true} if that byte is nonzero, {@code false} if that byte is zero. This method is suitable for reading the byt

Get all remote log segments relevant to the input offset, which including these segments whose remote log start offset higher that or equal to this of

Get whether table exists asynchronously. @param tablePath The table path of the table.

Write rows to the table through Fluss API. <p>This method writes data through Fluss, which will then be synced to Paimon via tiering job. The data wi

Creates a LISTAGG aggregation function with default comma delimiter. <p>Concatenates multiple string values into a single string with a delimiter. <

Creates an accessor for setting the elements of a binary writer during runtime. @param elementType the element type @param rowFormat the binary row f

Get an {@link OffsetsInitializer} which initializes the offsets to the earliest available offsets of each bucket. @return an {@link OffsetsInitialize

Declares a column to be auto-incremented. With an auto-increment column in the table, whenever a new row is inserted into the table, the new row will

Equals two memory segments regions. @param segments1 Segments 1 @param offset1 Offset of segments1 to start equaling @param segments2 Segments 2 @par

Returns all column names. It does not distinguish between different kinds of columns.

Gets the kv format of the table.

Get the table assignment in ZK.

Is it just in first MemorySegment, we use quick way to do something.

Returns in iterator over all available implementations of the given service interface (SPI) in all the plugins known to this plugin manager instance.