Checks if a String is not null and not empty.

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

Returns the comparator that defines the sort order of the records. @return a non-null comparator defining the sort order of the records

Deserialize the message from the given {@link ByteBuf}. The deserialization happens lazily (i.e. zero-copy) only for {@code "[optional|required] bytes

Parses an XML document from an input stream using a document handler. @param handler the handler for the XML document @param inputStream an input str

Append log records to leader replicas of the buckets, and wait for them to be replicated to other replicas. <p>The callback function will be triggere

Get batch base sequence for this log record batch. the base sequence is the first sequence number of this batch, it's used to protect the idempotence

Checks if the specified string is empty or null and if so, returns null. Otherwise simply returns the string. @param s The string to check. @return N

Closes the scanner and should release all resources.

Creates an instance of {@link TimestampLtz} from an instance of {@link Instant}. @param instant an instance of {@link Instant}

Create statistics for the currently recorded elements. @return Statistics about the currently recorded elements

Check if the table has primary key or not.

Releases any resources held by this {@code SchemaGetter}. <p>After calling this method, the instance may no longer be usable. Implementations should

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

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

Encode the key of given row to byte array.

Gets all the child nodes at a given zk node path. @param path the path to list children @return list of child node names

Retrieve the configuration used to create this connection.

Get number of events marked on the meter. @return number of events marked on the meter

Reads a value using the metadata included in {@link ConfigOption}. In contrast to {@link #get(ConfigOption)} returns {@link Optional#empty()} if value

Make a {@link MemoryLogRecords} instance from the given {@link BytesView}. <p>Note: this is a heavy operation involving copy bytes, only used for tes

Get the iterable of {@link KvRecord} in this batch. @param readContext The context to read records from the record batch @return The iterable of {@li

Writes a <code>boolean</code> value to this output stream. If the argument <code>v</code> is <code>true</code>, the value <code>(byte)1</code> is writ

Persist the snapshot handle to coordination system(e.g. Zookeeper, Kubernetes, etc.). @param tableBucket the table bucket the snapshot belongs to @pa

Creates assertions for {@link InternalRow}.

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

Sets custom properties on the table. <p>Custom properties are not understood by Fluss, but are stored as part of the table's metadata. This provides

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

Creates an instance of {@link TimestampNtz} for now.

Produce log data to the specified table bucket. @return the produce response.

Register table to ZK metadata.

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

Converts this {@link TimestampNtz} object to a {@link LocalDateTime}.

Wait for the presence of an optional value. @param supplier The function defining the optional value @param timeout Maximum time to wait @param error

The active segment that is currently taking appends.

Returns the custom properties of the table. <p>Custom properties are not understood by Fluss, but are stored as part of the table's metadata. This pr

Returns the <i>scale</i> of this {@link Decimal}.

Returns a long describing the <i>unscaled value</i> of this {@link Decimal}. @throws ArithmeticException if this {@link Decimal} does not exactly fit

Get the base log offset contained in this record batch. @return The base offset of this record batch (which may or may not be the offset of the first