MCPcopy Create free account

hub / github.com/baidu/bigflow / functions

Functions5,490 in github.com/baidu/bigflow

⨍ Functions 5,490◇ Types & classes 1,763
↓ 4 callersMethodrun
flume/runtime/spark/spark_job.cpp:160
↓ 4 callersMethodserde_eq
inner
bigflow_python/python/bigflow/test/serde_test.py:271
↓ 4 callersMethodserialize
flume/runtime/io/io_format.cpp:278
↓ 4 callersMethodserialize
serialize
bigflow_python/python/bigflow/test/serde_test.py:45
↓ 4 callersMethodset_infinite
flume/core/logical_plan.h:262
↓ 4 callersMethodsetup
flume/runtime/io/io_format.cpp:209
↓ 4 callersMethodsetup
flume/runtime/common/executor_impl.cpp:96
↓ 4 callersMethodsetup
bigflow_python/processors/pipe_processor.cpp:246
↓ 4 callersMethodsize
flume/runtime/util/serialize_buffer.h:112
↓ 4 callersFunctionto_piece
flume/runtime/common/file_cache_manager_test.cpp:56
↓ 4 callersMethodto_ulong
flume/util/bitset.h:358
↓ 4 callersMethodtype
(self)
bigflow_python/python/bigflow/core/logical_plan.py:156
↓ 4 callersMethodwrite
flume/runtime/common/transfer_encoding_test.cpp:165
↓ 3 callersMethodAddFileWithExecutePermission
flume/runtime/resource.cpp:304
↓ 3 callersMethodAddNormalFile
flume/runtime/resource.cpp:190
↓ 3 callersFunctionAddTaskByType
flume/planner/monitor/add_fixed_task_unit_pass.cpp:79
↓ 3 callersFunctionAssignTargetTask
flume/planner/spark/merge_task_pass.cpp:75
↓ 3 callersFunctionBasicMessageForLogicalExecutor
flume/runtime/executor_factory_test.cpp:70
↓ 3 callersMethodBeginGroup
flume/runtime/spark/cache_input_executor.cpp:99
↓ 3 callersMethodBeginGroup
flume/runtime/common/partial_executor_test.cpp:185
↓ 3 callersMethodBeginKeys
flume/runtime/spark/spark_cache_manager.cpp:59
↓ 3 callersMethodBeginSubGroup
flume/runtime/common/executor_base.cpp:194
↓ 3 callersFunctionBuildLogicalDag
flume/planner/graph_helper.h:44
↓ 3 callersMethodCache
flume/core/logical_plan.h:319
↓ 3 callersFunctionCacheEffectiveKeyNum
flume/planner/spark/testing/testing_helper.cpp:110
↓ 3 callersMethodClone
flume/runtime/session.cpp:87
↓ 3 callersMethodClose
flume/runtime/common/entity_dag.cpp:107
↓ 3 callersMethodCommitWithArgs
flume/runtime/platform/hadoop_client.cpp:58
↓ 3 callersFunctionCreateStatusShuffleCore
flume/runtime/common/status_shuffle_executor.cpp:103
↓ 3 callersMethodDeserialize
bigflow_python/common/barshal_objector.cpp:315
↓ 3 callersMethodDistributeByDefault
distribute each record to arbitrary bucket expressive method to set shuffle_type to SEQUENCE
flume/core/logical_plan.h:630
↓ 3 callersMethodDistributeInto
flume/core/logical_plan.h:743
↓ 3 callersMethodDone
flume/runtime/common/processor_executor.cpp:180
↓ 3 callersMethodDone
bigflow_python/common/iterator.h:49
↓ 3 callersMethodDraw
flume/planner/testing/pass_test_helper.cpp:65
↓ 3 callersMethodEndKeys
flume/runtime/spark/spark_cache_manager.cpp:92
↓ 3 callersFunctionEscapeLabel
flume/planner/common/draw_plan_pass.cpp:82
↓ 3 callersMethodFinishGroup
flume/runtime/spark/cache_input_executor.cpp:103
↓ 3 callersMethodFinishGroup
flume/runtime/common/partial_executor_test.cpp:189
↓ 3 callersMethodGetCacheArchiveList
flume/runtime/resource.cpp:357
↓ 3 callersMethodGetCacheFileList
flume/runtime/resource.cpp:361
↓ 3 callersMethodGetOutput
flume/runtime/common/executor_base.cpp:189
↓ 3 callersMethodGetSource
flume/runtime/common/partial_executor.cpp:168
↓ 3 callersMethodGetSplits
flume/runtime/common/file_cache_manager.cpp:104
↓ 3 callersFunctionGetUnNamedType
flume/util/reflection_test_helper.cpp:48
↓ 3 callersMethodHasNext
flume/runtime/testing/mock_source.h:53
↓ 3 callersMethodInvalidate
flume/runtime/common/memory_status_table.cpp:78
↓ 3 callersMethodIsCoverBy
flume/core/logical_plan.cpp:243
↓ 3 callersMethodListEntries
flume/runtime/resource_test.cpp:67
↓ 3 callersMethodMakeIterator
flume/runtime/testing/mock_status_table.h:47
↓ 3 callersFunctionMakeKeys
flume/runtime/testing/mock_executor_base.h:52
↓ 3 callersFunctionNewDatasetCore
flume/runtime/common/memory_dataset.cpp:56
↓ 3 callersMethodRead
flume/runtime/io/gzip_file.cpp:123
↓ 3 callersFunctionRecord
flume/runtime/common/write_cache_executor_test.cpp:83
↓ 3 callersMethodRelease
release resources hold by object
bigflow_python/processors/flatten_processor_test.cpp:60
↓ 3 callersFunctionRemoveHDFSPrefix
hdfs://host:port/xx => /xx hdfs:///xx => /xx /xx => /xx
flume/util/config_util.cpp:71
↓ 3 callersMethodReset
flume/runtime/common/general_dispatcher.cpp:57
↓ 3 callersMethodReset
flume/util/arena.cpp:68
↓ 3 callersMethodRun
flume/planner/rule_dispatcher.cpp:29
↓ 3 callersMethodRun
flume/planner/common/promote_partial_process_pass.cpp:150
↓ 3 callersMethodRun
flume/planner/common/build_executor_message_pass.cpp:194
↓ 3 callersMethodScope
flume/core/logical_plan.cpp:233
↓ 3 callersFunctionScopeLevelTag
flume/planner/testing/tag_desc.cpp:408
↓ 3 callersMethodSerialize
bigflow_python/common/barshal_objector.cpp:304
↓ 3 callersFunctionSetNodePrepared
flume/planner/monitor/prepared_node_analysis.cpp:37
↓ 3 callersMethodSetup
flume/core/empty_environment.cpp:28
↓ 3 callersFunctionStage
flume/planner/testing/tag_desc.cpp:431
↓ 3 callersFunctionToPiece
flume/runtime/common/write_cache_executor_test.cpp:78
↓ 3 callersMethodToPointer
flume/util/type_guard.h:56
↓ 3 callersMethodToString
flume/core/entity_test.cpp:71
↓ 3 callersMethod__init__
(self, path, **options)
bigflow_python/python/bigflow/output.py:167
↓ 3 callersMethod__inner_most_value
(self)
bigflow_python/python/bigflow/ptable.py:339
↓ 3 callersFunction_build_combine_node
(from_node, is_partial, size, scale)
bigflow_python/python/bigflow/transform_impls/combine.py:47
↓ 3 callersMethod_compare_expect_data_and_output
(self, expect_data, output_path)
bigflow_python/python/bigflow/test/write_binary_test.py:38
↓ 3 callersMethod_get_fields
内部函数
bigflow_python/python/bigflow/schema_pcollection.py:69
↓ 3 callersFunction_get_none_dict
内部函数
bigflow_python/python/bigflow/schema.py:706
↓ 3 callersFunction_get_opt
(name)
bigflow_python/python/bigflow/transform_impls/join.py:113
↓ 3 callersFunction_get_serde_of_field
内部函数
bigflow_python/python/bigflow/schema.py:97
↓ 3 callersMethod_load_data_by_parallelize
(self)
bigflow_python/python/bigflow/test/schema_advance_test.py:51
↓ 3 callersFunction_none_to_dict
内部函数
bigflow_python/python/bigflow/schema.py:720
↓ 3 callersFunction_origin_serde
内部函数
bigflow_python/python/bigflow/schema.py:127
↓ 3 callersMethod_path_exists
(self, path)
bigflow_python/python/bigflow/pipeline/pipeline_base.py:557
↓ 3 callersFunction_str_to_list
内部函数
bigflow_python/python/bigflow/schema.py:174
↓ 3 callersMethodadd_directory
Add a directory recursively to be packed with the job at runtime. Args: dir_path (str): path of directory to add
bigflow_python/python/bigflow/runtime/python_resource.py:122
↓ 3 callersMethodadd_egg_file
Add an .egg file to be packed with the job and set its path to PYTHONPATH at runtime Args: file_path (str): path of .egg
bigflow_python/python/bigflow/runtime/python_resource.py:98
↓ 3 callersMethodadd_egg_file
向Pipeline添加一个egg文件，使得该文件会在运行期自动被添加到PYTHONPATH中 Args: file_path (str): egg文件路径
bigflow_python/python/bigflow/pipeline/pipeline_base.py:137
↓ 3 callersMethodadd_file_from_bytes
Add a single file to be packed with the job at runtime. Args: source_bytes (str): the source binaries resource_
bigflow_python/python/bigflow/runtime/python_resource.py:76
↓ 3 callersMethodadd_tailing_key
flume/runtime/common/transfer_encoding_test.cpp:93
↓ 3 callersFunctionatom_file_put_contents
bigflow_python/common/python.cpp:287
↓ 3 callersMethodcombine
flume/runtime/common/split_combiner.cpp:41
↓ 3 callersMethodcombine
等同于 :func:`bigflow.transforms.combine(self, fn) <bigflow.transforms.combine>` Args: fn (callable): 合并函数 **optio
bigflow_python/python/bigflow/pcollection.py:112
↓ 3 callersMethodcontent
flume/runtime/spark/shuffle_protocol.h:56
↓ 3 callersMethoddone
bigflow_python/processors/processor.cpp:124
↓ 3 callersMethodeffective_key_num
flume/core/logical_plan.h:475
↓ 3 callersMethodemitter
bigflow_python/processors/processor.cpp:116
↓ 3 callersFunctionfilter
Filter transform implementation :param pvalue: PType :param fn: UDF :param side_inputs: SideInputs :return: PType after filter
bigflow_python/python/bigflow/transform_impls/filter.py:29
↓ 3 callersMethodfrom_node
(self, index)
bigflow_python/python/bigflow/core/logical_plan.py:403
↓ 3 callersMethodfs_put
Wraps console command 'hadoop fs -put <source> <target>' Args: source (str): path of source target (str): path
bigflow_python/python/bigflow/util/hadoop_client.py:93
↓ 3 callersMethodget_toft_style_path
bigflow_python/rpc/impls/get_toft_style_path_impl.h:30
↓ 3 callersMethodgroup_by
对元素分组，等同于 :func:`bigflow.transforms.group_by(self, key_extractor, value_extractor) <bigflow.transforms.group_by>` Ar
bigflow_python/python/bigflow/pcollection.py:231
← previousnext →601–700 of 5,490, ranked by callers