List of all items

Structs

• algebra::CheckedInt
• algebra::DefaultSemigroup
• algebra::F32
• algebra::F64
• algebra::Present
• algebra::UnimplementedSemigroup
• algebra::zset::IndexedZSetIterator
• circuit::CheckpointCommitter
• circuit::CircuitConfig
• circuit::CircuitStorageConfig
• circuit::DBSPHandle
• circuit::Host
• circuit::LocalStoreMarker
• circuit::Runtime
• circuit::RuntimeHandle
• circuit::StorageConfig
• circuit::StorageOptions
• circuit::WeakRuntime
• circuit::WorkerLocations
• circuit::cache::CircuitStoreMarker
• circuit::checkpointer::Checkpointer
• circuit::checkpointer::EmptyCheckpoint
• circuit::circuit_builder::BootstrapInfo
• circuit::circuit_builder::ChildCircuit
• circuit::circuit_builder::CircuitHandle
• circuit::circuit_builder::CircuitMetadata
• circuit::circuit_builder::Edge
• circuit::circuit_builder::Edges
• circuit::circuit_builder::ElapsedTime
• circuit::circuit_builder::ExportId
• circuit::circuit_builder::ExportStream
• circuit::circuit_builder::FeedbackConnector
• circuit::circuit_builder::GlobalNodeId
• circuit::circuit_builder::MetadataExchange
• circuit::circuit_builder::MetadataExchangeInner
• circuit::circuit_builder::NodeId
• circuit::circuit_builder::OwnershipPreference
• circuit::circuit_builder::RefStreamValue
• circuit::circuit_builder::RegionName
• circuit::circuit_builder::ReplaySource
• circuit::circuit_builder::Stream
• circuit::circuit_builder::StreamId
• circuit::circuit_builder::ThreadCpuTime
• circuit::circuit_builder::Timed
• circuit::metadata::BatchSizeStats
• circuit::metadata::CircuitMetric
• circuit::metadata::MetricId
• circuit::metadata::MetricReading
• circuit::metadata::OperatorMeta
• circuit::operator_traits::OperatorName
• circuit::schedule::CommitProgress
• circuit::schedule::DynamicScheduler
• dynamic::BSet
• dynamic::DeserializeImpl
• dynamic::LeanVec
• dynamic::RawIter
• dynamic::RawVec
• mimalloc::AllocStats
• mimalloc::MiMalloc
• monitor::TraceMonitor
• monitor::TraceMonitorInternal
• monitor::visual_graph::Graph
• operator::Apply
• operator::Condition
• operator::ConstantGenerator
• operator::CsvSource
• operator::DelayedFeedback
• operator::DelayedNestedFeedback
• operator::Delta0
• operator::Generator
• operator::GeneratorNested
• operator::Inspect
• operator::Minus
• operator::OutputHandle
• operator::Plus
• operator::Sum
• operator::TransactionGenerator
• operator::TransactionZ1
• operator::Z1
• operator::Z1Nested
• operator::apply2::Apply2
• operator::apply2::Apply2Owned
• operator::apply3::Apply3
• operator::communication::ExchangeReceiver
• operator::communication::ExchangeSender
• operator::dynamic::accumulator::Accumulation
• operator::dynamic::accumulator::Accumulator
• operator::dynamic::accumulator::AccumulatorId
• operator::dynamic::accumulator::EnableCount
• operator::dynamic::accumulator::ShardedAccumulatorId
• operator::dynamic::aggregate::ArgMinSome
• operator::dynamic::aggregate::Avg
• operator::dynamic::aggregate::AvgFactories
• operator::dynamic::aggregate::DynAggregatorImpl
• operator::dynamic::aggregate::Fold
• operator::dynamic::aggregate::IncAggregateFactories
• operator::dynamic::aggregate::IncAggregateLinearFactories
• operator::dynamic::aggregate::Max
• operator::dynamic::aggregate::MaxSemigroup
• operator::dynamic::aggregate::Min
• operator::dynamic::aggregate::MinSemigroup
• operator::dynamic::aggregate::MinSome1
• operator::dynamic::aggregate::MinSome1Semigroup
• operator::dynamic::aggregate::Postprocess
• operator::dynamic::aggregate::StreamAggregateFactories
• operator::dynamic::aggregate::StreamLinearAggregateFactories
• operator::dynamic::asof_join::AsofJoin
• operator::dynamic::asof_join::AsofJoinFactories
• operator::dynamic::balance::Balancer
• operator::dynamic::balance::BalancerHints
• operator::dynamic::balance::JoinConstraint
• operator::dynamic::balance::MaxSat
• operator::dynamic::controlled_filter::ControlledFilterFactories
• operator::dynamic::count::DistinctCountFactories
• operator::dynamic::count::StreamDistinctCountFactories
• operator::dynamic::distinct::Distinct
• operator::dynamic::distinct::DistinctFactories
• operator::dynamic::distinct::DistinctId
• operator::dynamic::distinct::DistinctIncrementalId
• operator::dynamic::distinct::HashDistinctFactories
• operator::dynamic::filter_map::FilterIndexedZSet
• operator::dynamic::filter_map::FilterZSet
• operator::dynamic::filter_map::FlatMapIndexedZSet
• operator::dynamic::filter_map::FlatMapZSet
• operator::dynamic::filter_map::MapIndexedZSet
• operator::dynamic::filter_map::MapZSet
• operator::dynamic::group::DiffGroupTransformer
• operator::dynamic::group::LagCustomOrdFactories
• operator::dynamic::group::LagFactories
• operator::dynamic::group::RankCustomOrdFactories
• operator::dynamic::group::RowNumberCustomOrdFactories
• operator::dynamic::group::TopKCustomOrdFactories
• operator::dynamic::group::TopKFactories
• operator::dynamic::group::TopKRankCustomOrdFactories
• operator::dynamic::index::Index
• operator::dynamic::index::IndexId
• operator::dynamic::index::IndexWith
• operator::dynamic::input::AddInputIndexedZSetFactories
• operator::dynamic::input::AddInputMapFactories
• operator::dynamic::input::AddInputMapWithWaterlineFactories
• operator::dynamic::input::AddInputSetFactories
• operator::dynamic::input::AddInputZSetFactories
• operator::dynamic::input::CollectionHandle
• operator::dynamic::input::UpsertHandle
• operator::dynamic::join::AntijoinFactories
• operator::dynamic::join::AntijoinId
• operator::dynamic::join::Join
• operator::dynamic::join::JoinFactories
• operator::dynamic::join::JoinTrace
• operator::dynamic::join::MonotonicJoin
• operator::dynamic::join::OuterJoinFactories
• operator::dynamic::join::StreamAntijoinFactories
• operator::dynamic::join::StreamJoinFactories
• operator::dynamic::join::TraceJoinFuncs
• operator::dynamic::join_range::StreamJoinRange
• operator::dynamic::join_range::StreamJoinRangeFactories
• operator::dynamic::multijoin::MatchFactories
• operator::dynamic::multijoin::StarJoinFactories
• operator::dynamic::neighborhood::ArchivedNeighborhoodDescr
• operator::dynamic::neighborhood::NeighborhoodDescr
• operator::dynamic::neighborhood::NeighborhoodDescrResolver
• operator::dynamic::neighborhood::NeighborhoodFactories
• operator::dynamic::sample::StreamSampleUniqueKeyValsFactories
• operator::dynamic::semijoin::SemiJoinStream
• operator::dynamic::semijoin::SemijoinId
• operator::dynamic::semijoin::SemijoinStreamFactories
• operator::dynamic::sharded_accumulator::ShardedAccumulatorId
• operator::dynamic::time_series::PartitionCursor
• operator::dynamic::time_series::PartitionedRollingAggregateFactories
• operator::dynamic::time_series::PartitionedRollingAggregateLinearFactories
• operator::dynamic::time_series::PartitionedRollingAggregateWithWaterlineFactories
• operator::dynamic::time_series::PartitionedRollingAverageFactories
• operator::dynamic::time_series::Range
• operator::dynamic::time_series::RelRange
• operator::dynamic::time_series::TreeNode
• operator::dynamic::trace::BoundsId
• operator::dynamic::trace::DelayedTraceId
• operator::dynamic::trace::TraceAppend
• operator::dynamic::trace::TraceBound
• operator::dynamic::trace::TraceBounds
• operator::dynamic::trace::TraceFeedbackConnector
• operator::dynamic::trace::TraceId
• operator::dynamic::trace::UntimedTraceAppend
• operator::dynamic::trace::Z1Trace
• operator::group::WithCustomOrd
• operator::input::IndexedZSetHandle
• operator::input::IndexedZSetStagedBuffers
• operator::input::Input
• operator::input::InputHandle
• operator::input::MapHandle
• operator::input::MapStagedBuffers
• operator::input::SetHandle
• operator::input::SetStagedBuffers
• operator::input::ZSetHandle
• operator::input::ZSetStagedBuffers
• profile::CPUProfiler
• profile::DbspProfile
• profile::GraphProfile
• profile::Profiler
• profile::WorkerProfile
• storage::backend::BlockLocation
• storage::backend::FileId
• storage::backend::InvalidBlockLocation
• storage::backend::StoragePath
• storage::backend::StoragePathPart
• storage::backend::memory_impl::MemoryBackend
• storage::backend::posixio_impl::DeleteOnDrop
• storage::backend::posixio_impl::PosixBackend
• storage::buffer_cache::AtomicCacheCounts
• storage::buffer_cache::AtomicCacheStats
• storage::buffer_cache::BufferCache
• storage::buffer_cache::CacheCounts
• storage::buffer_cache::CacheStats
• storage::buffer_cache::FBuf
• storage::buffer_cache::FBufSerializer
• storage::buffer_cache::LimitExceeded
• storage::dirlock::LockedDirectory
• storage::file::AnyFactories
• storage::file::DbspScratch
• storage::file::DbspSerializer
• storage::file::Deserializer
• storage::file::Factories
• storage::file::FilterPlan
• storage::file::FilterStats
• storage::file::SerializerInner
• storage::file::TrackingFilterStats
• storage::file::TrackingRoaringBitmap
• storage::file::format::BatchMetadata
• storage::file::format::BlockHeader
• storage::file::format::BloomFilterBlock
• storage::file::format::BloomFilterBlockRef
• storage::file::format::DataBlockHeader
• storage::file::format::FileTrailer
• storage::file::format::FileTrailerColumn
• storage::file::format::IndexBlockHeader
• storage::file::format::RoaringBitmapFilterBlock
• storage::file::format::RoaringBitmapFilterBlockRef
• storage::file::format::TouchedWindowCount
• storage::file::reader::BulkRows
• storage::file::reader::Cursor
• storage::file::reader::FetchIndexedZSet
• storage::file::reader::FetchZSet
• storage::file::reader::Reader
• storage::file::reader::RowGroup
• storage::file::writer::Parameters
• storage::file::writer::Writer1
• storage::file::writer::Writer2
• storage::tracking_bloom_filter::TrackingBloomFilter
• time::Antichain
• time::AntichainRef
• time::Product
• time::UnitTimestamp
• time::UnitTimestampResolver
• trace::IndexedWSetSerializer
• trace::TupleBuilder
• trace::cursor::CursorFactoryWrapper
• trace::cursor::DefaultPushCursor
• trace::cursor::DelegatingCursor
• trace::cursor::FilteredMergeCursor
• trace::cursor::FilteredMergeCursorWithSnapshot
• trace::cursor::Pending
• trace::cursor::Position
• trace::cursor::ReverseKeyCursor
• trace::cursor::UnfilteredMergeCursor
• trace::cursor::cursor_empty::CursorEmpty
• trace::cursor::cursor_group::CursorGroup
• trace::cursor::cursor_list::CursorList
• trace::cursor::cursor_pair::CursorPair
• trace::cursor::cursor_with_polarity::CursorWithPolarity
• trace::cursor::saturating_cursor::SaturatingCursor
• trace::filter::BatchFilterStats
• trace::filter::BatchFilters
• trace::filter::Filter
• trace::layers::Layer
• trace::layers::LayerBuilder
• trace::layers::LayerCursor
• trace::layers::LayerFactories
• trace::layers::Leaf
• trace::layers::LeafBuilder
• trace::layers::LeafCursor
• trace::layers::LeafFactories
• trace::ord::fallback::indexed_wset::FallbackIndexedWSet
• trace::ord::fallback::indexed_wset::FallbackIndexedWSetBuilder
• trace::ord::fallback::key_batch::FallbackKeyBatch
• trace::ord::fallback::key_batch::FallbackKeyBatchFactories
• trace::ord::fallback::key_batch::FallbackKeyBuilder
• trace::ord::fallback::val_batch::FallbackValBatch
• trace::ord::fallback::val_batch::FallbackValBatchFactories
• trace::ord::fallback::val_batch::FallbackValBuilder
• trace::ord::fallback::wset::FallbackWSet
• trace::ord::fallback::wset::FallbackWSetBuilder
• trace::ord::file::indexed_wset_batch::FileIndexedWSet
• trace::ord::file::indexed_wset_batch::FileIndexedWSetBuilder
• trace::ord::file::indexed_wset_batch::FileIndexedWSetCursor
• trace::ord::file::indexed_wset_batch::FileIndexedWSetFactories
• trace::ord::file::indexed_wset_batch::FileIndexedWSetPushCursor
• trace::ord::file::key_batch::FileKeyBatch
• trace::ord::file::key_batch::FileKeyBatchFactories
• trace::ord::file::key_batch::FileKeyBuilder
• trace::ord::file::key_batch::FileKeyCursor
• trace::ord::file::val_batch::FileValBatch
• trace::ord::file::val_batch::FileValBatchFactories
• trace::ord::file::val_batch::FileValBuilder
• trace::ord::file::val_batch::FileValCursor
• trace::ord::file::wset_batch::FileWSet
• trace::ord::file::wset_batch::FileWSetBuilder
• trace::ord::file::wset_batch::FileWSetCursor
• trace::ord::file::wset_batch::FileWSetFactories
• trace::ord::file::wset_batch::FileWSetPushCursor
• trace::ord::merge_batcher::MergeBatcher
• trace::ord::merge_batcher::MergeSorter
• trace::ord::vec::indexed_wset_batch::VecIndexedWSet
• trace::ord::vec::indexed_wset_batch::VecIndexedWSetBuilder
• trace::ord::vec::indexed_wset_batch::VecIndexedWSetCursor
• trace::ord::vec::indexed_wset_batch::VecIndexedWSetFactories
• trace::ord::vec::key_batch::ValKeyCursor
• trace::ord::vec::key_batch::VecKeyBatch
• trace::ord::vec::key_batch::VecKeyBatchFactories
• trace::ord::vec::key_batch::VecKeyBuilder
• trace::ord::vec::val_batch::VecValBatch
• trace::ord::vec::val_batch::VecValBatchFactories
• trace::ord::vec::val_batch::VecValBuilder
• trace::ord::vec::val_batch::VecValCursor
• trace::ord::vec::wset_batch::VecWSet
• trace::ord::vec::wset_batch::VecWSetBuilder
• trace::ord::vec::wset_batch::VecWSetCursor
• trace::ord::vec::wset_batch::VecWSetFactories
• trace::spine_async::ListMerger
• trace::spine_async::Spine
• trace::spine_async::SpineCursor
• trace::spine_async::SpineSnapshot
• typed_batch::ArchivedTypedBox
• typed_batch::TypedBatch
• typed_batch::TypedBox
• utils::DotEdgeAttributes
• utils::DotNodeAttributes
• utils::tuple::ArchivedTup0
• utils::tuple::ArchivedTup1
• utils::tuple::ArchivedTup10
• utils::tuple::ArchivedTup10Dense
• utils::tuple::ArchivedTup10Sparse
• utils::tuple::ArchivedTup2
• utils::tuple::ArchivedTup3
• utils::tuple::ArchivedTup4
• utils::tuple::ArchivedTup5
• utils::tuple::ArchivedTup6
• utils::tuple::ArchivedTup7
• utils::tuple::ArchivedTup8
• utils::tuple::ArchivedTup9
• utils::tuple::ArchivedTup9Dense
• utils::tuple::ArchivedTup9Sparse
• utils::tuple::Tup0
• utils::tuple::Tup0Resolver
• utils::tuple::Tup1
• utils::tuple::Tup10
• utils::tuple::Tup1Resolver
• utils::tuple::Tup2
• utils::tuple::Tup2Resolver
• utils::tuple::Tup3
• utils::tuple::Tup3Resolver
• utils::tuple::Tup4
• utils::tuple::Tup4Resolver
• utils::tuple::Tup5
• utils::tuple::Tup5Resolver
• utils::tuple::Tup6
• utils::tuple::Tup6Resolver
• utils::tuple::Tup7
• utils::tuple::Tup7Resolver
• utils::tuple::Tup8
• utils::tuple::Tup8Resolver
• utils::tuple::Tup9
• utils::tuple::TupleBitmap

