List of all items

Structs

• alloc::PriorityGuard
• checkpoint::barrier::BarrierPollHandle
• checkpoint::barrier::CheckpointBarrier
• checkpoint::barrier::CheckpointBarrierInjector
• cluster::control::barrier::BarrierAck
• cluster::control::barrier::BarrierAnnouncement
• cluster::control::barrier::BarrierCoordinator
• cluster::control::barrier::InMemoryKv
• cluster::control::chitchat_kv::ChitchatKv
• cluster::control::controller::ClusterController
• cluster::control::decision::CheckpointDecisionStore
• cluster::control::snapshot::AssignmentSnapshot
• cluster::control::snapshot::AssignmentSnapshotStore
• cluster::discovery::ArchivedNodeInfo
• cluster::discovery::ArchivedNodeMetadata
• cluster::discovery::GossipDiscovery
• cluster::discovery::GossipDiscoveryConfig
• cluster::discovery::NodeInfo
• cluster::discovery::NodeInfoResolver
• cluster::discovery::NodeMetadata
• cluster::discovery::NodeMetadataResolver
• cluster::discovery::StaticDiscovery
• cluster::discovery::StaticDiscoveryConfig
• cluster::testing::FaultyObjectStore
• cluster::testing::MiniCluster
• cluster::testing::NetworkRules
• cluster::testing::NodeHandle
• cluster::testing::PartitionableTransport
• lookup::foyer_cache::FoyerMemoryCache
• lookup::foyer_cache::FoyerMemoryCacheConfig
• lookup::foyer_cache::LookupCacheKey
• lookup::predicate::SourceCapabilities
• lookup::predicate::SplitPredicates
• lookup::source::LookupSourceCapabilities
• lookup::source::PushdownAdapter
• mv::MaterializedView
• mv::MvRegistry
• operator::Event
• operator::OperatorState
• operator::sliding_window::SlidingWindowAssigner
• operator::table_cache::TableCacheMetrics
• operator::table_cache::TableLruCache
• operator::table_cache::TableXorFilter
• operator::window::ChangelogRecord
• operator::window::TumblingWindowAssigner
• operator::window::WindowId
• shuffle::barrier_tracker::BarrierTracker
• shuffle::transport::ShuffleReceiver
• shuffle::transport::ShuffleSender
• state::in_process::InProcessBackend
• state::object_store::ObjectStoreBackend
• state::vnode::ArchivedNodeId
• state::vnode::NodeId
• state::vnode::NodeIdResolver
• state::vnode::VnodeRegistry
• streaming::channel::AsyncConsumer
• streaming::channel::Producer
• streaming::checkpoint::StreamCheckpointConfig
• streaming::config::ChannelConfig
• streaming::config::SourceConfig
• streaming::error::TryPushError
• streaming::sink::Sink
• streaming::source::Source
• streaming::subscription::Subscription
• time::AscendingTimestampsGenerator
• time::BoundedOutOfOrdernessGenerator
• time::CastError
• time::EventTimeExtractor
• time::PeriodicGenerator
• time::ProcessingTimeGenerator
• time::PunctuatedGenerator
• time::SourceProvidedGenerator
• time::TimerRegistration
• time::TimerService
• time::Watermark
• time::WatermarkTracker

Enums

• Error
• alloc::PriorityClass
• checkpoint::barrier::StreamMessage
• cluster::control::barrier::Phase
• cluster::control::barrier::QuorumOutcome
• cluster::control::decision::DecisionError
• cluster::control::snapshot::RotateOutcome
• cluster::control::snapshot::SnapshotError
• cluster::discovery::ArchivedNodeState
• cluster::discovery::DiscoveryError
• cluster::discovery::MembershipEvent
• cluster::discovery::NodeState
• cluster::discovery::NodeStateResolver
• cluster::testing::ObjectStoreFault
• error_codes::HotPathError
• error_codes::WarningSeverity
• lookup::LookupResult
• lookup::predicate::Predicate
• lookup::predicate::ScalarValue
• lookup::source::LookupError
• mv::MvError
• mv::MvState
• operator::OperatorError
• operator::table_cache::LookupDecision
• operator::window::CdcOperation
• operator::window::EmitStrategy
• shuffle::message::ShuffleMessage
• state::backend::StateBackendError
• state::config::DiscoveryMode
• state::config::StateBackendBuildError
• state::config::StateBackendConfig
• streaming::checkpoint::CheckpointError
• streaming::config::BackpressureStrategy
• streaming::config::WaitStrategy
• streaming::error::RecvError
• streaming::error::StreamingError
• time::EventTimeError
• time::ExtractionMode
• time::ThresholdOp
• time::TimeError
• time::TimestampField

Traits

• cluster::control::barrier::ClusterKv
• cluster::discovery::Discovery
• lookup::source::LookupSource
• lookup::source::LookupSourceDyn
• operator::window::WindowAssigner
• state::backend::StateBackend
• streaming::source::Record
• time::WatermarkGenerator

Macros

• debug_assert_priority

Functions

• cluster::control::leader::leader_of
• lookup::predicate::predicate_to_sql
• lookup::predicate::split_predicates
• operator::table_cache::collect_cache_metrics
• serialization::deserialize_batch_stream
• serialization::serialize_batch_stream
• state::vnode::key_hash
• state::vnode::owned_vnodes
• state::vnode::round_robin_assignment
• streaming::channel::channel
• streaming::source::create
• streaming::source::create_with_config
• time::cast_to_millis_array
• time::filter_batch_by_timestamp
• time::parse_duration_str

