MCPcopy Create free account

hub / github.com/baidu/bigflow / functions

Functions5,490 in github.com/baidu/bigflow

⨍ Functions 5,490◇ Types & classes 1,763
↓ 1 callersMethodCloseFile
flume/runtime/io/io_format.cpp:1282
↓ 1 callersMethodCloseInput
flume/runtime/common/executor_base_test.cpp:86
↓ 1 callersMethodCloseOutput
flume/runtime/common/executor_base_test.cpp:82
↓ 1 callersMethodCommit
flume/runtime/io/io_format.cpp:1149
↓ 1 callersMethodCommit
flume/runtime/platform/hadoop_client.h:90
↓ 1 callersFunctionConstructExecutorMessage
flume/runtime/local/local_input_executor_test.cpp:70
↓ 1 callersFunctionConstructLocalInputMessage
flume/runtime/local/local_input_executor_test.cpp:61
↓ 1 callersFunctionCreateLogicalExecutor
flume/runtime/executor_factory.cpp:52
↓ 1 callersFunctionCreateProcessorExecutor
flume/runtime/executor_factory.cpp:42
↓ 1 callersFunctionDefaultTempLocalPath
flume/util/config_util.cpp:64
↓ 1 callersMethodDelegate
flume/core/testing/mock_sinker.h:41
↓ 1 callersMethodDeserialize
flume/core/testing/mock_trigger.h:82
↓ 1 callersMethodDeserialize
bigflow_python/delegators/python_io_delegator.cpp:216
↓ 1 callersMethodDistributeAll
distribute all records to every buckets expressive method to set shuffle_type to BROADCAST
flume/core/logical_plan.h:622
↓ 1 callersMethodDistributeAsBatch
distribute as batch
flume/core/logical_plan.h:670
↓ 1 callersMethodDoPrepare
flume/runtime/common/entity_dag.cpp:126
↓ 1 callersMethodDoRun
flume/runtime/common/entity_dag.cpp:121
↓ 1 callersMethodDone
flume/runtime/common/cache_iterator.cpp:118
↓ 1 callersMethodDone
flume/runtime/testing/mock_dataset.h:127
↓ 1 callersMethodEmit
Gmock predicates can be used on OnEmit instead
flume/core/testing/mock_emitter.h:56
↓ 1 callersMethodEmit
flume/runtime/common/executor_base_test.cpp:78
↓ 1 callersMethodEndGroup
flume/core/testing/processor_test_helper.cpp:74
↓ 1 callersMethodEndGroup
flume/core/testing/processor_test_helper_test.cpp:68
↓ 1 callersMethodEndSubGroup
flume/runtime/common/executor_base_test.cpp:94
↓ 1 callersMethodExecute
flume/runtime/spark/spark_backend.cpp:240
↓ 1 callersMethodFilterProcessor
bigflow_python/processors/filter_processor.h:45
↓ 1 callersFunctionFindStreamTaskByPreparedType
flume/planner/monitor/add_fixed_task_unit_pass.cpp:67
↓ 1 callersFunctionFindTaskByType
flume/planner/monitor/add_fixed_task_unit_pass.cpp:55
↓ 1 callersMethodFinish
flume/runtime/common/entity_dag.cpp:604
↓ 1 callersMethodFinishGroup
flume/runtime/local/local_input_executor.cpp:58
↓ 1 callersMethodFinishGroup
flume/runtime/common/executor_impl.h:294
↓ 1 callersMethodFinishGroup
flume/runtime/common/partial_executor.cpp:179
↓ 1 callersMethodFlattenProcessor
bigflow_python/processors/flatten_processor.h:54
↓ 1 callersMethodFlush
flume/runtime/io/gzip_file.cpp:108
↓ 1 callersMethodFromProtoMessage
flume/core/entity.cpp:40
↓ 1 callersMethodFullJoinFinalizeFn
bigflow_python/functors/full_join_fn.cpp:86
↓ 1 callersMethodFullJoinTransformFn
bigflow_python/functors/full_join_fn.cpp:63
↓ 1 callersMethodGet
flume/runtime/util/object_holder.h:40
↓ 1 callersMethodGetCachedData
flume/runtime/backend.cpp:198
↓ 1 callersMethodGetCommitPath
flume/runtime/io/io_format.cpp:1213
↓ 1 callersMethodGetCommitter
flume/runtime/io/io_format.cpp:1145
↓ 1 callersMethodGetDataset
flume/runtime/common/single_dispatcher.cpp:172
↓ 1 callersMethodGetDataset
flume/runtime/common/general_dispatcher.cpp:306
↓ 1 callersMethodGetDirectNeeds
flume/planner/plan.cpp:169
↓ 1 callersMethodGetDirectUsers
flume/planner/plan.cpp:156
↓ 1 callersMethodGetLastKeyProcessor
bigflow_python/processors/get_last_key_processor.h:45
↓ 1 callersMethodGetObject
flume/util/reusable_object_pool.h:50
↓ 1 callersMethodGetReader
flume/runtime/spark/spark_cache_manager.cpp:108
↓ 1 callersMethodGetSource
flume/runtime/spark/hadoop_input_executor.cpp:69
↓ 1 callersMethodGetSource
flume/runtime/local/local_input_executor.cpp:50
↓ 1 callersMethodGetSource
flume/runtime/common/sub_executor_manager.cpp:137
↓ 1 callersMethodGetSource
flume/runtime/common/sub_executor_manager_test.cpp:92
↓ 1 callersFunctionGetTasksOfNeed
flume/planner/spark/merge_task_pass.cpp:53
↓ 1 callersFunctionGetTasksOfUser
flume/planner/spark/merge_task_pass.cpp:64
↓ 1 callersMethodGetTopologicalOrder
flume/planner/plan.cpp:136
↓ 1 callersMethodHasNext
flume/core/testing/processor_test_helper.h:65
↓ 1 callersMethodHasNext
flume/runtime/common/single_dispatcher.cpp:50
↓ 1 callersMethodHasNext
flume/runtime/common/general_dispatcher.cpp:48
↓ 1 callersMethodHasNext
flume/runtime/testing/mock_dataset.h:112
↓ 1 callersFunctionInitBigflow
bigflow_python/bigflow.cpp:34
↓ 1 callersMethodInitialize
flume/runtime/common/shuffle_runner.h:168
↓ 1 callersFunctionInserter
flume/planner/common/util.h:105
↓ 1 callersMethodIsCachedNodeIn
flume/runtime/session.cpp:52
↓ 1 callersFunctionIsMaterializedUnit
flume/planner/common/remove_useless_union_pass.cpp:42
↓ 1 callersFunctionIsNeed
flume/planner/spark/merge_task_pass.cpp:88
↓ 1 callersFunctionIsNeedOrUser
flume/planner/spark/merge_task_pass.cpp:106
↓ 1 callersMethodIsNodeCached
flume/runtime/backend.cpp:186
↓ 1 callersFunctionIsWorkerUnit
flume/planner/monitor/build_reader_writer_pass.cpp:63
↓ 1 callersFunctionJobMessageOf
flume/planner/spark/build_physical_plan_pass.cpp:43
↓ 1 callersFunctionJobMessageOf
flume/planner/monitor/build_physical_plan_pass.cpp:45
↓ 1 callersMethodKill
flume/runtime/backend.cpp:214
↓ 1 callersMethodListDynamicLibraries
flume/runtime/resource.cpp:259
↓ 1 callersMethodListJavaLibraries
flume/runtime/resource.cpp:271
↓ 1 callersMethodListPythonLibraries
flume/runtime/resource.cpp:283
↓ 1 callersMethodListSerde
bigflow_python/objectors/list_serde.h:85
↓ 1 callersMethodLoad
flume/runtime/local/local_backend_test.cpp:64
↓ 1 callersMethodLoadNode
flume/core/logical_plan.cpp:514
↓ 1 callersMethodMention
flume/util/reflection.h:165
↓ 1 callersMethodMoveTo
flume/runtime/common/shuffle_impl.h:233
↓ 1 callersMethodNewListener
flume/runtime/common/entity_dag_test.cpp:61
↓ 1 callersMethodNewRunner
flume/runtime/common/entity_dag.cpp:481
↓ 1 callersMethodNextValue
flume/core/testing/processor_test_helper.h:69
↓ 1 callersMethodNextValue
flume/runtime/common/single_dispatcher.cpp:54
↓ 1 callersMethodNextValue
flume/runtime/common/general_dispatcher.cpp:52
↓ 1 callersMethodNextValue
flume/runtime/testing/mock_dataset.h:117
↓ 1 callersMethodNextValue
bigflow_python/delegators/python_processor_delegator.cpp:62
↓ 1 callersMethodOneSideJoinFn
bigflow_python/functors/one_side_join_fn.cpp:38
↓ 1 callersMethodOpen
flume/core/testing/mock_sinker.h:60
↓ 1 callersMethodOpenFile
flume/runtime/io/io_format.cpp:1272
↓ 1 callersFunctionParseProperties
flume/util/hadoop_conf.cpp:60
↓ 1 callersFunctionParseProperty
flume/util/hadoop_conf.cpp:37
↓ 1 callersFunctionPartialEdge
flume/planner/testing/edge_desc.cpp:95
↓ 1 callersMethodPartition
flume/core/testing/string_partitioner.h:75
↓ 1 callersFunctionPbShuffleNodeTag
flume/planner/testing/tag_desc.cpp:351
↓ 1 callersMethodPipeProcessor
bigflow_python/processors/pipe_processor.cpp:592
↓ 1 callersMethodPlan
flume/planner/monitor/monitor_planner.cpp:109
↓ 1 callersMethodPlan
flume/planner/local/local_planner.cpp:203
↓ 1 callersMethodPrepare
flume/runtime/common/entity_dag.cpp:68
↓ 1 callersMethodPrepare
flume/runtime/common/entity_dag.h:124
↓ 1 callersFunctionPreparedEdge
flume/planner/testing/edge_desc.cpp:72
← previousnext →1,001–1,100 of 5,490, ranked by callers