Enums

• Error
• circuit::Layout
• circuit::LayoutError
• circuit::Mode
• circuit::RuntimeError
• circuit::StepSize
• circuit::StorageCacheConfig
• circuit::WorkerLocation
• circuit::metadata::CircuitMetricCategory
• circuit::metadata::MetaItem
• circuit::schedule::Error
• circuit::trace::CircuitEvent
• circuit::trace::EdgeKind
• circuit::trace::SchedulerEvent
• monitor::TraceError
• operator::communication::Mailbox
• operator::dynamic::balance::BalancerError
• operator::dynamic::balance::BalancerHint
• operator::dynamic::balance::FlushState
• operator::dynamic::balance::PartitioningPolicy
• operator::dynamic::group::Monotonicity
• operator::dynamic::time_series::RelOffset
• operator::input::Update
• storage::backend::StorageError
• storage::backend::StorageFileType
• storage::buffer_cache::CacheAccess
• storage::file::BatchKeyFilter
• storage::file::FilterKind
• storage::file::format::Compression
• storage::file::format::NodeType
• storage::file::format::Varint
• storage::file::reader::CorruptionError
• storage::file::reader::Error
• trace::BatchLocation
• trace::filter::GroupFilter
• utils::tuple::Tup10Resolver
• utils::tuple::Tup9Resolver
• utils::tuple::TupleFormat

