List of all items

Structs

• FlowConfig
• FlowWorkerManager
• FlownodeBuilder
• FlownodeInstance
• FlownodeOptions
• FlownodeServer
• FrontendInvoker
• adapter::CreateFlowArgs
• adapter::FlowConfig
• adapter::FlowTickManager
• adapter::FlowWorkerManager
• adapter::FlownodeOptions
• adapter::node_context::FlownodeContext
• adapter::node_context::IdToNameMap
• adapter::node_context::SourceSender
• adapter::refill::RefillTask
• adapter::refill::TaskData
• adapter::table_source::ManagedTableSource
• adapter::table_source::TableDesc
• adapter::worker::ActiveDataflowState
• adapter::worker::InterThreadCallClient
• adapter::worker::InterThreadCallServer
• adapter::worker::Worker
• adapter::worker::WorkerHandle
• compute::render::Context
• compute::render::SubgraphArg
• compute::render::reduce::AccumOutput
• compute::render::reduce::ReduceArrange
• compute::state::DataflowState
• compute::state::Scheduler
• compute::types::Arranged
• compute::types::Collection
• compute::types::CollectionBundle
• compute::types::ErrCollector
• df_optimizer::AvgExpandRule
• df_optimizer::CheckGroupByRule
• df_optimizer::ExpandAvgRewriter
• df_optimizer::FindColumn
• df_optimizer::TumbleExpand
• df_optimizer::TumbleExpandRule
• error::ArrowSnafu
• error::CacheRequiredSnafu
• error::CreateFlowSnafu
• error::DatafusionSnafu
• error::DatatypesSnafu
• error::EvalSnafu
• error::ExternalSnafu
• error::FlowAlreadyExistSnafu
• error::FlowNotFoundSnafu
• error::InsertIntoFlowSnafu
• error::InternalSnafu
• error::InvalidQuerySnafu
• error::JoinTaskSnafu
• error::ListFlowsSnafu
• error::MetaClientInitSnafu
• error::NotImplementedSnafu
• error::ParseAddrSnafu
• error::PlanSnafu
• error::ShutdownServerSnafu
• error::StartServerSnafu
• error::TableNotFoundMetaSnafu
• error::TableNotFoundSnafu
• error::UnexpectedSnafu
• error::UnsupportedTemporalFilterSnafu
• expr::Batch
• expr::VectorDiff
• expr::VectorDiffIter
• expr::df_func::DfScalarFunction
• expr::df_func::RawDfScalarFn
• expr::error::ArrowSnafu
• expr::error::CastValueSnafu
• expr::error::DataAlreadyExpiredSnafu
• expr::error::DataTypeSnafu
• expr::error::DatafusionSnafu
• expr::error::DivisionByZeroSnafu
• expr::error::ExternalSnafu
• expr::error::InternalSnafu
• expr::error::InvalidArgumentSnafu
• expr::error::OptimizeSnafu
• expr::error::OverflowSnafu
• expr::error::TryFromValueSnafu
• expr::error::TypeMismatchSnafu
• expr::func::BinaryFuncIter
• expr::id::LocalId
• expr::linear::MapFilterProject
• expr::linear::MfpPlan
• expr::linear::SafeMfpPlan
• expr::relation::AggregateExpr
• expr::relation::accum::Bool
• expr::relation::accum::Float
• expr::relation::accum::OrdValue
• expr::relation::accum::SimpleNumber
• expr::relation::func::AggregateFuncIter
• expr::scalar::TypedExpr
• expr::signature::Signature
• heartbeat::HeartbeatTask
• metrics::METRIC_FLOW_ERRORS
• metrics::METRIC_FLOW_INPUT_BUF_SIZE
• metrics::METRIC_FLOW_INSERT_ELAPSED
• metrics::METRIC_FLOW_PROCESSING_TIME
• metrics::METRIC_FLOW_ROWS
• metrics::METRIC_FLOW_RUN_INTERVAL_MS
• metrics::METRIC_FLOW_TASK_COUNT
• plan::TypedPlan
• plan::join::JoinFilter
• plan::join::LinearJoinPlan
• plan::join::LinearStagePlan
• plan::reduce::AccumulablePlan
• plan::reduce::AggrWithIndex
• plan::reduce::KeyValPlan
• recording_rules::frontend_client::DatabaseWithPeer
• recording_rules::time_window::TimeWindowExpr
• recording_rules::utils::AddAutoColumnRewriter
• recording_rules::utils::AddFilterRewriter
• recording_rules::utils::FindGroupByFinalName
• repr::Row
• repr::relation::ColumnType
• repr::relation::Key
• repr::relation::RelationDesc
• repr::relation::RelationType
• server::FlowService
• server::FlownodeBuilder
• server::FlownodeInstance
• server::FlownodeServer
• server::FrontendInvoker
• transform::FunctionExtensions
• transform::TumbleFunction
• utils::ArrangeHandler
• utils::Arrangement
• utils::KeyExpiryManager
• utils::SizeReportSender

Enums

• adapter::DiffRequest
• adapter::flownode_impl::FetchFromRow
• adapter::parse_expr::DateUnit
• adapter::parse_expr::Expr
• adapter::parse_expr::TimeUnit
• adapter::refill::QueryStream
• adapter::refill::TaskState
• adapter::worker::Request
• adapter::worker::Response
• error::Error
• expr::error::EvalError
• expr::func::BinaryFunc
• expr::func::UnaryFunc
• expr::func::UnmaterializableFunc
• expr::func::VariadicFunc
• expr::id::GlobalId
• expr::id::Id
• expr::relation::accum::Accum
• expr::relation::func::AggregateFunc
• expr::scalar::ScalarExpr
• expr::signature::GenericFn
• plan::Plan
• plan::join::JoinPlan
• plan::reduce::ReducePlan
• recording_rules::frontend_client::FrontendClient
• transform::literal::TimestampPrecision

