mirror of
https://github.com/GreptimeTeam/greptimedb.git
synced 2025-12-22 22:20:02 +00:00
1 line
35 KiB
HTML
1 line
35 KiB
HTML
<!DOCTYPE html><html lang="en"><head><meta charset="utf-8"><meta name="viewport" content="width=device-width, initial-scale=1.0"><meta name="generator" content="rustdoc"><meta name="description" content="List of all items in this crate"><title>List of all items in this crate</title><script>if(window.location.protocol!=="file:")document.head.insertAdjacentHTML("beforeend","SourceSerif4-Regular-6b053e98.ttf.woff2,FiraSans-Italic-81dc35de.woff2,FiraSans-Regular-0fe48ade.woff2,FiraSans-MediumItalic-ccf7e434.woff2,FiraSans-Medium-e1aa3f0a.woff2,SourceCodePro-Regular-8badfe75.ttf.woff2,SourceCodePro-Semibold-aa29a496.ttf.woff2".split(",").map(f=>`<link rel="preload" as="font" type="font/woff2"href="../static.files/${f}">`).join(""))</script><link rel="stylesheet" href="../static.files/normalize-9960930a.css"><link rel="stylesheet" href="../static.files/rustdoc-e56847b5.css"><meta name="rustdoc-vars" data-root-path="../" data-static-root-path="../static.files/" data-current-crate="flow" data-themes="" data-resource-suffix="" data-rustdoc-version="1.92.0-nightly (fa3155a64 2025-09-30)" data-channel="nightly" data-search-js="search-e256b49e.js" data-stringdex-js="stringdex-828709d0.js" data-settings-js="settings-c38705f0.js" ><script src="../static.files/storage-e2aeef58.js"></script><script defer src="../static.files/main-ce535bd0.js"></script><noscript><link rel="stylesheet" href="../static.files/noscript-263c88ec.css"></noscript><link rel="alternate icon" type="image/png" href="../static.files/favicon-32x32-eab170b8.png"><link rel="icon" type="image/svg+xml" href="../static.files/favicon-044be391.svg"></head><body class="rustdoc mod sys"><!--[if lte IE 11]><div class="warning">This old browser is unsupported and will most likely display funky things.</div><![endif]--><rustdoc-topbar><h2><a href="#">All</a></h2></rustdoc-topbar><nav class="sidebar"><div class="sidebar-crate"><h2><a href="../flow/index.html">flow</a><span class="version">1.0.0-beta.3</span></h2></div><div class="sidebar-elems"><section id="rustdoc-toc"><h3><a href="#macros">Crate Items</a></h3><ul class="block"><li><a href="#macros" title="Macros">Macros</a></li><li><a href="#structs" title="Structs">Structs</a></li><li><a href="#enums" title="Enums">Enums</a></li><li><a href="#constants" title="Constants">Constants</a></li><li><a href="#statics" title="Statics">Statics</a></li><li><a href="#traits" title="Traits">Traits</a></li><li><a href="#functions" title="Functions">Functions</a></li><li><a href="#types" title="Type Aliases">Type Aliases</a></li></ul></section><div id="rustdoc-modnav"></div></div></nav><div class="sidebar-resizer" title="Drag to resize sidebar"></div><main><div class="width-limiter"><section id="main-content" class="content"><div class="main-heading"><h1>List of all items</h1><rustdoc-toolbar></rustdoc-toolbar></div><h3 id="structs">Structs</h3><ul class="all-items"><li><a href="struct.FlowAuthHeader.html">FlowAuthHeader</a></li><li><a href="struct.FlowConfig.html">FlowConfig</a></li><li><a href="struct.FlownodeBuilder.html">FlownodeBuilder</a></li><li><a href="struct.FlownodeInstance.html">FlownodeInstance</a></li><li><a href="struct.FlownodeOptions.html">FlownodeOptions</a></li><li><a href="struct.FlownodeServer.html">FlownodeServer</a></li><li><a href="struct.FlownodeServiceBuilder.html">FlownodeServiceBuilder</a></li><li><a href="struct.FrontendInvoker.html">FrontendInvoker</a></li><li><a href="struct.StreamingEngine.html">StreamingEngine</a></li><li><a href="adapter/struct.FlowConfig.html">adapter::FlowConfig</a></li><li><a href="adapter/struct.FlowTickManager.html">adapter::FlowTickManager</a></li><li><a href="adapter/struct.FlownodeOptions.html">adapter::FlownodeOptions</a></li><li><a href="adapter/struct.StreamingEngine.html">adapter::StreamingEngine</a></li><li><a href="adapter/flownode_impl/struct.ConsistentCheckTask.html">adapter::flownode_impl::ConsistentCheckTask</a></li><li><a href="adapter/flownode_impl/struct.FlowDualEngine.html">adapter::flownode_impl::FlowDualEngine</a></li><li><a href="adapter/flownode_impl/struct.SrcTableToFlow.html">adapter::flownode_impl::SrcTableToFlow</a></li><li><a href="adapter/node_context/struct.FlownodeContext.html">adapter::node_context::FlownodeContext</a></li><li><a href="adapter/node_context/struct.IdToNameMap.html">adapter::node_context::IdToNameMap</a></li><li><a href="adapter/node_context/struct.SourceSender.html">adapter::node_context::SourceSender</a></li><li><a href="adapter/refill/struct.RefillTask.html">adapter::refill::RefillTask</a></li><li><a href="adapter/refill/struct.TaskData.html">adapter::refill::TaskData</a></li><li><a href="adapter/table_source/struct.ManagedTableSource.html">adapter::table_source::ManagedTableSource</a></li><li><a href="adapter/table_source/struct.TableDesc.html">adapter::table_source::TableDesc</a></li><li><a href="adapter/worker/struct.ActiveDataflowState.html">adapter::worker::ActiveDataflowState</a></li><li><a href="adapter/worker/struct.InterThreadCallClient.html">adapter::worker::InterThreadCallClient</a></li><li><a href="adapter/worker/struct.InterThreadCallServer.html">adapter::worker::InterThreadCallServer</a></li><li><a href="adapter/worker/struct.Worker.html">adapter::worker::Worker</a></li><li><a href="adapter/worker/struct.WorkerHandle.html">adapter::worker::WorkerHandle</a></li><li><a href="batching_mode/struct.BatchingModeOptions.html">batching_mode::BatchingModeOptions</a></li><li><a href="batching_mode/engine/struct.BatchingEngine.html">batching_mode::engine::BatchingEngine</a></li><li><a href="batching_mode/frontend_client/struct.DatabaseWithPeer.html">batching_mode::frontend_client::DatabaseWithPeer</a></li><li><a href="batching_mode/frontend_client/struct.HandlerMutable.html">batching_mode::frontend_client::HandlerMutable</a></li><li><a href="batching_mode/state/struct.DirtyTimeWindows.html">batching_mode::state::DirtyTimeWindows</a></li><li><a href="batching_mode/state/struct.FilterExprInfo.html">batching_mode::state::FilterExprInfo</a></li><li><a href="batching_mode/state/struct.TaskState.html">batching_mode::state::TaskState</a></li><li><a href="batching_mode/task/struct.BatchingTask.html">batching_mode::task::BatchingTask</a></li><li><a href="batching_mode/task/struct.PlanInfo.html">batching_mode::task::PlanInfo</a></li><li><a href="batching_mode/task/struct.TableDef.html">batching_mode::task::TableDef</a></li><li><a href="batching_mode/task/struct.TaskArgs.html">batching_mode::task::TaskArgs</a></li><li><a href="batching_mode/task/struct.TaskConfig.html">batching_mode::task::TaskConfig</a></li><li><a href="batching_mode/time_window/struct.TimeWindowExpr.html">batching_mode::time_window::TimeWindowExpr</a></li><li><a href="batching_mode/utils/struct.AddFilterRewriter.html">batching_mode::utils::AddFilterRewriter</a></li><li><a href="batching_mode/utils/struct.ColumnMatcherRewriter.html">batching_mode::utils::ColumnMatcherRewriter</a></li><li><a href="batching_mode/utils/struct.FindGroupByFinalName.html">batching_mode::utils::FindGroupByFinalName</a></li><li><a href="compute/render/struct.Context.html">compute::render::Context</a></li><li><a href="compute/render/struct.SubgraphArg.html">compute::render::SubgraphArg</a></li><li><a href="compute/render/reduce/struct.AccumOutput.html">compute::render::reduce::AccumOutput</a></li><li><a href="compute/render/reduce/struct.ReduceArrange.html">compute::render::reduce::ReduceArrange</a></li><li><a href="compute/state/struct.DataflowState.html">compute::state::DataflowState</a></li><li><a href="compute/state/struct.Scheduler.html">compute::state::Scheduler</a></li><li><a href="compute/types/struct.Arranged.html">compute::types::Arranged</a></li><li><a href="compute/types/struct.Collection.html">compute::types::Collection</a></li><li><a href="compute/types/struct.CollectionBundle.html">compute::types::CollectionBundle</a></li><li><a href="compute/types/struct.ErrCollector.html">compute::types::ErrCollector</a></li><li><a href="df_optimizer/struct.AvgExpandRule.html">df_optimizer::AvgExpandRule</a></li><li><a href="df_optimizer/struct.CheckGroupByRule.html">df_optimizer::CheckGroupByRule</a></li><li><a href="df_optimizer/struct.ExpandAvgRewriter.html">df_optimizer::ExpandAvgRewriter</a></li><li><a href="df_optimizer/struct.FindColumn.html">df_optimizer::FindColumn</a></li><li><a href="df_optimizer/struct.TumbleExpand.html">df_optimizer::TumbleExpand</a></li><li><a href="df_optimizer/struct.TumbleExpandRule.html">df_optimizer::TumbleExpandRule</a></li><li><a href="engine/struct.CreateFlowArgs.html">engine::CreateFlowArgs</a></li><li><a href="engine/struct.FlowAuthHeader.html">engine::FlowAuthHeader</a></li><li><a href="error/struct.ArrowSnafu.html">error::ArrowSnafu</a></li><li><a href="error/struct.CacheRequiredSnafu.html">error::CacheRequiredSnafu</a></li><li><a href="error/struct.ConvertColumnSchemaSnafu.html">error::ConvertColumnSchemaSnafu</a></li><li><a href="error/struct.CreateFlowSnafu.html">error::CreateFlowSnafu</a></li><li><a href="error/struct.CreateSinkTableSnafu.html">error::CreateSinkTableSnafu</a></li><li><a href="error/struct.DatafusionSnafu.html">error::DatafusionSnafu</a></li><li><a href="error/struct.DatatypesSnafu.html">error::DatatypesSnafu</a></li><li><a href="error/struct.EvalSnafu.html">error::EvalSnafu</a></li><li><a href="error/struct.ExternalSnafu.html">error::ExternalSnafu</a></li><li><a href="error/struct.FlowAlreadyExistSnafu.html">error::FlowAlreadyExistSnafu</a></li><li><a href="error/struct.FlowNotFoundSnafu.html">error::FlowNotFoundSnafu</a></li><li><a href="error/struct.FlowNotRecoveredSnafu.html">error::FlowNotRecoveredSnafu</a></li><li><a href="error/struct.IllegalAuthConfigSnafu.html">error::IllegalAuthConfigSnafu</a></li><li><a href="error/struct.IllegalCheckTaskStateSnafu.html">error::IllegalCheckTaskStateSnafu</a></li><li><a href="error/struct.InsertIntoFlowSnafu.html">error::InsertIntoFlowSnafu</a></li><li><a href="error/struct.InternalSnafu.html">error::InternalSnafu</a></li><li><a href="error/struct.InvalidClientConfigSnafu.html">error::InvalidClientConfigSnafu</a></li><li><a href="error/struct.InvalidQuerySnafu.html">error::InvalidQuerySnafu</a></li><li><a href="error/struct.InvalidRequestSnafu.html">error::InvalidRequestSnafu</a></li><li><a href="error/struct.JoinTaskSnafu.html">error::JoinTaskSnafu</a></li><li><a href="error/struct.ListFlowsSnafu.html">error::ListFlowsSnafu</a></li><li><a href="error/struct.MetaClientInitSnafu.html">error::MetaClientInitSnafu</a></li><li><a href="error/struct.NoAvailableFrontendSnafu.html">error::NoAvailableFrontendSnafu</a></li><li><a href="error/struct.NotImplementedSnafu.html">error::NotImplementedSnafu</a></li><li><a href="error/struct.ParseAddrSnafu.html">error::ParseAddrSnafu</a></li><li><a href="error/struct.PlanSnafu.html">error::PlanSnafu</a></li><li><a href="error/struct.ShutdownServerSnafu.html">error::ShutdownServerSnafu</a></li><li><a href="error/struct.StartServerSnafu.html">error::StartServerSnafu</a></li><li><a href="error/struct.SubstraitEncodeLogicalPlanSnafu.html">error::SubstraitEncodeLogicalPlanSnafu</a></li><li><a href="error/struct.SyncCheckTaskSnafu.html">error::SyncCheckTaskSnafu</a></li><li><a href="error/struct.TableNotFoundMetaSnafu.html">error::TableNotFoundMetaSnafu</a></li><li><a href="error/struct.TableNotFoundSnafu.html">error::TableNotFoundSnafu</a></li><li><a href="error/struct.TimeSnafu.html">error::TimeSnafu</a></li><li><a href="error/struct.UnexpectedSnafu.html">error::UnexpectedSnafu</a></li><li><a href="error/struct.UnsupportedSnafu.html">error::UnsupportedSnafu</a></li><li><a href="error/struct.UnsupportedTemporalFilterSnafu.html">error::UnsupportedTemporalFilterSnafu</a></li><li><a href="expr/struct.Batch.html">expr::Batch</a></li><li><a href="expr/struct.VectorDiff.html">expr::VectorDiff</a></li><li><a href="expr/struct.VectorDiffIter.html">expr::VectorDiffIter</a></li><li><a href="expr/df_func/struct.DfScalarFunction.html">expr::df_func::DfScalarFunction</a></li><li><a href="expr/df_func/struct.RawDfScalarFn.html">expr::df_func::RawDfScalarFn</a></li><li><a href="expr/error/struct.ArrowSnafu.html">expr::error::ArrowSnafu</a></li><li><a href="expr/error/struct.CastValueSnafu.html">expr::error::CastValueSnafu</a></li><li><a href="expr/error/struct.DataAlreadyExpiredSnafu.html">expr::error::DataAlreadyExpiredSnafu</a></li><li><a href="expr/error/struct.DataTypeSnafu.html">expr::error::DataTypeSnafu</a></li><li><a href="expr/error/struct.DatafusionSnafu.html">expr::error::DatafusionSnafu</a></li><li><a href="expr/error/struct.DivisionByZeroSnafu.html">expr::error::DivisionByZeroSnafu</a></li><li><a href="expr/error/struct.ExternalSnafu.html">expr::error::ExternalSnafu</a></li><li><a href="expr/error/struct.InternalSnafu.html">expr::error::InternalSnafu</a></li><li><a href="expr/error/struct.InvalidArgumentSnafu.html">expr::error::InvalidArgumentSnafu</a></li><li><a href="expr/error/struct.OptimizeSnafu.html">expr::error::OptimizeSnafu</a></li><li><a href="expr/error/struct.OverflowSnafu.html">expr::error::OverflowSnafu</a></li><li><a href="expr/error/struct.TryFromValueSnafu.html">expr::error::TryFromValueSnafu</a></li><li><a href="expr/error/struct.TypeMismatchSnafu.html">expr::error::TypeMismatchSnafu</a></li><li><a href="expr/func/struct.BinaryFuncIter.html">expr::func::BinaryFuncIter</a></li><li><a href="expr/id/struct.LocalId.html">expr::id::LocalId</a></li><li><a href="expr/linear/struct.MapFilterProject.html">expr::linear::MapFilterProject</a></li><li><a href="expr/linear/struct.MfpPlan.html">expr::linear::MfpPlan</a></li><li><a href="expr/linear/struct.SafeMfpPlan.html">expr::linear::SafeMfpPlan</a></li><li><a href="expr/relation/struct.AggregateExpr.html">expr::relation::AggregateExpr</a></li><li><a href="expr/relation/accum/struct.Bool.html">expr::relation::accum::Bool</a></li><li><a href="expr/relation/accum/struct.Float.html">expr::relation::accum::Float</a></li><li><a href="expr/relation/accum/struct.OrdValue.html">expr::relation::accum::OrdValue</a></li><li><a href="expr/relation/accum/struct.SimpleNumber.html">expr::relation::accum::SimpleNumber</a></li><li><a href="expr/relation/func/struct.AggregateFuncIter.html">expr::relation::func::AggregateFuncIter</a></li><li><a href="expr/scalar/struct.TypedExpr.html">expr::scalar::TypedExpr</a></li><li><a href="expr/signature/struct.Signature.html">expr::signature::Signature</a></li><li><a href="heartbeat/struct.HeartbeatTask.html">heartbeat::HeartbeatTask</a></li><li><a href="metrics/struct.METRIC_FLOW_BATCHING_ENGINE_BULK_MARK_TIME_WINDOW.html">metrics::METRIC_FLOW_BATCHING_ENGINE_BULK_MARK_TIME_WINDOW</a></li><li><a href="metrics/struct.METRIC_FLOW_BATCHING_ENGINE_ERROR_CNT.html">metrics::METRIC_FLOW_BATCHING_ENGINE_ERROR_CNT</a></li><li><a href="metrics/struct.METRIC_FLOW_BATCHING_ENGINE_QUERY_TIME.html">metrics::METRIC_FLOW_BATCHING_ENGINE_QUERY_TIME</a></li><li><a href="metrics/struct.METRIC_FLOW_BATCHING_ENGINE_QUERY_WINDOW_CNT.html">metrics::METRIC_FLOW_BATCHING_ENGINE_QUERY_WINDOW_CNT</a></li><li><a href="metrics/struct.METRIC_FLOW_BATCHING_ENGINE_QUERY_WINDOW_SIZE.html">metrics::METRIC_FLOW_BATCHING_ENGINE_QUERY_WINDOW_SIZE</a></li><li><a href="metrics/struct.METRIC_FLOW_BATCHING_ENGINE_SLOW_QUERY.html">metrics::METRIC_FLOW_BATCHING_ENGINE_SLOW_QUERY</a></li><li><a href="metrics/struct.METRIC_FLOW_BATCHING_ENGINE_STALLED_WINDOW_SIZE.html">metrics::METRIC_FLOW_BATCHING_ENGINE_STALLED_WINDOW_SIZE</a></li><li><a href="metrics/struct.METRIC_FLOW_BATCHING_ENGINE_START_QUERY_CNT.html">metrics::METRIC_FLOW_BATCHING_ENGINE_START_QUERY_CNT</a></li><li><a href="metrics/struct.METRIC_FLOW_ERRORS.html">metrics::METRIC_FLOW_ERRORS</a></li><li><a href="metrics/struct.METRIC_FLOW_INPUT_BUF_SIZE.html">metrics::METRIC_FLOW_INPUT_BUF_SIZE</a></li><li><a href="metrics/struct.METRIC_FLOW_INSERT_ELAPSED.html">metrics::METRIC_FLOW_INSERT_ELAPSED</a></li><li><a href="metrics/struct.METRIC_FLOW_PROCESSING_TIME.html">metrics::METRIC_FLOW_PROCESSING_TIME</a></li><li><a href="metrics/struct.METRIC_FLOW_ROWS.html">metrics::METRIC_FLOW_ROWS</a></li><li><a href="metrics/struct.METRIC_FLOW_RUN_INTERVAL_MS.html">metrics::METRIC_FLOW_RUN_INTERVAL_MS</a></li><li><a href="metrics/struct.METRIC_FLOW_TASK_COUNT.html">metrics::METRIC_FLOW_TASK_COUNT</a></li><li><a href="plan/struct.TypedPlan.html">plan::TypedPlan</a></li><li><a href="plan/join/struct.JoinFilter.html">plan::join::JoinFilter</a></li><li><a href="plan/join/struct.LinearJoinPlan.html">plan::join::LinearJoinPlan</a></li><li><a href="plan/join/struct.LinearStagePlan.html">plan::join::LinearStagePlan</a></li><li><a href="plan/reduce/struct.AccumulablePlan.html">plan::reduce::AccumulablePlan</a></li><li><a href="plan/reduce/struct.AggrWithIndex.html">plan::reduce::AggrWithIndex</a></li><li><a href="plan/reduce/struct.KeyValPlan.html">plan::reduce::KeyValPlan</a></li><li><a href="repr/struct.Row.html">repr::Row</a></li><li><a href="repr/relation/struct.ColumnType.html">repr::relation::ColumnType</a></li><li><a href="repr/relation/struct.Key.html">repr::relation::Key</a></li><li><a href="repr/relation/struct.RelationDesc.html">repr::relation::RelationDesc</a></li><li><a href="repr/relation/struct.RelationType.html">repr::relation::RelationType</a></li><li><a href="server/struct.FlowService.html">server::FlowService</a></li><li><a href="server/struct.FlownodeBuilder.html">server::FlownodeBuilder</a></li><li><a href="server/struct.FlownodeInstance.html">server::FlownodeInstance</a></li><li><a href="server/struct.FlownodeServer.html">server::FlownodeServer</a></li><li><a href="server/struct.FlownodeServerInner.html">server::FlownodeServerInner</a></li><li><a href="server/struct.FlownodeServiceBuilder.html">server::FlownodeServiceBuilder</a></li><li><a href="server/struct.FrontendInvoker.html">server::FrontendInvoker</a></li><li><a href="transform/struct.FunctionExtensions.html">transform::FunctionExtensions</a></li><li><a href="transform/struct.TumbleFunction.html">transform::TumbleFunction</a></li><li><a href="utils/struct.ArrangeHandler.html">utils::ArrangeHandler</a></li><li><a href="utils/struct.Arrangement.html">utils::Arrangement</a></li><li><a href="utils/struct.KeyExpiryManager.html">utils::KeyExpiryManager</a></li><li><a href="utils/struct.SizeReportSender.html">utils::SizeReportSender</a></li></ul><h3 id="enums">Enums</h3><ul class="all-items"><li><a href="enum.FrontendClient.html">FrontendClient</a></li><li><a href="adapter/enum.DiffRequest.html">adapter::DiffRequest</a></li><li><a href="adapter/flownode_impl/enum.FetchFromRow.html">adapter::flownode_impl::FetchFromRow</a></li><li><a href="adapter/parse_expr/enum.DateUnit.html">adapter::parse_expr::DateUnit</a></li><li><a href="adapter/parse_expr/enum.Expr.html">adapter::parse_expr::Expr</a></li><li><a href="adapter/parse_expr/enum.TimeUnit.html">adapter::parse_expr::TimeUnit</a></li><li><a href="adapter/refill/enum.QueryStream.html">adapter::refill::QueryStream</a></li><li><a href="adapter/refill/enum.TaskState.html">adapter::refill::TaskState</a></li><li><a href="adapter/worker/enum.Request.html">adapter::worker::Request</a></li><li><a href="adapter/worker/enum.Response.html">adapter::worker::Response</a></li><li><a href="batching_mode/frontend_client/enum.FrontendClient.html">batching_mode::frontend_client::FrontendClient</a></li><li><a href="batching_mode/frontend_client/enum.PeerDesc.html">batching_mode::frontend_client::PeerDesc</a></li><li><a href="batching_mode/state/enum.ExecState.html">batching_mode::state::ExecState</a></li><li><a href="batching_mode/task/enum.QueryType.html">batching_mode::task::QueryType</a></li><li><a href="error/enum.Error.html">error::Error</a></li><li><a href="expr/error/enum.EvalError.html">expr::error::EvalError</a></li><li><a href="expr/func/enum.BinaryFunc.html">expr::func::BinaryFunc</a></li><li><a href="expr/func/enum.UnaryFunc.html">expr::func::UnaryFunc</a></li><li><a href="expr/func/enum.UnmaterializableFunc.html">expr::func::UnmaterializableFunc</a></li><li><a href="expr/func/enum.VariadicFunc.html">expr::func::VariadicFunc</a></li><li><a href="expr/id/enum.GlobalId.html">expr::id::GlobalId</a></li><li><a href="expr/id/enum.Id.html">expr::id::Id</a></li><li><a href="expr/relation/accum/enum.Accum.html">expr::relation::accum::Accum</a></li><li><a href="expr/relation/func/enum.AggregateFunc.html">expr::relation::func::AggregateFunc</a></li><li><a href="expr/scalar/enum.ScalarExpr.html">expr::scalar::ScalarExpr</a></li><li><a href="expr/signature/enum.GenericFn.html">expr::signature::GenericFn</a></li><li><a href="plan/enum.Plan.html">plan::Plan</a></li><li><a href="plan/join/enum.JoinPlan.html">plan::join::JoinPlan</a></li><li><a href="plan/reduce/enum.ReducePlan.html">plan::reduce::ReducePlan</a></li><li><a href="transform/literal/enum.TimestampPrecision.html">transform::literal::TimestampPrecision</a></li></ul><h3 id="traits">Traits</h3><ul class="all-items"><li><a href="trait.GrpcQueryHandlerWithBoxedError.html">GrpcQueryHandlerWithBoxedError</a></li><li><a href="adapter/table_source/trait.FlowTableSource.html">adapter::table_source::FlowTableSource</a></li><li><a href="batching_mode/frontend_client/trait.GrpcQueryHandlerWithBoxedError.html">batching_mode::frontend_client::GrpcQueryHandlerWithBoxedError</a></li><li><a href="compute/types/trait.GenericBundle.html">compute::types::GenericBundle</a></li><li><a href="engine/trait.FlowEngine.html">engine::FlowEngine</a></li><li><a href="expr/relation/accum/trait.Accumulator.html">expr::relation::accum::Accumulator</a></li></ul><h3 id="macros">Macros</h3><ul class="all-items"><li><a href="expr/func/macro.generate_binary_signature.html">expr::func::generate_binary_signature</a></li><li><a href="expr/relation/func/macro.gen_one_siginature.html">expr::relation::func::gen_one_siginature</a></li><li><a href="expr/relation/func/macro.generate_signature.html">expr::relation::func::generate_signature</a></li><li><a href="transform/macro.not_impl_err.html">transform::not_impl_err</a></li><li><a href="transform/macro.plan_err.html">transform::plan_err</a></li></ul><h3 id="functions">Functions</h3><ul class="all-items"><li><a href="adapter/fn.batches_to_rows_req.html">adapter::batches_to_rows_req</a></li><li><a href="adapter/flownode_impl/fn.to_meta_err.html">adapter::flownode_impl::to_meta_err</a></li><li><a href="adapter/parse_expr/fn.infix_binding_power.html">adapter::parse_expr::infix_binding_power</a></li><li><a href="adapter/parse_expr/fn.parse_add_sub.html">adapter::parse_expr::parse_add_sub</a></li><li><a href="adapter/parse_expr/fn.parse_cmp.html">adapter::parse_expr::parse_cmp</a></li><li><a href="adapter/parse_expr/fn.parse_col_name.html">adapter::parse_expr::parse_col_name</a></li><li><a href="adapter/parse_expr/fn.parse_duration.html">adapter::parse_expr::parse_duration</a></li><li><a href="adapter/parse_expr/fn.parse_expr.html">adapter::parse_expr::parse_expr</a></li><li><a href="adapter/parse_expr/fn.parse_expr_bp.html">adapter::parse_expr::parse_expr_bp</a></li><li><a href="adapter/parse_expr/fn.parse_fixed.html">adapter::parse_expr::parse_fixed</a></li><li><a href="adapter/parse_expr/fn.parse_item.html">adapter::parse_expr::parse_item</a></li><li><a href="adapter/parse_expr/fn.parse_now.html">adapter::parse_expr::parse_now</a></li><li><a href="adapter/parse_expr/fn.parse_op.html">adapter::parse_expr::parse_op</a></li><li><a href="adapter/parse_expr/fn.parse_quality.html">adapter::parse_expr::parse_quality</a></li><li><a href="adapter/parse_expr/fn.parse_time_unit.html">adapter::parse_expr::parse_time_unit</a></li><li><a href="adapter/refill/test_send/fn.foo.html">adapter::refill::test_send::foo</a></li><li><a href="adapter/refill/test_send/fn.is_send.html">adapter::refill::test_send::is_send</a></li><li><a href="adapter/util/fn.column_schemas_to_proto.html">adapter::util::column_schemas_to_proto</a></li><li><a href="adapter/util/fn.from_proto_to_data_type.html">adapter::util::from_proto_to_data_type</a></li><li><a href="adapter/util/fn.relation_desc_to_column_schemas_with_fallback.html">adapter::util::relation_desc_to_column_schemas_with_fallback</a></li><li><a href="adapter/util/fn.table_info_value_to_relation_desc.html">adapter::util::table_info_value_to_relation_desc</a></li><li><a href="adapter/worker/fn.create_inter_thread_call.html">adapter::worker::create_inter_thread_call</a></li><li><a href="adapter/worker/fn.create_worker.html">adapter::worker::create_worker</a></li><li><a href="adapter/worker/fn.from_send_error.html">adapter::worker::from_send_error</a></li><li><a href="batching_mode/engine/fn.get_table_info.html">batching_mode::engine::get_table_info</a></li><li><a href="batching_mode/engine/fn.get_table_name.html">batching_mode::engine::get_table_name</a></li><li><a href="batching_mode/state/fn.to_df_literal.html">batching_mode::state::to_df_literal</a></li><li><a href="batching_mode/task/fn.build_by_sql_schema.html">batching_mode::task::build_by_sql_schema</a></li><li><a href="batching_mode/task/fn.build_by_tql_schema.html">batching_mode::task::build_by_tql_schema</a></li><li><a href="batching_mode/task/fn.build_pk_from_aggr.html">batching_mode::task::build_pk_from_aggr</a></li><li><a href="batching_mode/task/fn.create_table_with_expr.html">batching_mode::task::create_table_with_expr</a></li><li><a href="batching_mode/task/fn.determine_query_type.html">batching_mode::task::determine_query_type</a></li><li><a href="batching_mode/time_window/fn.binary_search_expr.html">batching_mode::time_window::binary_search_expr</a></li><li><a href="batching_mode/time_window/fn.calc_expr_time_window_lower_bound.html">batching_mode::time_window::calc_expr_time_window_lower_bound</a></li><li><a href="batching_mode/time_window/fn.columnar_to_ts_vector.html">batching_mode::time_window::columnar_to_ts_vector</a></li><li><a href="batching_mode/time_window/fn.create_df_schema_for_ts_column.html">batching_mode::time_window::create_df_schema_for_ts_column</a></li><li><a href="batching_mode/time_window/fn.eval_phy_time_window_expr.html">batching_mode::time_window::eval_phy_time_window_expr</a></li><li><a href="batching_mode/time_window/fn.find_time_window_expr.html">batching_mode::time_window::find_time_window_expr</a></li><li><a href="batching_mode/time_window/fn.probe_expr_time_window_upper_bound.html">batching_mode::time_window::probe_expr_time_window_upper_bound</a></li><li><a href="batching_mode/time_window/fn.to_phy_expr.html">batching_mode::time_window::to_phy_expr</a></li><li><a href="batching_mode/utils/fn.df_plan_to_sql.html">batching_mode::utils::df_plan_to_sql</a></li><li><a href="batching_mode/utils/fn.gen_plan_with_matching_schema.html">batching_mode::utils::gen_plan_with_matching_schema</a></li><li><a href="batching_mode/utils/fn.get_table_info_df_schema.html">batching_mode::utils::get_table_info_df_schema</a></li><li><a href="batching_mode/utils/fn.sql_to_df_plan.html">batching_mode::utils::sql_to_df_plan</a></li><li><a href="compute/render/map/fn.eval_mfp_core.html">compute::render::map::eval_mfp_core</a></li><li><a href="compute/render/map/fn.mfp_subgraph.html">compute::render::map::mfp_subgraph</a></li><li><a href="compute/render/reduce/fn.batch_split_by_key_val.html">compute::render::reduce::batch_split_by_key_val</a></li><li><a href="compute/render/reduce/fn.check_no_future_updates.html">compute::render::reduce::check_no_future_updates</a></li><li><a href="compute/render/reduce/fn.eval_distinct_aggrs.html">compute::render::reduce::eval_distinct_aggrs</a></li><li><a href="compute/render/reduce/fn.eval_distinct_core.html">compute::render::reduce::eval_distinct_core</a></li><li><a href="compute/render/reduce/fn.eval_simple_aggrs.html">compute::render::reduce::eval_simple_aggrs</a></li><li><a href="compute/render/reduce/fn.from_accum_values_to_live_accums.html">compute::render::reduce::from_accum_values_to_live_accums</a></li><li><a href="compute/render/reduce/fn.from_accums_to_offsetted_accum.html">compute::render::reduce::from_accums_to_offsetted_accum</a></li><li><a href="compute/render/reduce/fn.from_val_to_slice_idx.html">compute::render::reduce::from_val_to_slice_idx</a></li><li><a href="compute/render/reduce/fn.get_col_diffs.html">compute::render::reduce::get_col_diffs</a></li><li><a href="compute/render/reduce/fn.reduce_accum_subgraph.html">compute::render::reduce::reduce_accum_subgraph</a></li><li><a href="compute/render/reduce/fn.reduce_batch_subgraph.html">compute::render::reduce::reduce_batch_subgraph</a></li><li><a href="compute/render/reduce/fn.reduce_distinct_subgraph.html">compute::render::reduce::reduce_distinct_subgraph</a></li><li><a href="compute/render/reduce/fn.reduce_subgraph.html">compute::render::reduce::reduce_subgraph</a></li><li><a href="compute/render/reduce/fn.split_rows_to_key_val.html">compute::render::reduce::split_rows_to_key_val</a></li><li><a href="compute/render/reduce/fn.update_reduce_distinct_arrange.html">compute::render::reduce::update_reduce_distinct_arrange</a></li><li><a href="df_optimizer/fn.apply_df_optimizer.html">df_optimizer::apply_df_optimizer</a></li><li><a href="df_optimizer/fn.check_group_by_analyzer.html">df_optimizer::check_group_by_analyzer</a></li><li><a href="df_optimizer/fn.expand_avg_analyzer.html">df_optimizer::expand_avg_analyzer</a></li><li><a href="df_optimizer/fn.expand_tumble_analyzer.html">df_optimizer::expand_tumble_analyzer</a></li><li><a href="df_optimizer/fn.put_aggr_to_proj_analyzer.html">df_optimizer::put_aggr_to_proj_analyzer</a></li><li><a href="df_optimizer/fn.sql_to_flow_plan.html">df_optimizer::sql_to_flow_plan</a></li><li><a href="error/fn.to_status_with_last_err.html">error::to_status_with_last_err</a></li><li><a href="expr/func/fn.add.html">expr::func::add</a></li><li><a href="expr/func/fn.and.html">expr::func::and</a></li><li><a href="expr/func/fn.div.html">expr::func::div</a></li><li><a href="expr/func/fn.get_timestamp_array.html">expr::func::get_timestamp_array</a></li><li><a href="expr/func/fn.get_ts_as_millisecond.html">expr::func::get_ts_as_millisecond</a></li><li><a href="expr/func/fn.get_window_start.html">expr::func::get_window_start</a></li><li><a href="expr/func/fn.mul.html">expr::func::mul</a></li><li><a href="expr/func/fn.or.html">expr::func::or</a></li><li><a href="expr/func/fn.rem.html">expr::func::rem</a></li><li><a href="expr/func/fn.sub.html">expr::func::sub</a></li><li><a href="expr/relation/accum/fn.err_try_from_val.html">expr::relation::accum::err_try_from_val</a></li><li><a href="expr/relation/accum/fn.fail_accum.html">expr::relation::accum::fail_accum</a></li><li><a href="expr/relation/accum/fn.ty_eq_without_precision.html">expr::relation::accum::ty_eq_without_precision</a></li><li><a href="expr/utils/fn.find_plan_time_window_expr_lower_bound.html">expr::utils::find_plan_time_window_expr_lower_bound</a></li><li><a href="expr/utils/fn.find_time_window_lower_bound.html">expr::utils::find_time_window_lower_bound</a></li><li><a href="fn.get_flow_auth_options.html">get_flow_auth_options</a></li><li><a href="heartbeat/fn.query_flow_state.html">heartbeat::query_flow_state</a></li><li><a href="repr/relation/fn.return_true.html">repr::relation::return_true</a></li><li><a href="repr/fn.value_to_internal_ts.html">repr::value_to_internal_ts</a></li><li><a href="server/fn.get_all_flow_ids.html">server::get_all_flow_ids</a></li><li><a href="server/fn.get_flow_auth_options.html">server::get_flow_auth_options</a></li><li><a href="transform/aggr/fn.find_time_index_in_group_exprs.html">transform::aggr::find_time_index_in_group_exprs</a></li><li><a href="transform/expr/fn.build_proto_lit.html">transform::expr::build_proto_lit</a></li><li><a href="transform/expr/fn.from_scalar_fn_to_df_fn_impl.html">transform::expr::from_scalar_fn_to_df_fn_impl</a></li><li><a href="transform/expr/fn.is_proto_literal.html">transform::expr::is_proto_literal</a></li><li><a href="transform/expr/fn.proto_col.html">transform::expr::proto_col</a></li><li><a href="transform/expr/fn.rewrite_scalar_function.html">transform::expr::rewrite_scalar_function</a></li><li><a href="transform/expr/fn.typename_to_cdt.html">transform::expr::typename_to_cdt</a></li><li><a href="transform/literal/fn.from_bytes.html">transform::literal::from_bytes</a></li><li><a href="transform/literal/fn.from_interval_day_sec.html">transform::literal::from_interval_day_sec</a></li><li><a href="transform/literal/fn.from_interval_year_month.html">transform::literal::from_interval_year_month</a></li><li><a href="transform/literal/fn.from_substrait_literal.html">transform::literal::from_substrait_literal</a></li><li><a href="transform/literal/fn.from_substrait_type.html">transform::literal::from_substrait_type</a></li><li><a href="transform/literal/fn.to_substrait_literal.html">transform::literal::to_substrait_literal</a></li><li><a href="transform/fn.register_function_to_query_engine.html">transform::register_function_to_query_engine</a></li><li><a href="utils/fn.compact_diff_row.html">utils::compact_diff_row</a></li><li><a href="utils/fn.get_value_heap_size.html">utils::get_value_heap_size</a></li></ul><h3 id="types">Type Aliases</h3><ul class="all-items"><li><a href="type.FlowStreamingEngineRef.html">FlowStreamingEngineRef</a></li><li><a href="adapter/type.FlowStreamingEngineRef.html">adapter::FlowStreamingEngineRef</a></li><li><a href="adapter/flownode_impl/type.FlowDualEngineRef.html">adapter::flownode_impl::FlowDualEngineRef</a></li><li><a href="adapter/worker/type.ReqId.html">adapter::worker::ReqId</a></li><li><a href="adapter/worker/type.SharedBuf.html">adapter::worker::SharedBuf</a></li><li><a href="compute/types/type.Toff.html">compute::types::Toff</a></li><li><a href="engine/type.FlowId.html">engine::FlowId</a></li><li><a href="engine/type.TableName.html">engine::TableName</a></li><li><a href="error/type.Result.html">error::Result</a></li><li><a href="repr/type.Diff.html">repr::Diff</a></li><li><a href="repr/type.DiffRow.html">repr::DiffRow</a></li><li><a href="repr/type.Duration.html">repr::Duration</a></li><li><a href="repr/type.KeyValDiffRow.html">repr::KeyValDiffRow</a></li><li><a href="repr/type.Timestamp.html">repr::Timestamp</a></li><li><a href="repr/relation/type.ColumnName.html">repr::relation::ColumnName</a></li><li><a href="utils/type.ArrangeReader.html">utils::ArrangeReader</a></li><li><a href="utils/type.ArrangeWriter.html">utils::ArrangeWriter</a></li><li><a href="utils/type.Batch.html">utils::Batch</a></li><li><a href="utils/type.Spine.html">utils::Spine</a></li><li><a href="utils/type.StateReportHandler.html">utils::StateReportHandler</a></li></ul><h3 id="statics">Statics</h3><ul class="all-items"><li><a href="expr/func/static.SPECIALIZATION.html">expr::func::SPECIALIZATION</a></li><li><a href="expr/relation/func/static.SPECIALIZATION.html">expr::relation::func::SPECIALIZATION</a></li></ul><h3 id="constants">Constants</h3><ul class="all-items"><li><a href="adapter/constant.AUTO_CREATED_PLACEHOLDER_TS_COL.html">adapter::AUTO_CREATED_PLACEHOLDER_TS_COL</a></li><li><a href="adapter/constant.AUTO_CREATED_UPDATE_AT_TS_COL.html">adapter::AUTO_CREATED_UPDATE_AT_TS_COL</a></li><li><a href="batching_mode/time_window/constant.DEFAULT_TEST_TIMESTAMP.html">batching_mode::time_window::DEFAULT_TEST_TIMESTAMP</a></li><li><a href="expr/constant.TUMBLE_END.html">expr::TUMBLE_END</a></li><li><a href="expr/constant.TUMBLE_START.html">expr::TUMBLE_START</a></li><li><a href="repr/constant.BATCH_SIZE.html">repr::BATCH_SIZE</a></li><li><a href="repr/constant.BROADCAST_CAP.html">repr::BROADCAST_CAP</a></li><li><a href="repr/constant.SEND_BUF_CAP.html">repr::SEND_BUF_CAP</a></li><li><a href="server/constant.FLOW_NODE_SERVER_NAME.html">server::FLOW_NODE_SERVER_NAME</a></li></ul></section></div></main></body></html> |