Traits

• DetailedError
• NumEntries
• algebra::AddAssignByRef
• algebra::AddByRef
• algebra::FirstLargeValue
• algebra::GroupValue
• algebra::HasOne
• algebra::HasZero
• algebra::Lattice
• algebra::MaxValue
• algebra::MinValue
• algebra::MonoidValue
• algebra::MulByRef
• algebra::NegByRef
• algebra::OptionWeightType
• algebra::PartialOrder
• algebra::RingValue
• algebra::Semigroup
• algebra::SemigroupValue
• algebra::SignedPrimInt
• algebra::TotalOrder
• algebra::UnsignedPrimInt
• algebra::ZRingValue
• algebra::zset::IndexedZSet
• algebra::zset::IndexedZSetReader
• algebra::zset::ZBatch
• algebra::zset::ZBatchReader
• algebra::zset::ZCursor
• algebra::zset::ZSet
• algebra::zset::ZSetReader
• algebra::zset::ZTrace
• circuit::checkpointer::Checkpoint
• circuit::circuit_builder::Circuit
• circuit::circuit_builder::CircuitBase
• circuit::circuit_builder::Node
• circuit::circuit_builder::StreamMetadata
• circuit::circuit_builder::WithClock
• circuit::operator_traits::BinaryOperator
• circuit::operator_traits::BinarySinkOperator
• circuit::operator_traits::Data
• circuit::operator_traits::ImportOperator
• circuit::operator_traits::NaryOperator
• circuit::operator_traits::Operator
• circuit::operator_traits::QuaternaryOperator
• circuit::operator_traits::SinkOperator
• circuit::operator_traits::SourceOperator
• circuit::operator_traits::StrictOperator
• circuit::operator_traits::StrictUnaryOperator
• circuit::operator_traits::TernaryOperator
• circuit::operator_traits::TernarySinkOperator
• circuit::operator_traits::UnaryOperator
• circuit::schedule::Executor
• circuit::schedule::Scheduler
• dynamic::ArchiveTrait
• dynamic::ArchivedDBData
• dynamic::AsAny
• dynamic::Clonable
• dynamic::ClonableTrait
• dynamic::Comparable
• dynamic::Data
• dynamic::DataTrait
• dynamic::DataTraitTyped
• dynamic::DeserializableDyn
• dynamic::DeserializeDyn
• dynamic::DowncastTrait
• dynamic::Erase
• dynamic::Factory
• dynamic::Opt
• dynamic::Pairs
• dynamic::PairsTrait
• dynamic::SerializeDyn
• dynamic::Set
• dynamic::SetTrait
• dynamic::VecTrait
• dynamic::Vector
• dynamic::Weight
• dynamic::WeightTrait
• dynamic::WeightTraitTyped
• dynamic::WeightedPairs
• dynamic::WeightedPairsTrait
• dynamic::WithFactory
• dynamic::pair::Pair
• operator::RecursiveStreams
• operator::dynamic::aggregate::AggCombineFunc
• operator::dynamic::aggregate::AggOutputFunc
• operator::dynamic::aggregate::Aggregator
• operator::dynamic::aggregate::DynAggregator
• operator::dynamic::aggregate::WeightedCountOutFunc
• operator::dynamic::filter_map::DynFilterMap
• operator::dynamic::group::GroupTransformer
• operator::dynamic::group::NonIncrementalGroupTransformer
• operator::dynamic::input::HashFunc
• operator::dynamic::join::JoinFuncTrait
• operator::dynamic::join::TraceJoinFuncTrait
• operator::dynamic::neighborhood::NeighborhoodDescrTrait
• operator::dynamic::recursive::RecursiveStreams
• operator::dynamic::time_series::PartitionedBatch
• operator::dynamic::time_series::PartitionedBatchReader
• operator::dynamic::time_series::PartitionedIndexedZSet
• operator::dynamic::trace::TraceFeedback
• operator::group::CmpFunc
• operator::input::StagedBuffers
• storage::backend::FileReader
• storage::backend::FileRw
• storage::backend::FileWriter
• storage::backend::StorageBackend
• storage::file::ArchivedItem
• storage::file::Deserializable
• storage::file::Item
• storage::file::ItemFactory
• storage::file::Rkyv
• storage::file::WithItemFactory
• storage::file::reader::ColumnSpec
• storage::file::reader::FallibleEq
• time::Timestamp
• trace::Batch
• trace::BatchFactories
• trace::BatchReader
• trace::BatchReaderFactories
• trace::Batcher
• trace::Builder
• trace::DBData
• trace::DBWeight
• trace::Trace
• trace::cursor::ClonableCursor
• trace::cursor::Cursor
• trace::cursor::CursorFactory
• trace::cursor::MergeCursor
• trace::cursor::PushCursor
• trace::filter::FilterFunc
• trace::layers::Builder
• trace::layers::Cursor
• trace::layers::MergeBuilder
• trace::layers::OrdOffset
• trace::layers::Trie
• trace::layers::TupleBuilder
• trace::spine_async::BatchReaderWithSnapshot
• trace::spine_async::WithSnapshot
• typed_batch::Batch
• typed_batch::BatchReader
• typed_batch::IndexedZSet
• typed_batch::IndexedZSetReader
• typed_batch::Trace
• typed_batch::ZSet
• typed_batch::ZSetReader
• utils::ConsolidatePairedSlices
• utils::IsNone
• utils::SupportsRoaring

