List of all items

Structs

• ServerNode
• client::AppendWriter
• client::FlussAdmin
• client::FlussConnection
• client::FlussTable
• client::KvWriteRecord
• client::LogScanner
• client::LookupResult
• client::Lookuper
• client::Metadata
• client::ReadyCheckResult
• client::ReadyWriteBatch
• client::RecordAccumulator
• client::RecordAppendResult
• client::RecordBatchLogScanner
• client::ResultHandle
• client::SecurityTokenManager
• client::TableAppend
• client::TableLookup
• client::TableScan
• client::TableUpsert
• client::UpsertWriter
• client::WriteRecord
• client::WriteResultFuture
• config::Config
• io::FileIO
• io::FileIOBuilder
• io::FileStatus
• io::InputFile
• metadata::ArrayType
• metadata::AutoPartitionStrategy
• metadata::BigIntType
• metadata::BinaryType
• metadata::BooleanType
• metadata::BytesType
• metadata::CharType
• metadata::Column
• metadata::DataField
• metadata::DataTypes
• metadata::DatabaseDescriptor
• metadata::DatabaseDescriptorBuilder
• metadata::DatabaseInfo
• metadata::DateType
• metadata::DecimalType
• metadata::DoubleType
• metadata::FloatType
• metadata::IntType
• metadata::LakeSnapshot
• metadata::MapType
• metadata::PartitionInfo
• metadata::PartitionSpec
• metadata::PhysicalTablePath
• metadata::PrimaryKey
• metadata::ResolvedPartitionSpec
• metadata::RowType
• metadata::Schema
• metadata::SchemaBuilder
• metadata::SmallIntType
• metadata::StringType
• metadata::TableBucket
• metadata::TableConfig
• metadata::TableDescriptor
• metadata::TableDescriptorBuilder
• metadata::TableDistribution
• metadata::TableInfo
• metadata::TablePartition
• metadata::TablePath
• metadata::TimeType
• metadata::TimestampLTzType
• metadata::TimestampType
• metadata::TinyIntType
• proto::AuthenticateRequest
• proto::AuthenticateResponse
• proto::CreateDatabaseRequest
• proto::CreateDatabaseResponse
• proto::CreatePartitionRequest
• proto::CreatePartitionResponse
• proto::CreateTableRequest
• proto::CreateTableResponse
• proto::DatabaseExistsRequest
• proto::DatabaseExistsResponse
• proto::DropDatabaseRequest
• proto::DropDatabaseResponse
• proto::DropPartitionRequest
• proto::DropPartitionResponse
• proto::DropTableRequest
• proto::DropTableResponse
• proto::ErrorResponse
• proto::FetchLogRequest
• proto::FetchLogResponse
• proto::GetDatabaseInfoRequest
• proto::GetDatabaseInfoResponse
• proto::GetFileSystemSecurityTokenRequest
• proto::GetFileSystemSecurityTokenResponse
• proto::GetLatestLakeSnapshotRequest
• proto::GetLatestLakeSnapshotResponse
• proto::GetTableInfoRequest
• proto::GetTableInfoResponse
• proto::InitWriterRequest
• proto::InitWriterResponse
• proto::ListDatabasesRequest
• proto::ListDatabasesResponse
• proto::ListOffsetsRequest
• proto::ListOffsetsResponse
• proto::ListPartitionInfosRequest
• proto::ListPartitionInfosResponse
• proto::ListTablesRequest
• proto::ListTablesResponse
• proto::LookupRequest
• proto::LookupResponse
• proto::MetadataRequest
• proto::MetadataResponse
• proto::PbBucketMetadata
• proto::PbFetchLogReqForBucket
• proto::PbFetchLogReqForTable
• proto::PbFetchLogRespForBucket
• proto::PbFetchLogRespForTable
• proto::PbKeyValue
• proto::PbLakeSnapshotForBucket
• proto::PbListOffsetsRespForBucket
• proto::PbLookupReqForBucket
• proto::PbLookupRespForBucket
• proto::PbPartitionInfo
• proto::PbPartitionMetadata
• proto::PbPartitionSpec
• proto::PbPhysicalTablePath
• proto::PbProduceLogReqForBucket
• proto::PbProduceLogRespForBucket
• proto::PbPutKvReqForBucket
• proto::PbPutKvRespForBucket
• proto::PbRemoteLogFetchInfo
• proto::PbRemoteLogSegment
• proto::PbServerNode
• proto::PbTableMetadata
• proto::PbTablePath
• proto::PbValue
• proto::ProduceLogRequest
• proto::ProduceLogResponse
• proto::PutKvRequest
• proto::PutKvResponse
• proto::TableExistsRequest
• proto::TableExistsResponse
• record::ArrowLogRecordIterator
• record::ArrowReader
• record::LogRecordBatch
• record::LogRecordsBatches
• record::MemoryLogRecordsArrowBuilder
• record::MyVec
• record::PrebuiltRecordBatchBuilder
• record::ReadContext
• record::RowAppendRecordBatchBuilder
• record::ScanBatch
• record::ScanRecord
• record::ScanRecords
• record::kv::KvRecord
• record::kv::KvRecordBatch
• record::kv::KvRecordBatchBuilder
• record::kv::KvRecordIterator
• record::kv::KvRecordReadContext
• record::kv::KvRecords
• row::BinaryRow
• row::ColumnarRow
• row::CompactedRowDecoder
• row::Date
• row::Decimal
• row::GenericRow
• row::RowDecoderFactory
• row::Time
• row::TimestampLtz
• row::TimestampNtz
• row::compacted::CompactedKeyWriter
• row::compacted::CompactedRow
• row::compacted::CompactedRowDeserializer
• row::compacted::CompactedRowReader
• row::compacted::CompactedRowWriter
• row::encode::KeyEncoderFactory
• row::encode::RowEncoderFactory
• rpc::ApiError
• rpc::RpcClient
• rpc::SaslConfig
• rpc::ServerConnectionInner
• rpc::message::AuthenticateRequest
• rpc::message::CreateDatabaseRequest
• rpc::message::CreatePartitionRequest
• rpc::message::CreateTableRequest
• rpc::message::DatabaseExistsRequest
• rpc::message::DropDatabaseRequest
• rpc::message::DropPartitionRequest
• rpc::message::DropTableRequest
• rpc::message::FetchLogRequest
• rpc::message::GetDatabaseInfoRequest
• rpc::message::GetLatestLakeSnapshotRequest
• rpc::message::GetSecurityTokenRequest
• rpc::message::GetTableRequest
• rpc::message::InitWriterRequest
• rpc::message::ListDatabasesRequest
• rpc::message::ListOffsetsRequest
• rpc::message::ListPartitionInfosRequest
• rpc::message::ListTablesRequest
• rpc::message::LookupRequest
• rpc::message::ProduceLogRequest
• rpc::message::PutKvRequest
• rpc::message::RequestHeader
• rpc::message::ResponseHeader
• rpc::message::TableExistsRequest
• rpc::message::UpdateMetadataRequest