Type Aliases

• Result
• lookup::source::ColumnId
• operator::TimerKey
• operator::window::WindowIdVec
• shuffle::transport::ShufflePeerId
• time::FiredTimersVec
• time::TimerKey

Constants

• checkpoint::barrier::flags::CANCEL
• checkpoint::barrier::flags::DRAIN
• checkpoint::barrier::flags::FULL_SNAPSHOT
• checkpoint::barrier::flags::NONE
• cluster::control::barrier::ACK_KEY
• cluster::control::barrier::ANNOUNCEMENT_KEY
• cluster::discovery::keys::FAILURE_DOMAIN
• cluster::discovery::keys::LOAD_CORES
• cluster::discovery::keys::LOAD_MEMORY
• cluster::discovery::keys::NODE_NAME
• cluster::discovery::keys::NODE_STATE
• cluster::discovery::keys::NODE_VERSION
• cluster::discovery::keys::PARTITIONS_OWNED
• cluster::discovery::keys::RAFT_ADDRESS
• cluster::discovery::keys::RPC_ADDRESS
• error_codes::ARROW_ERROR
• error_codes::BASE64_DECODE_ERROR
• error_codes::CHECKPOINT_FAILED
• error_codes::CHECKPOINT_NOT_FOUND
• error_codes::CHECKPOINT_PRUNE_FAILED
• error_codes::CONNECTOR_AUTH_FAILED
• error_codes::CONNECTOR_CONFIG_ERROR
• error_codes::CONNECTOR_CONNECTION_FAILED
• error_codes::CONNECTOR_READ_ERROR
• error_codes::CONNECTOR_SCHEMA_ERROR
• error_codes::CONNECTOR_SERDE_ERROR
• error_codes::CONNECTOR_WRITE_ERROR
• error_codes::DESERIALIZATION_FAILED
• error_codes::DURABILITY_GATE_BACKEND_ERROR
• error_codes::DURABILITY_GATE_MISS
• error_codes::DURABILITY_GATE_ROLLBACK_FAILED
• error_codes::DURABILITY_GATE_ROLLBACK_ON_ERROR_FAILED
• error_codes::EXACTLY_ONCE_NON_REPLAYABLE
• error_codes::EXACTLY_ONCE_NO_CHECKPOINT
• error_codes::EXACTLY_ONCE_SINK_UNSUPPORTED
• error_codes::INTERNAL
• error_codes::INVALID_CONFIG
• error_codes::INVALID_OPERATION
• error_codes::JOIN_KEY_MISSING
• error_codes::JOIN_TIME_BOUND_MISSING
• error_codes::JOIN_TYPE_UNSUPPORTED
• error_codes::JSON_PARSE_ERROR
• error_codes::LATE_DATA_REJECTED
• error_codes::MANIFEST_PERSIST_FAILED
• error_codes::MATERIALIZED_VIEW_ERROR
• error_codes::MISSING_CONFIG
• error_codes::MIXED_DELIVERY_CAPABILITIES
• error_codes::NO_COMPILED_PROJECTION
• error_codes::OFFSET_METADATA_MISSING
• error_codes::PIPELINE_ERROR
• error_codes::PLAN_OPTIMIZATION_FAILED
• error_codes::QUERY_EXECUTION_FAILED
• error_codes::QUERY_PIPELINE_ERROR
• error_codes::RECOVERY_FAILED
• error_codes::SCHEMA_MISMATCH
• error_codes::SERIALIZATION_FAILED
• error_codes::SHUTDOWN
• error_codes::SIDECAR_CORRUPTION
• error_codes::SINK_ALREADY_EXISTS
• error_codes::SINK_NOT_FOUND
• error_codes::SINK_ROLLBACK_FAILED
• error_codes::SOURCE_ALREADY_EXISTS
• error_codes::SOURCE_NOT_FOUND
• error_codes::SQL_COLUMN_NOT_FOUND
• error_codes::SQL_PLANNING_FAILED
• error_codes::SQL_TABLE_NOT_FOUND
• error_codes::SQL_TYPE_MISMATCH
• error_codes::SQL_UNSUPPORTED
• error_codes::STATE_CORRUPTION
• error_codes::STATE_KEY_MISSING
• error_codes::TEMPORAL_JOIN_NO_PK
• error_codes::UNRESOLVED_CONFIG_VAR
• error_codes::WAL_CHECKSUM_MISMATCH
• error_codes::WAL_ERROR
• error_codes::WAL_INVALID_LENGTH
• error_codes::WATERMARK_REQUIRED
• error_codes::WINDOW_INVALID
• error_codes::WINDOW_SIZE_INVALID
• serialization::jsonb_tags::ARRAY
• serialization::jsonb_tags::BOOL_FALSE
• serialization::jsonb_tags::BOOL_TRUE
• serialization::jsonb_tags::FLOAT64
• serialization::jsonb_tags::INT64
• serialization::jsonb_tags::NULL
• serialization::jsonb_tags::OBJECT
• serialization::jsonb_tags::STRING
• shuffle::message::MAX_PAYLOAD_BYTES
• shuffle::transport::SHUFFLE_ADDR_KEY
• state::config::DEFAULT_VNODE_CAPACITY
• streaming::config::DEFAULT_BUFFER_SIZE
• streaming::config::MAX_BUFFER_SIZE
• streaming::config::MIN_BUFFER_SIZE