Macros

• build_star_join_flatmap_func
• build_star_join_func
• build_star_join_index_func
• circuit_cache_key
• circuit_cache_key_unsized
• count_tts
• declare_trait_object
• declare_trait_object_with_archived
• declare_typed_trait_object
• define_inner_star_join
• define_inner_star_join_flatmap
• define_inner_star_join_index
• define_star_join
• define_star_join_flatmap
• define_star_join_index
• delegate_is_none
• delegate_supports_roaring
• derive_comparison_traits
• derive_erase
• generate_all_join_orderings
• indexed_zset
• inner_star_join_body
• inner_star_join_flatmap_body
• inner_star_join_flatmap_root_body
• inner_star_join_index_body
• inner_star_join_index_root_body
• inner_star_join_root_body
• lean_vec
• metadata
• never_none
• never_none_1
• never_none_tuples
• never_roaring_filter
• never_roaring_filter_1
• never_roaring_filter_tuples
• num_entries_scalar
• star_join_body
• star_join_flatmap_body
• star_join_flatmap_funcs
• star_join_funcs
• star_join_index_body
• star_join_index_funcs
• zset
• zset_set

Functions

• circuit::adaptive_joins_enabled
• circuit::balancer_balance_tax
• circuit::balancer_key_distribution_refresh_threshold
• circuit::balancer_min_absolute_improvement_threshold
• circuit::balancer_min_relative_improvement_threshold
• circuit::max_level0_batch_size_records
• circuit::negative_weight_multiplier
• circuit::splitter_output_chunk_size
• circuit::splitter_output_first_chunk_size
• default_hash
• default_hasher
• operator::apply_n
• operator::communication::new_exchange_operators
• operator::dynamic::concat::dyn_accumulate_concat
• operator::dynamic::concat::dyn_concat_accumulated
• operator::dynamic::sample::default_quantiles
• storage::backend::tempdir_for_thread
• storage::file::to_bytes
• storage::file::to_bytes_dyn
• storage::init
• trace::aligned_deserialize
• trace::deserialize_indexed_wset
• trace::eq_batch
• trace::merge_batches
• trace::merge_batches_by_reference
• trace::ord::fallback::pick_insert_destination
• trace::ord::fallback::pick_merge_destination
• trace::serialize_indexed_wset
• trace::unaligned_deserialize
• utils::advance
• utils::advance_erased
• utils::components
• utils::consolidate
• utils::consolidate_from
• utils::consolidate_paired_slices
• utils::consolidate_payload_from
• utils::consolidate_slice
• utils::dyn_advance
• utils::dyn_retreat
• utils::indent
• utils::process_rss_bytes
• utils::retreat
• utils::retreat_erased
• utils::sample_slice
• utils::stable_sort
• utils::stable_sort_by
• utils::unstable_sort
• utils::unstable_sort_by