Enums

• ServerType
• client::LogWriteRecord
• client::Record
• client::RowBytes
• client::WriteFormat
• config::NoKeyAssigner
• error::Error
• io::Storage
• metadata::DataLakeFormat
• metadata::DataType
• metadata::KvFormat
• metadata::LogFormat
• record::ChangeType
• record::LogMagicValue
• record::LogRecordIterator
• row::BinaryDataWrapper
• row::Datum
• row::binary::BinaryRowFormat
• row::binary::InnerValueWriter
• row::binary::ValueWriter
• row::field_getter::FieldGetter
• row::field_getter::InnerFieldGetter
• rpc::FlussError
• rpc::error::RpcError
• rpc::message::OffsetSpec

Traits

• io::FileRead
• metadata::JsonSerde
• record::ArrowRecordBatchInnerBuilder
• record::ToArrow
• record::kv::ReadContext
• record::kv::SchemaGetter
• row::InternalRow
• row::RowDecoder
• row::ToArrow
• row::binary::BinaryWriter
• row::encode::KeyEncoder
• row::encode::RowEncoder
• rpc::message::ReadVersionedType
• rpc::message::RequestBody
• rpc::message::WriteVersionedType

Macros

• impl_read_version_type
• impl_write_version_type

Functions

• record::to_arrow_schema
• record::to_arrow_type
• rpc::from_pb_server_node
• rpc::from_pb_table_path
• rpc::to_table_path

