List of all items

Structs

• arrangement::manager::PaddedTrace
• arrangement::manager::TraceBundle
• arrangement::manager::TraceManager
• compute_state::ActiveComputeState
• compute_state::CollectionState
• compute_state::ComputeState
• compute_state::DroppedCollection
• compute_state::HydrationEvent
• compute_state::IndexPeek
• compute_state::PersistPeek
• compute_state::ReportedFrontiers
• compute_state::SinkToken
• extensions::arrange::KeyCollection
• logging::BatchLogger
• logging::EventQueue
• logging::LogCollection
• logging::PermutedRowPacker
• logging::SharedLoggingState
• logging::compute::ArrangementHeapDatum
• logging::compute::ArrangementSizeState
• logging::compute::CollectionLogging
• logging::compute::DataflowGlobalDatum
• logging::compute::DemuxHandler
• logging::compute::DemuxOutput
• logging::compute::DemuxState
• logging::compute::ErrorCountDatum
• logging::compute::ExportDatum
• logging::compute::ExportState
• logging::compute::FrontierDatum
• logging::compute::HydrationTimeDatum
• logging::compute::ImportFrontierDatum
• logging::compute::LirMappingDatum
• logging::compute::LirMetadata
• logging::compute::Peek
• logging::compute::PeekDatum
• logging::compute::PeekDurationDatum
• logging::differential::DemuxHandler
• logging::differential::DemuxOutput
• logging::differential::DemuxState
• logging::initialize::LoggingContext
• logging::timely::ChannelDatum
• logging::timely::DemuxHandler
• logging::timely::DemuxOutput
• logging::timely::DemuxState
• logging::timely::MessageCount
• logging::timely::MessageDatum
• logging::timely::Park
• logging::timely::ParkDatum
• logging::timely::ScheduleHistogramDatum
• metrics::ComputeMetrics
• metrics::TraceMetrics
• metrics::WorkerMetrics
• render::Pairer
• render::StartSignal
• render::context::CollectionBundle
• render::context::Context
• render::context::HydrationLogger
• render::context::PendingWork
• render::context::ShutdownToken
• render::continual_task::ContinualTaskCtx
• render::continual_task::SinkState
• render::errors::ErrorLogger
• render::join::linear_join::LinearJoinSpec
• render::join::linear_join::YieldSpec
• render::join::mz_join_core::Deferred
• render::reduce::monoids::ReductionMonoidRegion
• render::reduce::window_agg_helpers::AccumulableOneByOneAggr
• render::reduce::window_agg_helpers::HierarchicalOneByOneAggr
• render::top_k::monoids::Top1Monoid
• render::top_k::monoids::Top1MonoidLocal
• render::top_k::monoids::Top1MonoidRegion
• render::top_k::monoids::Top1MonoidShared
• render::top_k::topk_agg::TopKBatch
• row_spine::container::DatumBatch
• row_spine::container::DatumContainer
• row_spine::container::DatumSeq
• row_spine::offset_opt::OffsetOptimized
• row_spine::spines::RowLayout
• row_spine::spines::RowRowLayout
• row_spine::spines::RowValLayout
• server::CommandReceiver
• server::CommandReceiverQueue
• server::ComputeInstanceContext
• server::Config
• server::ResponseSender
• server::Worker
• sink::copy_to_s3_oneshot::ResponseProtocol
• sink::correction::ConsolidatingVec
• sink::correction::Correction
• sink::correction::LengthAndCapacity
• sink::materialized_view_v2::BatchDescription
• sink::materialized_view_v2::OkErr
• sink::materialized_view_v2::PersistApi
• sink::materialized_view_v2::append::State
• sink::materialized_view_v2::mint::State
• sink::materialized_view_v2::write::State
• sink::subscribe::SubscribeProtocol
• typedefs::spines::MzFlatLayout
• typedefs::spines::MzStack

Enums

• arrangement::manager::SpecializedTraceHandle
• compute_state::PendingPeek
• compute_state::ReportedFrontier
• logging::compute::ComputeEvent
• logging::compute::PeekType
• render::context::ArrangementFlavor
• render::context::MzArrangement
• render::context::MzArrangementImport
• render::continual_task::ContinualTaskSourceTransformer
• render::join::linear_join::JoinedFlavor
• render::join::linear_join::LinearJoinImpl
• render::reduce::Accum
• render::reduce::monoids::ReductionMonoid
• render::reduce::window_agg_helpers::OneByOneAggrImpls
• row_spine::offset_opt::OffsetStride

Traits