Type Aliases

• Scope
• algebra::zset::DynZWeight
• algebra::zset::OrdIndexedZSet
• algebra::zset::OrdIndexedZSetFactories
• algebra::zset::OrdZSet
• algebra::zset::OrdZSetFactories
• algebra::zset::VecIndexedZSet
• algebra::zset::VecIndexedZSetFactories
• algebra::zset::VecZSet
• algebra::zset::VecZSetFactories
• algebra::zset::ZWeight
• circuit::LocalStore
• circuit::cache::CircuitCache
• circuit::circuit_builder::IterativeCircuit
• circuit::circuit_builder::NestedCircuit
• circuit::circuit_builder::NonIterativeCircuit
• circuit::circuit_builder::RootCircuit
• circuit::circuit_builder::Scope
• circuit::metadata::MetaLabel
• circuit::metadata::MetricLabels
• circuit::metadata::OperatorLocation
• dynamic::DynBool
• dynamic::DynData
• dynamic::DynDataTyped
• dynamic::DynOpt
• dynamic::DynPairs
• dynamic::DynSet
• dynamic::DynUnit
• dynamic::DynVec
• dynamic::DynWeight
• dynamic::DynWeightTyped
• dynamic::DynWeightedPairs
• dynamic::pair::DynPair
• operator::dynamic::MonoIndexedZSet
• operator::dynamic::MonoIndexedZSetFactories
• operator::dynamic::MonoZSet
• operator::dynamic::MonoZSetFactories
• operator::dynamic::aggregate::DynAverage
• operator::dynamic::asof_join::AsofJoinFunc
• operator::dynamic::input::IndexedZSetStream
• operator::dynamic::input::ZSetStream
• operator::dynamic::join::JoinFunc
• operator::dynamic::join::TraceJoinFunc
• operator::dynamic::multijoin::StarJoinFunc
• operator::dynamic::neighborhood::DynNeighborhood
• operator::dynamic::neighborhood::DynNeighborhoodDescr
• operator::dynamic::neighborhood::NeighborhoodDescrStream
• operator::dynamic::neighborhood::NeighborhoodStream
• operator::dynamic::time_series::LeastUpperBoundFunc
• operator::dynamic::time_series::OrdPartitionedIndexedZSet
• operator::dynamic::time_series::OrdPartitionedOverStream
• operator::dynamic::trace::TimedSpine
• operator::input::IndexedZSetStream
• operator::input::PatchFunc
• operator::input::ZSetStream
• operator::neighborhood::Neighborhood
• operator::neighborhood::NeighborhoodDescrBox
• operator::neighborhood::NeighborhoodDescrStream
• operator::neighborhood::NeighborhoodStream
• operator::time_series::OrdPartitionedIndexedZSet
• operator::time_series::OrdPartitionedOverStream
• trace::WeightedItem
• trace::ord::fallback::indexed_wset::FallbackIndexedWSetFactories
• trace::ord::fallback::wset::FallbackWSetFactories
• trace::ord::vec::key_batch::VecKeyBatchLayer
• trace::ord::vec::val_batch::VecValBatchLayer
• typed_batch::FallbackIndexedWSet
• typed_batch::FallbackIndexedZSet
• typed_batch::FallbackKeyBatch
• typed_batch::FallbackValBatch
• typed_batch::FallbackWSet
• typed_batch::FallbackZSet
• typed_batch::FileIndexedWSet
• typed_batch::FileIndexedZSet
• typed_batch::FileKeyBatch
• typed_batch::FileValBatch
• typed_batch::FileWSet
• typed_batch::FileZSet
• typed_batch::OrdIndexedWSet
• typed_batch::OrdIndexedZSet
• typed_batch::OrdKeyBatch
• typed_batch::OrdValBatch
• typed_batch::OrdWSet
• typed_batch::OrdZSet
• typed_batch::Spine
• typed_batch::SpineSnapshot
• typed_batch::VecIndexedWSet
• typed_batch::VecIndexedZSet
• typed_batch::VecKeyBatch
• typed_batch::VecValBatch
• typed_batch::VecWSet
• typed_batch::VecZSet