Traits

• adapter::table_source::FlowTableSource
• compute::types::GenericBundle
• expr::relation::accum::Accumulator

Macros

• expr::func::generate_binary_signature
• expr::relation::func::gen_one_siginature
• expr::relation::func::generate_signature
• transform::not_impl_err
• transform::plan_err

Functions

• adapter::batches_to_rows_req
• adapter::flownode_impl::to_meta_err
• adapter::parse_expr::infix_binding_power
• adapter::parse_expr::parse_add_sub
• adapter::parse_expr::parse_cmp
• adapter::parse_expr::parse_col_name
• adapter::parse_expr::parse_duration
• adapter::parse_expr::parse_expr
• adapter::parse_expr::parse_expr_bp
• adapter::parse_expr::parse_fixed
• adapter::parse_expr::parse_item
• adapter::parse_expr::parse_now
• adapter::parse_expr::parse_op
• adapter::parse_expr::parse_quality
• adapter::parse_expr::parse_time_unit
• adapter::refill::test_send::foo
• adapter::refill::test_send::is_send
• adapter::util::column_schemas_to_proto
• adapter::util::from_proto_to_data_type
• adapter::util::relation_desc_to_column_schemas_with_fallback
• adapter::util::table_info_value_to_relation_desc
• adapter::worker::create_inter_thread_call
• adapter::worker::create_worker
• adapter::worker::from_send_error
• compute::render::map::eval_mfp_core
• compute::render::map::mfp_subgraph
• compute::render::reduce::batch_split_by_key_val
• compute::render::reduce::check_no_future_updates
• compute::render::reduce::eval_distinct_aggrs
• compute::render::reduce::eval_distinct_core
• compute::render::reduce::eval_simple_aggrs
• compute::render::reduce::from_accum_values_to_live_accums
• compute::render::reduce::from_accums_to_offsetted_accum
• compute::render::reduce::from_val_to_slice_idx
• compute::render::reduce::get_col_diffs
• compute::render::reduce::reduce_accum_subgraph
• compute::render::reduce::reduce_batch_subgraph
• compute::render::reduce::reduce_distinct_subgraph
• compute::render::reduce::reduce_subgraph
• compute::render::reduce::split_rows_to_key_val
• compute::render::reduce::update_reduce_distinct_arrange
• df_optimizer::apply_df_optimizer
• df_optimizer::check_group_by_analyzer
• df_optimizer::expand_avg_analyzer
• df_optimizer::expand_tumble_analyzer
• df_optimizer::put_aggr_to_proj_analyzer
• df_optimizer::sql_to_flow_plan
• error::to_status_with_last_err
• expr::func::add
• expr::func::and
• expr::func::div
• expr::func::get_timestamp_array
• expr::func::get_ts_as_millisecond
• expr::func::get_window_start
• expr::func::mul
• expr::func::or
• expr::func::rem
• expr::func::sub
• expr::relation::accum::err_try_from_val
• expr::relation::accum::fail_accum
• expr::relation::accum::ty_eq_without_precision
• expr::utils::find_plan_time_window_expr_lower_bound
• expr::utils::find_time_window_lower_bound
• heartbeat::query_flow_state
• recording_rules::frontend_client::client_from_urls
• recording_rules::frontend_client::default_channel_mgr
• recording_rules::time_window::binary_search_expr
• recording_rules::time_window::calc_expr_time_window_lower_bound
• recording_rules::time_window::columnar_to_ts_vector
• recording_rules::time_window::create_df_schema_for_ts_column
• recording_rules::time_window::eval_phy_time_window_expr
• recording_rules::time_window::find_time_window_expr
• recording_rules::time_window::probe_expr_time_window_upper_bound
• recording_rules::time_window::to_phy_expr
• recording_rules::utils::df_plan_to_sql
• recording_rules::utils::sql_to_df_plan
• repr::relation::return_true
• repr::value_to_internal_ts
• server::get_all_flow_ids
• transform::aggr::find_time_index_in_group_exprs
• transform::expr::build_proto_lit
• transform::expr::from_scalar_fn_to_df_fn_impl
• transform::expr::is_proto_literal
• transform::expr::proto_col
• transform::expr::rewrite_scalar_function
• transform::expr::typename_to_cdt
• transform::literal::from_bytes
• transform::literal::from_interval_day_sec
• transform::literal::from_interval_year_month
• transform::literal::from_substrait_literal
• transform::literal::from_substrait_type
• transform::literal::to_substrait_literal
• transform::register_function_to_query_engine
• utils::compact_diff_row
• utils::get_value_heap_size

Type Aliases

• FlowWorkerManagerRef
• adapter::FlowId
• adapter::FlowWorkerManagerRef
• adapter::TableName
• adapter::worker::ReqId
• adapter::worker::SharedBuf
• compute::types::Toff
• error::Result
• repr::Diff
• repr::DiffRow
• repr::Duration
• repr::KeyValDiffRow
• repr::Timestamp
• repr::relation::ColumnName
• utils::ArrangeReader
• utils::ArrangeWriter
• utils::Batch
• utils::Spine
• utils::StateReportHandler

Statics

• expr::func::SPECIALIZATION
• expr::relation::func::SPECIALIZATION

Constants

• adapter::AUTO_CREATED_PLACEHOLDER_TS_COL
• adapter::UPDATE_AT_TS_COL
• expr::TUMBLE_END
• expr::TUMBLE_START
• recording_rules::DEFAULT_RULE_ENGINE_QUERY_TIMEOUT
• repr::BATCH_SIZE
• repr::BROADCAST_CAP
• repr::SEND_BUF_CAP
• server::FLOW_NODE_SERVER_NAME