SecurityTokenReceiver for Azure Blob Storage using the ABFS (Azure Blob File System) driver. Registered for the {@code abfs://} scheme. <p>ABFS is th

Tests for {@link AbfsDelegationTokenReceiver}.

Tests that validate the behavior of the Azure File System Plugin.

FileSystem plugin for Azure Blob Storage using the ABFS (Azure Blob File System) driver. Registered for the {@code abfs://} scheme. <p>ABFS is the re

SecurityTokenReceiver for Azure Blob Storage using the ABFS driver with SSL/TLS encryption. Registered for the {@code abfss://} scheme. <p>This is th

Tests for {@link AbfssDelegationTokenReceiver}.

FileSystem plugin for Azure Blob Storage using the ABFS driver with SSL/TLS encryption. Registered for the {@code abfss://} scheme. <p>This is the se

{@link org.apache.flink.table.procedures.Procedure} to operate acl.

Abstract Authorizer class provides common functionality for authorizing operations on resources.

This is the abstract base class for registries that allow to register instances of {@link Closeable}, which are all closed if this registry is closed.

Tests for the {@link org.apache.fluss.utils.AbstractAutoCloseableRegistry}.

Use the special format to write data to a {@link MemorySegment} (its capacity grows automatically). <p>If write a format binary: 1. New a writer. 2.

An abstract class for goals.

The abstract index class which holds entry format agnostic methods.

Tests for {@link AbstractIndex}.

A base class that simplifies implementing an iterator. @param <T> The type of thing we are iterating over

An abstract lookup batch.

Abstract Class to represent a lookup operation.

Abstract lookuper implementation for common methods.

Abstract {@link MetricGroup} that contains key functionality for adding metrics and groups. <p><b>IMPORTANT IMPLEMENTATION NOTE</b> <p>This class us

Tests for the {@link AbstractMetricGroup}.

The base class for all output views that are backed by multiple memory pages. This base class contains all encoding methods to write data to a page an

Base class for Prometheus metric reporters. Contains common logic for metric registration and collector management.

Abstract base class to deduplicate logic for row-based log write batches backed by in-memory builders. Concrete subclasses only need to provide a row-

A base class for {@link AppendWriter} and {@link UpsertWriter} to write data to table.

Abstract metric the users in server and tracks the expiration.

An event designed to safely access the {@link CoordinatorContext}. Since {@link CoordinatorContext} is not thread-safe, directly accessing it in tests

Represents an Access Control List (ACL) entry defining permissions for a principal on a specific resource operation. <p>This class encapsulates the c

Represents a filter which matches access control entries. <p>The API for this class is still evolving and we may break compatibility in minor release

Handler for AccessControlList response XML documents. The document is parsed into an {@link AccessControlList} object available via the {@link #getAcc

Represents an Access Control List (ACL) binding that associates a resource with specific access control rules. <p>An {@code AclBinding} encapsulates

AclBindingDeleteResult represents the result of deleting a specific ACL binding that matched a delete filter.

A filter which can match AclBinding objects. @since 0.7

The znode for individual ACL change notifications. Each notification is stored as a sequential child node under the {@link AclChangesNode} with a pref

The znode for tracking ACL changes in the system. This znode serves as a root node for all ACL change notifications. The znode path is: <p>/fluss-acl

AclCreateResult represents the result of an ACL (Access Control List) creation operation. It encapsulates either a successful creation result containi

AclDeleteResult represents the result of an ACL (Access Control List) deletion operation. It encapsulates the results of matching ACL filters and any

The root znode for ACLs. This is the top-level node under which all resource-specific ACLs are stored. The znode path is: <p>/fluss-acls

A class to represent the result of acquire kv snapshot lease. It contains: <ul> <li>A map of unavailable snapshots. Such as the specify snapshotId

The action to operator.

Flags to indicate if an action is acceptable by the goal(s).

Flags to indicate the type of action.

Procedure to add acl.

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

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

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

An event for add server tag.

Procedure to add server tag.

A table change to add a unique constraint. <p>It is equal to the following statement: <pre> ALTER TABLE &lt;table_name&gt; ADD PRIMARY KEY (&lt;c

A table change to add a unique constraint. <p>It is equal to the following statement: <pre> ALTER TABLE &lt;table_name&gt; ADD PRIMARY KEY (&lt;c

A table change to add a watermark. <p>It is equal to the following statement: <pre> ALTER TABLE &lt;table_name&gt; ADD WATERMARK FOR &lt;row_time

A table change to add a watermark. <p>It is equal to the following statement: <pre> ALTER TABLE &lt;table_name&gt; ADD WATERMARK FOR &lt;row_time

Tests for {@link AddressBook}.

ITCase for adjust isr while ISR change.

per bucket leader and isr data with future result callback.

Handles updating the ISR by sending {@link AdjustIsrRequest} to the coordinator server. Updating the ISR is an asynchronous operation, so replica will

Test for {@link AdjustIsrManager}.

An event for receive the request of adjust isr to coordinator server.

The bucket result of each table bucket for {@link AdjustIsrRequest}.

UT test for adjust isr for tablet server.

The administrative client for Fluss, which supports managing and inspecting tables, servers, configurations and ACLs. @since 0.1

The gateway interface between the client and the server for reading and writing metadata.

The gateway interface between the client and the server for the read-only metadata access.

Column position AFTER means the specified column should be put after the given `column`.

Column position AFTER means the specified column should be put after the given `column`.

Column position AFTER means the specified column should be put after the given `column`.

Aggregation function with optional parameters for aggregate merge engine. <p>This class represents a parameterized aggregation function that can be a

Aggregation function type for aggregate merge engine. <p>This enum represents all supported aggregation function types that can be applied to non-pri

Utility class for creating parameterized aggregation functions. <p>This class provides factory methods for all supported aggregation functions with t

Utility class for processing aggregated fields from old and new rows. <p>This class provides reusable methods for aggregating fields with different s

A row merger that aggregates rows with the same primary key using field-level aggregate functions. <p>Each field can have its own aggregate function

Tests for {@link AggregateRowMerger}.

AggregatedStatisticsTracker tracks the statistics aggregation received from {@link DataStatisticsOperator} subtasks for every checkpoint. <p>NOTE: Th

Context for aggregation operations, containing field getters, aggregators, and encoder for a specific schema. <p>This class supports schema evolution

The cache for {@link AggregationContext}.

Tests for aggregator creation in {@link AggregationContext}.

A {@link BinaryArray} that uses {@link org.apache.fluss.row.aligned.AlignedRow} as the binary format for arrays of nested row type.

A {@link BinaryMap} that uses {@link org.apache.fluss.row.aligned.AlignedRow} as the binary format for nested row types.

An implementation of {@link InternalRow} which is backed by {@link MemorySegment} instead of Object. It can significantly reduce the serialization/des

A {@link RowEncoder} for {@link AlignedRow}. @since 0.9

Test for {@link AlignedRowEncoder}.

Test for {@link AlignedRow}.

Writer for {@link AlignedRow}. <p>Use the special format to write data to a {@link MemorySegment} (its capacity grows automatically). <p>If write a

An extension wrap logic for {@link BeforeAllCallback} and {@link AfterAllCallback}.

Test POJO containing all supported field types used by converters.

Configuration change operation for cluster.

The operation type of altering configurations.

A {@link CompoundPredicate.Function} to eval and.

Encapsulates an error code (via the Errors enum) and an optional message. Generally, the optional message is only defined if it adds information over

Tests for {@link org.apache.fluss.rpc.protocol.ApiError}.

Any API exception that is part of the public protocol and should be a subclass of this class and be part of this package.

Identifiers for all the Fluss wire protocol APIs.

A manager manages the supported RPC API.

Tests for {@link org.apache.fluss.rpc.protocol.ApiManager}.

An object that can serialize itself. The serialization protocol is versioned. Messages also implement toString, equals, and hashCode.

Describes an RPC API method to be invoked.