Statics

• circuit::metrics::COMPACTION_STALL_TIME_NANOSECONDS
• circuit::metrics::DBSP_OPERATOR_COMMIT_LATENCY_MICROSECONDS
• circuit::metrics::DBSP_STEP
• circuit::metrics::DBSP_STEP_LATENCY_MICROSECONDS
• circuit::metrics::FILES_CREATED
• circuit::metrics::FILES_DELETED
• circuit::metrics::TOTAL_LATE_RECORDS
• circuit::tokio::TOKIO
• circuit::tokio::TOKIO_DEDICATED_IO

Constants

• circuit::metadata::ACCUMULATOR_RECORDS_TO_REPARTITION_COUNT
• circuit::metadata::ALLOCATED_MEMORY_BYTES
• circuit::metadata::BACKGROUND_CACHE_OCCUPANCY
• circuit::metadata::BALANCER_POLICY
• circuit::metadata::BLOOM_FILTER_BITS_PER_KEY
• circuit::metadata::BLOOM_FILTER_HITS_COUNT
• circuit::metadata::BLOOM_FILTER_HIT_RATE_PERCENT
• circuit::metadata::BLOOM_FILTER_MISSES_COUNT
• circuit::metadata::BLOOM_FILTER_SIZE_BYTES
• circuit::metadata::CACHE_BACKGROUND_HITS
• circuit::metadata::CACHE_BACKGROUND_HIT_RATE_PERCENT
• circuit::metadata::CACHE_BACKGROUND_MISSES
• circuit::metadata::CACHE_FOREGROUND_HITS
• circuit::metadata::CACHE_FOREGROUND_HIT_RATE_PERCENT
• circuit::metadata::CACHE_FOREGROUND_MISSES
• circuit::metadata::CIRCUIT_IDLE_TIME_SECONDS
• circuit::metadata::CIRCUIT_METRICS
• circuit::metadata::CIRCUIT_RUNTIME_ELAPSED_SECONDS
• circuit::metadata::CIRCUIT_RUNTIME_SECONDS
• circuit::metadata::CIRCUIT_WAIT_TIME_SECONDS
• circuit::metadata::COMPACTION_STATE
• circuit::metadata::COMPLETED_MERGES
• circuit::metadata::COMPUTED_OUTPUT_RECORDS_COUNT
• circuit::metadata::EXCHANGE_DESERIALIZATION_TIME_SECONDS
• circuit::metadata::EXCHANGE_DESERIALIZED_BYTES
• circuit::metadata::EXCHANGE_SERIALIZATION_TIME_SECONDS
• circuit::metadata::EXCHANGE_SERIALIZED_BYTES
• circuit::metadata::EXCHANGE_WAIT_TIME_SECONDS
• circuit::metadata::FOREGROUND_CACHE_OCCUPANCY
• circuit::metadata::INPROGRESS_REBALANCING_TIME_SECONDS
• circuit::metadata::INPUT_BATCHES_STATS
• circuit::metadata::INPUT_INTEGRAL_RECORDS_COUNT
• circuit::metadata::INPUT_RECORDS_COUNT
• circuit::metadata::INTEGRAL_RECORDS_TO_REPARTITION_COUNT
• circuit::metadata::INVOCATIONS_COUNT
• circuit::metadata::KEY_DISTRIBUTION
• circuit::metadata::LEFT_INPUT_BATCHES_STATS
• circuit::metadata::LEFT_INPUT_RECORDS_COUNT
• circuit::metadata::LOCAL_SHARD_RECORDS_COUNT
• circuit::metadata::LOOSE_BATCHES_COUNT
• circuit::metadata::LOOSE_MEMORY_RECORDS_COUNT
• circuit::metadata::LOOSE_STORAGE_RECORDS_COUNT
• circuit::metadata::MEMORY_ALLOCATIONS_COUNT
• circuit::metadata::MERGE_BACKPRESSURE_WAIT_TIME_SECONDS
• circuit::metadata::MERGE_REDUCTION_PERCENT
• circuit::metadata::MERGING_BATCHES_COUNT
• circuit::metadata::MERGING_MEMORY_RECORDS_COUNT
• circuit::metadata::MERGING_SIZE_BYTES
• circuit::metadata::MERGING_STORAGE_RECORDS_COUNT
• circuit::metadata::NEGATIVE_WEIGHT_COUNT
• circuit::metadata::OUTPUT_BATCHES_STATS
• circuit::metadata::OUTPUT_REDUNDANCY_PERCENT
• circuit::metadata::PREFIX_BATCHES_STATS
• circuit::metadata::RABALANCINGS_COUNT
• circuit::metadata::RANGE_FILTER_HITS_COUNT
• circuit::metadata::RANGE_FILTER_HIT_RATE_PERCENT
• circuit::metadata::RANGE_FILTER_MISSES_COUNT
• circuit::metadata::RANGE_FILTER_SIZE_BYTES
• circuit::metadata::REBALANCING_IN_PROGRESS
• circuit::metadata::RETAINMENT_BOUNDS
• circuit::metadata::RIGHT_INPUT_BATCHES_STATS
• circuit::metadata::RIGHT_INPUT_INTEGRAL_RECORDS_COUNT
• circuit::metadata::ROARING_FILTER_HITS_COUNT
• circuit::metadata::ROARING_FILTER_HIT_RATE_PERCENT
• circuit::metadata::ROARING_FILTER_MISSES_COUNT
• circuit::metadata::ROARING_FILTER_SIZE_BYTES
• circuit::metadata::RUNTIME_NONBLOCKING_PERCENT
• circuit::metadata::RUNTIME_PERCENT
• circuit::metadata::RUNTIME_SECONDS
• circuit::metadata::SHARED_MEMORY_BYTES
• circuit::metadata::SIZE_DISTRIBUTION
• circuit::metadata::SPINE_BATCHES_COUNT
• circuit::metadata::SPINE_COUNT
• circuit::metadata::SPINE_STORAGE_SIZE_BYTES
• circuit::metadata::STATE_RECORDS_COUNT
• circuit::metadata::STEPS_COUNT
• circuit::metadata::TOTAL_REBALANCING_TIME_SECONDS
• circuit::metadata::USED_MEMORY_BYTES
• ir::LABEL_MIR_NODE_ID
• operator::dynamic::balance::BALANCE_TAX
• operator::dynamic::balance::KEY_DISTRIBUTION_REFRESH_THRESHOLD
• operator::dynamic::balance::MIN_ABSOLUTE_IMPROVEMENT_THRESHOLD
• operator::dynamic::balance::MIN_RELATIVE_IMPROVEMENT_THRESHOLD
• operator::dynamic::sample::MAX_QUANTILES
• operator::dynamic::sample::MAX_SAMPLE_SIZE
• storage::file::BLOOM_FILTER_FALSE_POSITIVE_RATE
• storage::file::SCRATCH_SIZE
• storage::file::format::BLOOM_FILTER_BLOCK_MAGIC
• storage::file::format::COMPATIBLE_FEATURE_FILTER64
• storage::file::format::COMPATIBLE_FEATURE_NEGATIVE_WEIGHT_COUNT
• storage::file::format::DATA_BLOCK_MAGIC
• storage::file::format::FILE_TRAILER_BLOCK_MAGIC
• storage::file::format::INCOMPATIBLE_FEATURE_ROARING_FILTERS
• storage::file::format::INDEX_BLOCK_MAGIC
• storage::file::format::MIN_SUPPORTED_VERSION
• storage::file::format::ROARING_BITMAP_FILTER_BLOCK_MAGIC
• storage::file::format::VERSION_NUMBER