• extensions::arrange::ArrangementSize
• extensions::arrange::MzArrange
• extensions::arrange::MzArrangeCore
• extensions::reduce::MzReduce
• extensions::reduce::ReduceExt
• logging::compute::LogDataflowErrors
• render::RenderTimestamp
• render::WithStartSignal
• render::continual_task::StepForward
• render::continual_task::TimesExtract
• render::continual_task::TimesReduce
• render::errors::MaybeValidatingRow
• render::sinks::SinkRender

Functions

• extensions::arrange::log_arrangement_size_inner
• logging::compute::construct
• logging::compute::make_string_datum
• logging::compute::sum_batch_diffs
• logging::differential::construct
• logging::initialize::initialize
• logging::initialize::try_downcast_timestamp
• logging::reachability::construct
• logging::timely::construct
• logging::timely::grow_vec
• render::build_compute_dataflow
• render::context::specialized_arrangement_key
• render::continual_task::continual_task_sink
• render::continual_task::truncating_compare_and_append
• render::flat_map::drain_through_mfp
• render::join::delta_join::build_halfjoin
• render::join::delta_join::build_update_stream
• render::join::delta_join::dispatch_build_halfjoin_local
• render::join::delta_join::dispatch_build_halfjoin_trace
• render::join::delta_join::dispatch_build_update_stream_local
• render::join::delta_join::dispatch_build_update_stream_trace
• render::join::mz_join_core::mz_join_core
• render::reduce::accumulable_zero
• render::reduce::datum_to_accumulator
• render::reduce::evaluate_mfp_after
• render::reduce::finalize_accum
• render::reduce::monoids::get_monoid
• render::sinks::get_sink_render_for
• render::suppress_early_progress
• render::threshold::build_threshold_basic
• render::threshold::dispatch_threshold_arrangement_local
• render::threshold::dispatch_threshold_arrangement_trace
• render::threshold::threshold_arrangement
• render::top_k::build_topk_negated_stage
• render::top_k::render_intra_ts_thinning
• row_spine::offset_list_size
• server::serve
• server::set_core_affinity
• sink::materialized_view::append_batches
• sink::materialized_view::install_desired_into_persist
• sink::materialized_view::mint_batch_descriptions
• sink::materialized_view::persist_sink
• sink::materialized_view::write_batches
• sink::materialized_view_v2::advance
• sink::materialized_view_v2::append::advance_shard_upper
• sink::materialized_view_v2::append::render
• sink::materialized_view_v2::mint::render
• sink::materialized_view_v2::persist_sink
• sink::materialized_view_v2::persist_source
• sink::materialized_view_v2::write::render
• sink::refresh::apply_refresh
• sink::subscribe::subscribe

Type Aliases

• logging::compute::Logger
• logging::compute::OutputSession
• logging::compute::Pusher
• logging::compute::Update
• logging::differential::OutputSession
• logging::differential::Pusher
• logging::initialize::ReachabilityEventRegion
• logging::initialize::ReachabilityEventRegionPreference
• logging::timely::OutputSession
• logging::timely::Pusher
• row_spine::spines::RowRowSpine
• row_spine::spines::RowSpine
• row_spine::spines::RowValSpine
• server::ActivatorSender
• sink::materialized_view_v2::BatchesStream
• sink::materialized_view_v2::DescsStream
• sink::materialized_view_v2::DesiredStreams
• sink::materialized_view_v2::PersistStreams
• typedefs::ErrAgent
• typedefs::ErrEnter
• typedefs::ErrSpine
• typedefs::FlatKeyValAgent
• typedefs::FlatKeyValBatch
• typedefs::FlatKeyValEnter
• typedefs::FlatKeyValSpine
• typedefs::FlatKeyValSpineDefault
• typedefs::KeyAgent
• typedefs::KeyBatcher
• typedefs::KeyEnter
• typedefs::KeyErrSpine
• typedefs::KeySpine
• typedefs::KeyValAgent
• typedefs::KeyValBatcher
• typedefs::KeyValEnter
• typedefs::KeyValSpine
• typedefs::RowAgent
• typedefs::RowArrangement
• typedefs::RowEnter
• typedefs::RowErrSpine
• typedefs::RowRowAgent
• typedefs::RowRowArrangement
• typedefs::RowRowEnter
• typedefs::RowValAgent
• typedefs::RowValArrangement
• typedefs::RowValEnter
• typedefs::spines::ColKeySpine
• typedefs::spines::ColValSpine

Statics

• render::reduce::FLOAT_SCALE