Files

1 line
31 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-1ed95124.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.98.1 (48a229cea 2026-09-01)" data-channel="1.98.1" data-search-js="search-9944d736.js" data-stringdex-js="stringdex-2da4960a.js" data-settings-js="settings-170eb4bf.js" ><script src="../static.files/storage-41dd4d93.js"></script><script defer src="../static.files/main-417ebf0a.js"></script><noscript><link rel="stylesheet" href="../static.files/noscript-f7c3ffd8.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"><a class="skip-main-content" href="#main-content">Skip to main content</a><!--[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.4.0-alpha.0</span></h2></div><div class="sidebar-elems"><section id="rustdoc-toc"><h3><a href="#structs">Crate Items</a></h3><ul class="block"><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="#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" tabindex="-1"><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.BatchingExecutionGuard.html">BatchingExecutionGuard</a></li><li><a href="struct.BatchingModeOptions.html">BatchingModeOptions</a></li><li><a href="struct.BatchingTask.html">BatchingTask</a></li><li><a href="struct.ExecuteOnceOutcome.html">ExecuteOnceOutcome</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.IncrementalAggregateAnalysis.html">IncrementalAggregateAnalysis</a></li><li><a href="struct.IncrementalAggregateMergeColumn.html">IncrementalAggregateMergeColumn</a></li><li><a href="struct.PlanInfo.html">PlanInfo</a></li><li><a href="struct.StreamingEngine.html">StreamingEngine</a></li><li><a href="struct.TaskArgs.html">TaskArgs</a></li><li><a href="struct.TimeWindowExpr.html">TimeWindowExpr</a></li><li><a href="adapter/struct.FlowConfig.html">adapter::FlowConfig</a></li><li><a href="adapter/struct.FlownodeOptions.html">adapter::FlownodeOptions</a></li><li><a href="adapter/struct.StatelessFlowRuntime.html">adapter::StatelessFlowRuntime</a></li><li><a href="adapter/struct.StatelessFlowSlot.html">adapter::StatelessFlowSlot</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/stateless/struct.StatelessFlow.html">adapter::stateless::StatelessFlow</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="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/engine/struct.FlowRuntimeRegistry.html">batching_mode::engine::FlowRuntimeRegistry</a></li><li><a href="batching_mode/eval_schedule/struct.DueScheduledTimes.html">batching_mode::eval_schedule::DueScheduledTimes</a></li><li><a href="batching_mode/eval_schedule/struct.EvalSchedule.html">batching_mode::eval_schedule::EvalSchedule</a></li><li><a href="batching_mode/eval_schedule/struct.FlowScheduleConfig.html">batching_mode::eval_schedule::FlowScheduleConfig</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.FencedRepair.html">batching_mode::state::FencedRepair</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/table_creator/struct.TableDef.html">batching_mode::table_creator::TableDef</a></li><li><a href="batching_mode/task/struct.BatchingExecutionGuard.html">batching_mode::task::BatchingExecutionGuard</a></li><li><a href="batching_mode/task/struct.BatchingTask.html">batching_mode::task::BatchingTask</a></li><li><a href="batching_mode/task/struct.ExecuteOnceOutcome.html">batching_mode::task::ExecuteOnceOutcome</a></li><li><a href="batching_mode/task/struct.PlanInfo.html">batching_mode::task::PlanInfo</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/time_window/struct.TimeWindowPlanShape.html">batching_mode::time_window::TimeWindowPlanShape</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="batching_mode/utils/struct.IncrementalAggregateAnalysis.html">batching_mode::utils::IncrementalAggregateAnalysis</a></li><li><a href="batching_mode/utils/struct.IncrementalAggregateMergeColumn.html">batching_mode::utils::IncrementalAggregateMergeColumn</a></li><li><a href="batching_mode/utils/struct.OutputProjectionInfo.html">batching_mode::utils::OutputProjectionInfo</a></li><li><a href="df_optimizer/struct.CheckGroupByRule.html">df_optimizer::CheckGroupByRule</a></li><li><a href="df_optimizer/struct.FindColumn.html">df_optimizer::FindColumn</a></li><li><a href="engine/struct.CreateFlowArgs.html">engine::CreateFlowArgs</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.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.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.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="expr/struct.Batch.html">expr::Batch</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.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.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.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="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_CHECKPOINT_DECISION_CNT.html">metrics::METRIC_FLOW_BATCHING_ENGINE_CHECKPOINT_DECISION_CNT</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_MODE_CNT.html">metrics::METRIC_FLOW_BATCHING_ENGINE_QUERY_MODE_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_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_TASK_COUNT.html">metrics::METRIC_FLOW_TASK_COUNT</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="utils/struct.SizeReportSender.html">utils::SizeReportSender</a></li></ul><h3 id="enums">Enums</h3><ul class="all-items"><li><a href="enum.DirtyRestore.html">DirtyRestore</a></li><li><a href="enum.FrontendClient.html">FrontendClient</a></li><li><a href="enum.IncrementalAggregateMergeOp.html">IncrementalAggregateMergeOp</a></li><li><a href="enum.PeerDesc.html">PeerDesc</a></li><li><a href="enum.QueryCoverage.html">QueryCoverage</a></li><li><a href="adapter/enum.FetchFromRow.html">adapter::FetchFromRow</a></li><li><a href="batching_mode/checkpoint/enum.FlowCheckpointDecision.html">batching_mode::checkpoint::FlowCheckpointDecision</a></li><li><a href="batching_mode/checkpoint/enum.FlowQueryFallbackReason.html">batching_mode::checkpoint::FlowQueryFallbackReason</a></li><li><a href="batching_mode/eval_schedule/enum.FlowMissedTickPolicy.html">batching_mode::eval_schedule::FlowMissedTickPolicy</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.CheckpointMode.html">batching_mode::state::CheckpointMode</a></li><li><a href="batching_mode/state/enum.ExecState.html">batching_mode::state::ExecState</a></li><li><a href="batching_mode/table_creator/enum.QueryType.html">batching_mode::table_creator::QueryType</a></li><li><a href="batching_mode/task/enum.DirtyRestore.html">batching_mode::task::DirtyRestore</a></li><li><a href="batching_mode/task/enum.QueryCoverage.html">batching_mode::task::QueryCoverage</a></li><li><a href="batching_mode/utils/enum.IncrementalAggregateMergeOp.html">batching_mode::utils::IncrementalAggregateMergeOp</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></ul><h3 id="traits">Traits</h3><ul class="all-items"><li><a href="trait.BatchingExecution.html">BatchingExecution</a></li><li><a href="trait.BatchingExecutionFactory.html">BatchingExecutionFactory</a></li><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/batching_execution/trait.BatchingExecution.html">batching_mode::batching_execution::BatchingExecution</a></li><li><a href="batching_mode/batching_execution/trait.BatchingExecutionFactory.html">batching_mode::batching_execution::BatchingExecutionFactory</a></li><li><a href="batching_mode/frontend_client/trait.GrpcQueryHandlerWithBoxedError.html">batching_mode::frontend_client::GrpcQueryHandlerWithBoxedError</a></li><li><a href="engine/trait.FlowEngine.html">engine::FlowEngine</a></li><li><a href="engine/trait.FlowStatProvider.html">engine::FlowStatProvider</a></li></ul><h3 id="functions">Functions</h3><ul class="all-items"><li><a href="adapter/fn.default_num_workers.html">adapter::default_num_workers</a></li><li><a href="adapter/flownode_impl/fn.decode_internal_eval_schedule.html">adapter::flownode_impl::decode_internal_eval_schedule</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/fn.is_explicit_source_timestamp_compatibility.html">adapter::is_explicit_source_timestamp_compatibility</a></li><li><a href="adapter/fn.output_column_schemas.html">adapter::output_column_schemas</a></li><li><a href="adapter/fn.relation_desc_from_output.html">adapter::relation_desc_from_output</a></li><li><a href="adapter/fn.resolve_sink_layout.html">adapter::resolve_sink_layout</a></li><li><a href="adapter/fn.sink_output_column_count.html">adapter::sink_output_column_count</a></li><li><a href="adapter/stateless/fn.execute.html">adapter::stateless::execute</a></li><li><a href="adapter/stateless/fn.input_provider.html">adapter::stateless::input_provider</a></li><li><a href="adapter/stateless/fn.replace_source.html">adapter::stateless::replace_source</a></li><li><a href="adapter/stateless/fn.rewrite_source_timestamp.html">adapter::stateless::rewrite_source_timestamp</a></li><li><a href="adapter/stateless/fn.synthesize_auto_values.html">adapter::stateless::synthesize_auto_values</a></li><li><a href="adapter/stateless/fn.validate_plan.html">adapter::stateless::validate_plan</a></li><li><a href="adapter/stateless/fn.validate_source_scan.html">adapter::stateless::validate_source_scan</a></li><li><a href="adapter/stateless/fn.validate_source_schema_version.html">adapter::stateless::validate_source_schema_version</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/fn.validate_auto_column_names.html">adapter::validate_auto_column_names</a></li><li><a href="adapter/fn.validate_captured_slot.html">adapter::validate_captured_slot</a></li><li><a href="adapter/fn.validate_sink_layout.html">adapter::validate_sink_layout</a></li><li><a href="adapter/fn.validate_sink_layout_with_suffix.html">adapter::validate_sink_layout_with_suffix</a></li><li><a href="fn.analyze_incremental_aggregate_plan.html">analyze_incremental_aggregate_plan</a></li><li><a href="batching_mode/checkpoint/fn.checkpoint_mode_label.html">batching_mode::checkpoint::checkpoint_mode_label</a></li><li><a href="batching_mode/engine/fn.abort_flow_task.html">batching_mode::engine::abort_flow_task</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/engine/fn.notify_flow_shutdown.html">batching_mode::engine::notify_flow_shutdown</a></li><li><a href="batching_mode/eval_schedule/fn.ceil_to_boundary.html">batching_mode::eval_schedule::ceil_to_boundary</a></li><li><a href="batching_mode/eval_schedule/fn.first_due_in_sequence.html">batching_mode::eval_schedule::first_due_in_sequence</a></li><li><a href="batching_mode/eval_schedule/fn.next_in_sequence.html">batching_mode::eval_schedule::next_in_sequence</a></li><li><a href="batching_mode/eval_schedule/fn.select_due_scheduled_times.html">batching_mode::eval_schedule::select_due_scheduled_times</a></li><li><a href="batching_mode/frontend_client/fn.build_flow_extensions.html">batching_mode::frontend_client::build_flow_extensions</a></li><li><a href="batching_mode/frontend_client/fn.wrap_standalone_output_with_terminal_metrics.html">batching_mode::frontend_client::wrap_standalone_output_with_terminal_metrics</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/table_creator/fn.build_by_sql_schema.html">batching_mode::table_creator::build_by_sql_schema</a></li><li><a href="batching_mode/table_creator/fn.build_by_tql_schema.html">batching_mode::table_creator::build_by_tql_schema</a></li><li><a href="batching_mode/table_creator/fn.build_pk_from_aggr.html">batching_mode::table_creator::build_pk_from_aggr</a></li><li><a href="batching_mode/table_creator/fn.create_table_with_expr.html">batching_mode::table_creator::create_table_with_expr</a></li><li><a href="batching_mode/task/fn.capture_recovery_batch_windows.html">batching_mode::task::capture_recovery_batch_windows</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/task/fn.encode_insert_plan_request.html">batching_mode::task::encode_insert_plan_request</a></li><li><a href="batching_mode/task/fn.format_insert_target_columns.html">batching_mode::task::format_insert_target_columns</a></li><li><a href="batching_mode/task/fn.initial_schedule_cursor.html">batching_mode::task::initial_schedule_cursor</a></li><li><a href="batching_mode/task/fn.is_merge_mode_last_non_null.html">batching_mode::task::is_merge_mode_last_non_null</a></li><li><a href="batching_mode/task/fn.recovery_aggregate_input.html">batching_mode::task::recovery_aggregate_input</a></li><li><a href="batching_mode/task/fn.scheduled_time_millis.html">batching_mode::task::scheduled_time_millis</a></li><li><a href="batching_mode/task/fn.sleep_delta_secs.html">batching_mode::task::sleep_delta_secs</a></li><li><a href="batching_mode/task/fn.wall_clock_unix_secs.html">batching_mode::task::wall_clock_unix_secs</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.inspect_time_window_plan_shape.html">batching_mode::time_window::inspect_time_window_plan_shape</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.should_skip_time_window_expr.html">batching_mode::time_window::should_skip_time_window_expr</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.analyze_incremental_aggregate_plan.html">batching_mode::utils::analyze_incremental_aggregate_plan</a></li><li><a href="batching_mode/utils/fn.build_left_join_merge_expr.html">batching_mode::utils::build_left_join_merge_expr</a></li><li><a href="batching_mode/utils/fn.build_state_delta_merge_expr.html">batching_mode::utils::build_state_delta_merge_expr</a></li><li><a href="batching_mode/utils/fn.check_input_plan_shape.html">batching_mode::utils::check_input_plan_shape</a></li><li><a href="batching_mode/utils/fn.collect_output_projection_info.html">batching_mode::utils::collect_output_projection_info</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.duplicate_names.html">batching_mode::utils::duplicate_names</a></li><li><a href="batching_mode/utils/fn.extract_incremental_aggregate.html">batching_mode::utils::extract_incremental_aggregate</a></li><li><a href="batching_mode/utils/fn.find_group_key_names.html">batching_mode::utils::find_group_key_names</a></li><li><a href="batching_mode/utils/fn.find_uncovered_output_fields.html">batching_mode::utils::find_uncovered_output_fields</a></li><li><a href="batching_mode/utils/fn.find_unsupported_group_key_projection_outputs.html">batching_mode::utils::find_unsupported_group_key_projection_outputs</a></li><li><a href="batching_mode/utils/fn.format_flow_sink_schema_mismatch.html">batching_mode::utils::format_flow_sink_schema_mismatch</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.gen_plan_with_matching_schema_and_values.html">batching_mode::utils::gen_plan_with_matching_schema_and_values</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.has_aggregate.html">batching_mode::utils::has_aggregate</a></li><li><a href="batching_mode/utils/fn.has_grouping_set.html">batching_mode::utils::has_grouping_set</a></li><li><a href="batching_mode/utils/fn.is_alias_of_group_expr.html">batching_mode::utils::is_alias_of_group_expr</a></li><li><a href="batching_mode/utils/fn.is_literal_or_cast_literal.html">batching_mode::utils::is_literal_or_cast_literal</a></li><li><a href="batching_mode/utils/fn.is_obviously_incompatible_positional_match.html">batching_mode::utils::is_obviously_incompatible_positional_match</a></li><li><a href="batching_mode/utils/fn.is_passthrough_output_column.html">batching_mode::utils::is_passthrough_output_column</a></li><li><a href="batching_mode/utils/fn.merge_op_for_aggregate_expr.html">batching_mode::utils::merge_op_for_aggregate_expr</a></li><li><a href="batching_mode/utils/fn.peel_subquery_aliases.html">batching_mode::utils::peel_subquery_aliases</a></li><li><a href="batching_mode/utils/fn.qualified_col.html">batching_mode::utils::qualified_col</a></li><li><a href="batching_mode/utils/fn.qualified_column.html">batching_mode::utils::qualified_column</a></li><li><a href="batching_mode/utils/fn.resolve_aggregate_output_fields.html">batching_mode::utils::resolve_aggregate_output_fields</a></li><li><a href="batching_mode/utils/fn.rewrite_incremental_aggregate_with_sink_merge.html">batching_mode::utils::rewrite_incremental_aggregate_with_sink_merge</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="batching_mode/utils/fn.unqualified_col.html">batching_mode::utils::unqualified_col</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="error/fn.to_status_with_last_err.html">error::to_status_with_last_err</a></li><li><a href="fn.find_time_window_expr.html">find_time_window_expr</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="fn.sql_to_df_plan.html">sql_to_df_plan</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.FlowDualEngineRef.html">FlowDualEngineRef</a></li><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="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.StateReportHandler.html">utils::StateReportHandler</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/checkpoint/constant.CHECKPOINT_DECISION_ADVANCE.html">batching_mode::checkpoint::CHECKPOINT_DECISION_ADVANCE</a></li><li><a href="batching_mode/checkpoint/constant.CHECKPOINT_DECISION_CONTINUE_REPAIR.html">batching_mode::checkpoint::CHECKPOINT_DECISION_CONTINUE_REPAIR</a></li><li><a href="batching_mode/checkpoint/constant.CHECKPOINT_DECISION_FALLBACK.html">batching_mode::checkpoint::CHECKPOINT_DECISION_FALLBACK</a></li><li><a href="batching_mode/checkpoint/constant.CHECKPOINT_REASON_NONE.html">batching_mode::checkpoint::CHECKPOINT_REASON_NONE</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="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>