List of all items

Structs

• activator::ActivationAck
• activator::ActivatorInner
• activator::ArcActivator
• activator::RcActivator
• antichain::FrontierPrinter
• builder_async::AsyncInputHandle
• builder_async::AsyncOutputHandle
• builder_async::AsyncOutputHandleInner
• builder_async::Button
• builder_async::ButtonHandle
• builder_async::ConnectedToMany
• builder_async::ConnectedToOne
• builder_async::Disconnected
• builder_async::InputHandleQueue
• builder_async::OperatorBuilder
• builder_async::PressOnDropButton
• builder_async::TimelyWaker
• capture::EventLink
• capture::PusherCapture
• capture::UnboundedTokioCapture
• column_pager::AlwaysResidentPolicy
• column_pager::ColumnPager
• column_pager::Meta
• column_pager::PageHint
• column_pager::ResidentTicket
• column_pager::metrics::PagerMetrics
• column_pager::policy::TieredPolicy
• columnar::batcher::Chunker
• columnar::batcher::ColumnChunker
• columnar::batcher::ColumnMerger
• columnar::builder::ColumnBuilder
• columnar::consolidate::ConsolidatingColumnBuilder
• columnar::merge_batcher::ColumnMergeBatcher
• columnar::merge_batcher::FetchIter
• columnation::ColInternalMerger
• columnation::ColumnationChunker
• columnation::ColumnationStack
• containers::stack::FueledBuilder
• order::Interval
• order::Partitioned
• order::Reverse
• pact::Distribute
• pact::DistributePusher
• probe::Handle
• reclock::ChainBatch
• temporal::BucketChain
• temporal::BucketRange

Enums

• builder_async::Event
• column_pager::Codec
• column_pager::CompressedInner
• column_pager::PageDecision
• column_pager::PageEvent
• column_pager::PagedColumn
• columnar::Column

Traits

• activator::ActivatorTrait
• antichain::AntichainExt
• builder_async::InputConnection
• builder_async::InputQueue
• builder_async::OutputIndex
• column_pager::PagingPolicy
• operator::ClearContainer
• operator::CollectionExt
• operator::ConcatenateFlatten
• operator::StreamExt
• order::Extrema
• order::Step
• probe::ProbeNotify
• replay::MzReplay
• scope_label::ScopeExt
• temporal::Bucket
• temporal::BucketTimestamp

Functions

• builder_async::button
• capture::arc_event_link
• column_pager::apply_tiered_config
• column_pager::global_pager
• column_pager::metrics::bytes_to_u64
• column_pager::metrics::metrics
• column_pager::metrics::observe_pagein
• column_pager::metrics::observe_pageout
• column_pager::metrics::observe_resident_released
• column_pager::metrics::observe_skip
• column_pager::metrics::register
• column_pager::pad_u8_to_u64
• column_pager::policy::decode_backend
• column_pager::policy::decode_codec
• column_pager::policy::encode_backend
• column_pager::policy::encode_codec
• column_pager::policy::try_consume
• column_pager::set_global_pager
• column_pager::tiered_policy
• columnar::at_serialized_capacity
• columnar::batcher::drain_side
• columnar::batcher::empty_chunk
• columnar::batcher::gallop
• columnar::batcher::recycle_chunk
• columnar::columnar_exchange
• columnar::consolidate::default_staging_cap
• columnar::merge_batcher::account_chunk
• columnar::merge_batcher::drain_side
• columnar::merge_batcher::extract_chain
• columnar::merge_batcher::merge_chains
• columnar::merge_batcher::recycle_capped
• operator::consolidate_pact
• order::refine_antichain
• panic::halt_on_timely_communication_panic
• probe::source
• reclock::reclock

Type Aliases

• columnar::Col2KeyBatcher
• columnar::Col2ValBatcher
• columnar::Col2ValPagedBatcher

Statics

• column_pager::GLOBAL_PAGER
• column_pager::TIERED_POLICY
• column_pager::metrics::METRICS

Constants

• column_pager::policy::BACKEND_FILE
• column_pager::policy::BACKEND_SWAP
• column_pager::policy::CODEC_LZ4
• column_pager::policy::CODEC_NONE
• columnar::SHIP_WORDS
• columnar::consolidate::DRAIN_CHUNK_ROWS
• columnar::consolidate::FLUSH_THRESHOLD_WORDS
• columnar::consolidate::OUTPUT_TARGET_WORDS
• columnar::consolidate::STAGING_BUFFER_BYTES
• columnar::merge_batcher::MAX_RECYCLE_BYTES
• columnar::merge_batcher::STASH_CAP