Type Aliases

• BucketId
• PartitionId
• TableId
• client::CredentialsReceiver
• error::Result
• row::Blob
• row::F32
• row::F64
• row::Str
• rpc::MessengerTransport
• rpc::ServerConnection

Constants

• client::DEFAULT_REMOTE_FILE_DOWNLOAD_THREAD_NUM
• client::DEFAULT_SCANNER_REMOTE_LOG_PREFETCH_NUM
• client::EARLIEST_OFFSET
• metadata::PARTITION_SPEC_SEPARATOR
• record::ARROW_CHANGETYPE_OFFSET
• record::ATTRIBUTES_OFFSET
• record::ATTRIBUTE_LENGTH
• record::BASE_OFFSET_LENGTH
• record::BASE_OFFSET_OFFSET
• record::BATCH_SEQUENCE_LENGTH
• record::BATCH_SEQUENCE_OFFSET
• record::BUILDER_DEFAULT_OFFSET
• record::COMMIT_TIMESTAMP_LENGTH
• record::COMMIT_TIMESTAMP_OFFSET
• record::CRC_LENGTH
• record::CRC_OFFSET
• record::CURRENT_LOG_MAGIC_VALUE
• record::DEFAULT_MAX_RECORD
• record::LAST_OFFSET_DELTA_LENGTH
• record::LAST_OFFSET_DELTA_OFFSET
• record::LENGTH_LENGTH
• record::LENGTH_OFFSET
• record::LOG_OVERHEAD
• record::MAGIC_LENGTH
• record::MAGIC_OFFSET
• record::MAX_BATCH_SIZE
• record::NO_BATCH_SEQUENCE
• record::NO_WRITER_ID
• record::RECORDS_COUNT_LENGTH
• record::RECORDS_COUNT_OFFSET
• record::RECORDS_OFFSET
• record::RECORD_BATCH_HEADER_SIZE
• record::SCHEMA_ID_LENGTH
• record::SCHEMA_ID_OFFSET
• record::WRITE_CLIENT_ID_LENGTH
• record::WRITE_CLIENT_ID_OFFSET
• record::kv::ATTRIBUTES_OFFSET
• record::kv::ATTRIBUTE_LENGTH
• record::kv::BATCH_SEQUENCE_LENGTH
• record::kv::BATCH_SEQUENCE_OFFSET
• record::kv::CRC_LENGTH
• record::kv::CRC_OFFSET
• record::kv::CURRENT_KV_MAGIC_VALUE
• record::kv::KV_OVERHEAD
• record::kv::KV_RECORD_LENGTH_LENGTH
• record::kv::LENGTH_LENGTH
• record::kv::LENGTH_OFFSET
• record::kv::MAGIC_LENGTH
• record::kv::MAGIC_OFFSET
• record::kv::NO_BATCH_SEQUENCE
• record::kv::NO_WRITER_ID
• record::kv::RECORDS_COUNT_LENGTH
• record::kv::RECORDS_COUNT_OFFSET
• record::kv::RECORDS_OFFSET
• record::kv::RECORD_BATCH_HEADER_SIZE
• record::kv::SCHEMA_ID_LENGTH
• record::kv::SCHEMA_ID_OFFSET
• record::kv::WRITE_CLIENT_ID_LENGTH
• record::kv::WRITE_CLIENT_ID_OFFSET
• row::MAX_COMPACT_PRECISION
• row::MAX_COMPACT_TIMESTAMP_PRECISION
• row::MAX_NANO_OF_MILLISECOND
• rpc::message::CLIENT_FOLLOWER_SERVER_ID
• rpc::message::LIST_EARLIEST_OFFSET
• rpc::message::LIST_LATEST_OFFSET
• rpc::message::LIST_OFFSET_FROM_TIMESTAMP