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 callersMethodProcess
flume/core/testing/processor_test_helper.cpp:70
↓ 1 callersMethodProcess
flume/core/testing/processor_test_helper_test.cpp:62
↓ 1 callersMethodProcessNode
flume/core/logical_plan.cpp:538
↓ 1 callersMethodPythonTimeReaderDelegator
bigflow_python/delegators/python_time_reader_delegator.cpp:82
↓ 1 callersFunctionRead
flume/runtime/common/memory_status_table_test.cpp:110
↓ 1 callersMethodReadKey
flume/core/testing/mock_key_reader.h:68
↓ 1 callersMethodRelease
flume/core/testing/string_objector.h:48
↓ 1 callersMethodRelease
flume/runtime/testing/fake_objector.h:62
↓ 1 callersMethodRelease
flume/util/cached_allocator.h:54
↓ 1 callersMethodRelease
bigflow_python/delegators/python_io_delegator.cpp:221
↓ 1 callersMethodRemoveFactory
flume/util/reflection.h:203
↓ 1 callersMethodReserve
flume/runtime/util/serialize_buffer.h:156
↓ 1 callersMethodReset
flume/core/testing/processor_test_helper.h:73
↓ 1 callersMethodReset
flume/runtime/counter.cpp:43
↓ 1 callersMethodReset
flume/runtime/spark/spark_cache_iterator.cpp:100
↓ 1 callersMethodReset
flume/runtime/common/local_dataset.cpp:53
↓ 1 callersMethodReset
flume/runtime/common/shuffle_runner.h:358
↓ 1 callersMethodReset
bigflow_python/delegators/python_processor_delegator.cpp:71
↓ 1 callersMethodReuse
flume/util/intrusive_ptr_base.h:46
↓ 1 callersMethodRun
flume/planner/spark/add_cache_task_pass.cpp:97
↓ 1 callersMethodRun
flume/planner/spark/add_task_unit_pass.cpp:102
↓ 1 callersMethodRun
flume/planner/spark/add_distribute_by_default_pass.cpp:150
↓ 1 callersMethodRun
flume/planner/common/scope_analysis.cpp:118
↓ 1 callersMethodRun
flume/runtime/common/entity_dag.cpp:76
↓ 1 callersMethodRun
flume/util/process_launcher.cpp:72
↓ 1 callersMethodRunAndWaitExit
flume/util/process_launcher.cpp:53
↓ 1 callersMethodRunLocally
flume/core/logical_plan.cpp:113
↓ 1 callersMethodScopeStack
flume/core/logical_plan.cpp:251
↓ 1 callersMethodSerialize
flume/planner/common/cache_util.cpp:41
↓ 1 callersMethodSerialize
flume/core/testing/mock_trigger.h:80
↓ 1 callersMethodSerialize
bigflow_python/delegators/python_io_delegator.cpp:206
↓ 1 callersFunctionSessionEquals
flume/runtime/session_test.cpp:47
↓ 1 callersMethodSetCacheArchiveList
flume/runtime/resource.cpp:349
↓ 1 callersMethodSetCacheFileList
flume/runtime/resource.cpp:353
↓ 1 callersMethodSetDataset
flume/runtime/common/single_dispatcher.cpp:45
↓ 1 callersMethodSetDebugDirectory
flume/planner/monitor/monitor_planner.cpp:105
↓ 1 callersFunctionSetNodePrepared
flume/planner/monitor/prepared_node_basic_analysis.cpp:37
↓ 1 callersMethodSetRange
flume/runtime/testing/mock_source.h:48
↓ 1 callersMethodSetStatusTable
flume/runtime/common/processor_executor.cpp:223
↓ 1 callersMethodSetup
flume/runtime/local/local_input_executor.cpp:46
↓ 1 callersMethodSetup
flume/runtime/common/executor_base_test.cpp:198
↓ 1 callersMethodSetup
flume/runtime/common/executor_impl_test.cpp:508
↓ 1 callersMethodSetup
flume/runtime/common/partial_executor_test.cpp:168
↓ 1 callersMethodSetup
flume/runtime/common/executor_impl.h:267
↓ 1 callersMethodSetup
flume/runtime/common/general_dispatcher.cpp:43
↓ 1 callersMethodSetup
bigflow_python/delegators/python_io_delegator.cpp:171
↓ 1 callersMethodSetup
bigflow_python/common/barshal_objector.h:45
↓ 1 callersMethodSink
flume/runtime/io/io_format.cpp:1071
↓ 1 callersMethodSinkNode
flume/core/logical_plan.cpp:527
↓ 1 callersMethodSourcesFromParentTo
flume/planner/local/local_planner_test.cpp:113
↓ 1 callersFunctionSparkTaskType
flume/planner/spark/testing/testing_helper.cpp:55
↓ 1 callersMethodSplit
if splits is empty, use api default concurrency
flume/core/sinker.h:52
↓ 1 callersMethodSplit
flume/runtime/local/local_backend_test.cpp:59
↓ 1 callersMethodStop
flume/util/process_launcher.cpp:144
↓ 1 callersMethodSuspend
flume/runtime/backend.cpp:210
↓ 1 callersMethodSynchronize
TODO(wenxiang): add '= 0' after all users implements this interface
flume/core/processor.h:50
↓ 1 callersMethodTerminate
flume/util/process_launcher.cpp:148
↓ 1 callersMethodTransformProcessor
bigflow_python/processors/transform_processor.cpp:41
↓ 1 callersMethodValue
flume/util/reflection_test.cpp:205
↓ 1 callersMethodValueStr
flume/runtime/common/cache_iterator.cpp:130
↓ 1 callersMethod__add_shuffle_node
(self, source_node, target_scope)
bigflow_python/python/bigflow/core/logical_plan.py:968
↓ 1 callersMethod__append_cache_archive
(self, file_path, resource_path)
bigflow_python/python/bigflow/pipeline/spark_pipeline.py:363
↓ 1 callersMethod__append_cache_file
(self, file_path, resource_path, executable=False)
bigflow_python/python/bigflow/pipeline/spark_pipeline.py:348
↓ 1 callersMethod__init__
(self, fn)
bigflow_python/python/bigflow/transform_impls/processor.py:35
↓ 1 callersMethod__init_server
(self, path=None, params=[], port=None)
bigflow_python/python/bigflow/rpc/service.py:123
↓ 1 callersFunction__left_join_in_every_group
(*pcollections, **options)
bigflow_python/python/bigflow/transform_impls/join.py:45
↓ 1 callersMethod__set_distribute_every
(self, distribute_every=True)
bigflow_python/python/bigflow/core/logical_plan.py:794
↓ 1 callersMethod__wait_for_server_port
(self)
bigflow_python/python/bigflow/rpc/service.py:192
↓ 1 callersMethod__wrap
(self, transform)
bigflow_python/python/bigflow/user_defined_functions.py:79
↓ 1 callersMethod_add_bigflow_path
(self)
bigflow_python/python/bigflow/pipeline/pipeline_base.py:396
↓ 1 callersMethod_add_remote_file
add remote file for local pipeline 生成hadoop命令来下载文件 Args: file_path (str): 文件路径 resource_path (str): 运行期访问该文件的路径
bigflow_python/python/bigflow/pipeline/local_pipeline.py:199
↓ 1 callersMethod_after_run
(self)
bigflow_python/python/bigflow/pipeline/spark_pipeline.py:462
↓ 1 callersMethod_after_run
(self)
bigflow_python/python/bigflow/pipeline/pipeline_base.py:484
↓ 1 callersMethod_before_run
(self)
bigflow_python/python/bigflow/pipeline/local_pipeline.py:273
↓ 1 callersMethod_before_run
(self)
bigflow_python/python/bigflow/pipeline/spark_pipeline.py:402
↓ 1 callersMethod_delete_local_temp_files
force delete the local temp files
bigflow_python/python/bigflow/pipeline/pipeline_base.py:620
↓ 1 callersMethod_delete_remote_temp_files
force delete the remote temp files
bigflow_python/python/bigflow/pipeline/spark_pipeline.py:525
↓ 1 callersFunction_flatten_once
(node, key_serde, value_serde)
bigflow_python/python/bigflow/transform_impls/flatten.py:34
↓ 1 callersMethod_generate_op_handlers
(self)
bigflow_python/python/bigflow/pobject.py:174
↓ 1 callersMethod_generate_plan_message
(self)
bigflow_python/python/bigflow/pipeline/pipeline_base.py:562
↓ 1 callersMethod_generate_resource_message
(self)
bigflow_python/python/bigflow/pipeline/pipeline_base.py:565
↓ 1 callersFunction_get_all
get the counter dict include all counters. Group name is prepended to the key in the return dict if grouped is False. :param grouped: bo
bigflow_python/python/bigflow/counter.py:91
↓ 1 callersMethod_get_async_mode
(self, **options)
bigflow_python/python/bigflow/output.py:53
↓ 1 callersMethod_get_async_mode
(self, **options)
bigflow_python/python/bigflow/output.py:94
↓ 1 callersMethod_get_bigflow_python_home
(self)
bigflow_python/python/bigflow/pipeline/spark_pipeline.py:414
↓ 1 callersMethod_get_cached_data
(self)
bigflow_python/python/bigflow/ptype.py:129
↓ 1 callersFunction_get_col
(index)
bigflow_python/python/bigflow/schema.py:136
↓ 1 callersMethod_get_default_job_name
inner function
bigflow_python/python/bigflow/pipeline/pipeline_base.py:89
↓ 1 callersFunction_get_dict
内部函数
bigflow_python/python/bigflow/schema.py:708
↓ 1 callersFunction_get_field
(field)
bigflow_python/python/bigflow/schema.py:116
↓ 1 callersFunction_get_field
(field)
bigflow_python/python/bigflow/future/fields.py:92
↓ 1 callersMethod_get_fs_conf
get fs.defaultFS and hadoop.job.ugi as tuple
bigflow_python/python/bigflow/pipeline/pipeline_base.py:596
↓ 1 callersMethod_get_hadoop_config_path_for_unit_test
(self)
bigflow_python/python/bigflow/test/test_base.py:187
↓ 1 callersFunction_get_key_dict
内部函数
bigflow_python/python/bigflow/schema.py:692
↓ 1 callersFunction_get_line_number
()
bigflow_python/python/bigflow/util/decorators.py:40
↓ 1 callersMethod_get_tmp_data_path_for_unit_test
(self)
bigflow_python/python/bigflow/test/test_base.py:174
↓ 1 callersMethod_get_tuple_serde
内部函数
bigflow_python/python/bigflow/schema.py:63
↓ 1 callersMethod_handle_new_writtens
(self)
bigflow_python/python/bigflow/pipeline/pipeline_base.py:505
↓ 1 callersMethod_handle_serialized_exception
(self)
bigflow_python/python/bigflow/pipeline/local_pipeline.py:238
↓ 1 callersMethod_handle_serialized_exception
(self)
bigflow_python/python/bigflow/pipeline/spark_pipeline.py:502
← previousnext →1,101–1,200 of 5,490, ranked by callers