MCPcopy Create free account

hub / github.com/baidu/bigflow / functions

Functions5,490 in github.com/baidu/bigflow

⨍ Functions 5,490◇ Types & classes 1,763
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:133
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:187
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:217
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:248
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:277
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:305
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:330
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:353
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:386
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:401
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:444
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:470
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:526
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:548
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:584
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:655
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:721
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:770
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:832
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:887
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:937
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:999
MethodAccept
flume/planner/common/add_common_executor_pass.cpp:1022
MethodAccept
flume/planner/common/side_effect_analysis.cpp:42
MethodAccept
flume/planner/common/clean_tag_rule.h:40
MethodAccept
flume/planner/common/data_flow_analysis.cpp:65
MethodAccept
flume/planner/common/session_analysis.cpp:40
MethodAccept
flume/planner/common/session_analysis.cpp:66
MethodAccept
flume/planner/common/session_analysis.cpp:80
MethodAccept
flume/planner/testing/pass_test_helper_test.cpp:37
MethodAccept
flume/planner/testing/pass_test_helper_test.cpp:62
MethodAcceptMore
flume/runtime/testing/mock_dispatcher.h:83
MethodAccumulateProcessorTest
bigflow_python/processors/accumulate_processor_test.cpp:39
MethodAcquireArena
flume/runtime/common/memory_dataset.cpp:164
MethodAcquireArena
flume/runtime/testing/mock_dataset.h:89
MethodAddClientStreamTaskUnitRule
flume/planner/monitor/add_fixed_task_unit_pass.cpp:125
MethodAddDefaultLogicalPlanNode
flume/planner/testing/plan_test_helper.cpp:196
MethodAddDirectOutput
flume/runtime/common/partial_executor_test.cpp:89
MethodAddDispatcher
flume/runtime/common/executor_base_test.cpp:248
MethodAddInput
flume/planner/testing/plan_test_helper.cpp:129
MethodAddInput
flume/runtime/common/partial_executor_test.cpp:79
MethodAddInput
flume/runtime/common/sub_executor_manager_test.cpp:146
MethodAddLeaf
flume/planner/testing/plan_test_helper.cpp:81
MethodAddLeafBelowTask
flume/planner/testing/plan_test_helper.cpp:76
MethodAddMessage
flume/planner/common/draw_plan_pass.cpp:383
MethodAddNode
flume/planner/testing/plan_test_helper.cpp:90
MethodAddNodeBelowTask
flume/planner/testing/plan_test_helper.cpp:85
MethodAddNormalFileByRename
flume/runtime/resource.cpp:206
MethodAddOutput
flume/runtime/common/partial_executor_test.cpp:129
MethodAddOutput
flume/runtime/common/sub_executor_manager_test.cpp:153
MethodAddReaderUnitRule
flume/planner/monitor/build_reader_writer_pass.cpp:108
MethodAddReference
flume/runtime/common/memory_dataset.cpp:180
MethodAddReference
flume/runtime/testing/mock_dataset.h:96
FunctionAddResourceFromBytes
flume/runtime/spark/spark_backend.cpp:79
MethodAddScopeLevel
flume/runtime/common/partial_executor_test.cpp:114
MethodAddScopeLevel
flume/runtime/common/entity_dag_test.cpp:127
MethodAddScript
flume/runtime/spark/spark_backend.cpp:230
MethodAddScript
flume/runtime/local/local_backend.cpp:196
MethodAddShuffleInput
flume/runtime/common/shuffle_runner.cpp:58
MethodAddShuffleInput
flume/runtime/common/status_shuffle_executor_test.cpp:97
MethodAddShuffleNode
flume/planner/spark/add_distribute_by_default_pass.cpp:80
MethodAddShuffleNode
flume/core/logical_plan.cpp:153
MethodAddShuffleNode
flume/runtime/common/status_shuffle_executor_test.cpp:119
MethodAddSortedOutput
flume/runtime/common/partial_executor_test.cpp:93
MethodAddSource
flume/planner/graph_helper_impl.h:214
MethodAddSourceUsage
flume/planner/graph_helper_impl.h:223
MethodAddTaskByDiff
flume/planner/task_dispatcher.cpp:130
MethodAddTaskRelations
flume/planner/task_dispatcher.cpp:114
MethodAddTasksOf
flume/planner/testing/plan_test_helper.cpp:48
MethodAddUnionUnit
flume/planner/common/split_union_unit_pass.cpp:126
MethodAddUnionUnitForProcessNode
flume/planner/common/split_union_unit_pass.cpp:107
MethodAddUnionUnitForUnionNode
flume/planner/common/split_union_unit_pass.cpp:88
MethodAddUnitByPostorder
flume/planner/depth_first_dispatcher.cpp:61
MethodAddUnitByPreorder
flume/planner/depth_first_dispatcher.cpp:54
MethodAddWorkerStreamTaskUnitRule
flume/planner/monitor/add_fixed_task_unit_pass.cpp:102
MethodAddWriterUnitRule
flume/planner/monitor/build_reader_writer_pass.cpp:164
MethodAllocate
flume/util/arena.h:62
MethodAllocateBytes
Allocate bytes from self's block
flume/util/arena.h:109
MethodAllowMassiveInstance
flume/core/logical_plan.h:511
MethodAnalyzeShouldBeSeparated
flume/planner/common/add_common_executor_pass.cpp:370
MethodAnalyzeShouldUnderPartialExecutor
flume/planner/common/add_common_executor_pass.cpp:153
MethodAndFilter
flume/planner/testing/plan_test_helper.h:140
FunctionAppendReverseOrdered
flume/util/comparable.h:52
MethodAppendToString
flume/planner/plan.cpp:182
MethodAppendToString
flume/planner/spark/spark_planner.cpp:200
MethodAppendToString
flume/planner/local/local_planner.cpp:177
MethodApply
flume/planner/pass_manager.h:452
MethodApplyPass
flume/planner/testing/plan_test_helper.h:539
MethodApplyPassRegister
flume/planner/pass_manager.h:323
MethodApplyRepeatedly
flume/planner/pass_manager.h:459
MethodApplySessionAnalysis
flume/planner/common/session_analysis_test.cpp:73
MethodArena
flume/util/arena.cpp:33
MethodArray
flume/runtime/common/sub_executor_manager_test.cpp:170
MethodAs
flume/core/logical_plan.h:364
MethodAs
flume/core/logical_plan.h:493
MethodAs
flume/core/logical_plan.h:544
MethodAsInput
flume/runtime/common/entity_dag_test.cpp:81
MethodAsKey
flume/runtime/common/local_dataset.cpp:422
MethodAsValue
flume/runtime/common/local_dataset.h:106
FunctionBOOST_FOREACH
first apply passes who are immune from other passes
flume/planner/pass_manager.cpp:181
← previousnext →1,701–1,800 of 5,490, ranked by callers