MCPcopy Create free account

hub / github.com/baidu/bigflow / functions

Functions5,490 in github.com/baidu/bigflow

⨍ Functions 5,490◇ Types & classes 1,763
↓ 2 callersFunctionNest
flume/planner/common/draw_plan_pass.cpp:67
↓ 2 callersFunctionNewArena
flume/runtime/common/memory_dataset.cpp:41
↓ 2 callersFunctionNewTagDesc
flume/planner/testing/tag_desc.h:85
↓ 2 callersMethodNextValue
flume/runtime/testing/mock_source.h:57
↓ 2 callersMethodNextValue
bigflow_python/common/iterator.h:41
↓ 2 callersFunctionNodeIdCollectionEquals
flume/runtime/session_test.cpp:32
↓ 2 callersMethodOpen
flume/runtime/io/io_format.cpp:1030
↓ 2 callersMethodOpen
flume/runtime/common/testing/cache_sinker.cpp:88
↓ 2 callersFunctionParseFromBytes
flume/runtime/spark/jni/jni_task.cpp:74
↓ 2 callersMethodPartition
flume/planner/common/cache_util.cpp:112
↓ 2 callersMethodPlan
flume/planner/plan.cpp:35
↓ 2 callersMethodPrepareAtLeast
flume/core/logical_plan.h:501
↓ 2 callersMethodPrepareBeforeProcessing
flume/core/logical_plan.h:448
↓ 2 callersMethodProcess
bigflow_python/processors/processor.h:222
↓ 2 callersFunctionPushBack
flume/runtime/common/write_cache_executor_test.cpp:55
↓ 2 callersMethodReduceProcessor
bigflow_python/processors/reduce_processor.h:46
↓ 2 callersMethodRegisterFactory
flume/util/reflection.h:198
↓ 2 callersMethodRelease
flume/planner/common/cache_util.cpp:90
↓ 2 callersMethodReset
bigflow_python/common/iterator.h:45
↓ 2 callersMethodResource
flume/runtime/resource.cpp:37
↓ 2 callersMethodRun
flume/planner/spark/set_default_concurrency_pass.cpp:156
↓ 2 callersMethodRun
flume/planner/common/executor_dependency_analysis.cpp:162
↓ 2 callersMethodRun
flume/planner/common/draw_plan_pass.cpp:393
↓ 2 callersMethodSelectElementsProcessor
bigflow_python/processors/select_elements_processor.h:47
↓ 2 callersMethodSerialize
flume/runtime/testing/fake_objector.h:48
↓ 2 callersMethodSet
flume/planner/testing/tag_desc.h:88
↓ 2 callersMethodSetDebugDirectory
flume/planner/spark/spark_planner.cpp:219
↓ 2 callersMethodSetup
flume/runtime/spark/cache_input_executor.cpp:92
↓ 2 callersMethodSetup
bigflow_python/processors/processor.h:173
↓ 2 callersMethodShuffleNode
flume/core/logical_plan.cpp:592
↓ 2 callersMethodSink
flume/runtime/common/testing/cache_sinker.cpp:98
↓ 2 callersMethodSort
flume/core/logical_plan.h:216
↓ 2 callersMethodSplitStringToTypes
bigflow_python/functors/split_string_to_types.cpp:32
↓ 2 callersFunctionStripKeyProcessorEntity
flume/planner/common/cache_util.h:149
↓ 2 callersMethodTest
flume/planner/testing/tag_desc.h:92
↓ 2 callersFunctionThrowException
flume/runtime/spark/jni_util/util.cpp:50
↓ 2 callersMethodToString
flume/runtime/testing/mock_listener.h:105
↓ 2 callersMethodUnionNode
flume/core/logical_plan.cpp:571
↓ 2 callersMethod__get_dict_from_keys
(root, keys)
bigflow_python/python/bigflow/ptable.py:356
↓ 2 callersMethod__init__
(self, key)
bigflow_python/python/bigflow/transform_impls/sort.py:49
↓ 2 callersMethod__setstate__
避免参与反序列化
bigflow_python/python/bigflow/pipeline/pipeline_base.py:640
↓ 2 callersMethod_add_dynamic_library_in_path
(self, lib_dir)
bigflow_python/python/bigflow/pipeline/pipeline_base.py:513
↓ 2 callersFunction_basic_log
(fn, result, *args, **kwargs)
bigflow_python/python/bigflow/util/decorators.py:43
↓ 2 callersMethod_force_delete_file
(self, path)
bigflow_python/python/bigflow/pipeline/pipeline_base.py:544
↓ 2 callersFunction_get_serde_of_fields
内部函数
bigflow_python/python/bigflow/schema.py:104
↓ 2 callersMethod_hadoop_client
(self)
bigflow_python/python/bigflow/pipeline/pipeline_base.py:537
↓ 2 callersMethod_is_readable
(self)
bigflow_python/python/bigflow/ptype.py:125
↓ 2 callersMethod_load_schema_data_by_parallelize
(self)
bigflow_python/python/bigflow/test/schema_advance_test.py:36
↓ 2 callersFunction_pack_udf
内部函数
bigflow_python/python/bigflow/schema.py:335
↓ 2 callersFunction_ret_dict_handler
内部函数
bigflow_python/python/bigflow/schema.py:614
↓ 2 callersFunction_ret_tuple_handler
内部函数
bigflow_python/python/bigflow/schema.py:647
↓ 2 callersFunction_safe_unicode
Converts any given object to unicode string. >>> safeunicode('hello') u'hello' >>> safeunicode(2) u'2' >
bigflow_python/python/bigflow/util/log.py:51
↓ 2 callersFunction_select_fields
内部函数
bigflow_python/python/bigflow/schema.py:526
↓ 2 callersFunction_serde_to_string
(serde)
bigflow_python/python/bigflow/transform_impls/sort.py:83
↓ 2 callersMethod_set_exception_path
(self)
bigflow_python/python/bigflow/pipeline/pipeline_base.py:646
↓ 2 callersMethod_test_count
test count
bigflow_python/python/bigflow/test/pcollection_test.py:109
↓ 2 callersMethod_test_distinct
test distinct
bigflow_python/python/bigflow/test/pcollection_test.py:113
↓ 2 callersMethod_tmp_output_path
(self, uri)
bigflow_python/python/bigflow/pipeline/pipeline_base.py:532
↓ 2 callersMethod_toft_path
(self, path)
bigflow_python/python/bigflow/pipeline/pipeline_base.py:529
↓ 2 callersFunction_transform_with_fns
pcollection transform
bigflow_python/python/bigflow/transform_impls/transform.py:28
↓ 2 callersMethod_use_dce_combine
(self, options)
bigflow_python/python/bigflow/input.py:225
↓ 2 callersMethodaccept
(self, line)
bigflow_python/python/bigflow/rpc/backend_parser.py:43
↓ 2 callersMethodadd_father
(self, father)
bigflow_python/python/bigflow/core/tests/test_helper.py:179
↓ 2 callersMethodadd_stdout_listener
(self, fn)
bigflow_python/python/bigflow/util/process_util.py:51
↓ 2 callersMethodadd_variable_length_key
flume/runtime/common/transfer_encoding_test.cpp:87
↓ 2 callersMethodallocate_count
flume/util/cached_allocator.h:94
↓ 2 callersMethodappend_debug_info
this debug infos will be appended at the end of the debug info
bigflow_python/python/bigflow/core/logical_plan.py:288
↓ 2 callersMethodapply_key_values
将Key和Value做一个变换 Args: transform (function): 变换函数 *side_inputs: 参与计算的SideInputs **options: 可配置选项
bigflow_python/python/bigflow/ptable.py:212
↓ 2 callersMethodas_list
bigflow_python/common/side_input.cpp:50
↓ 2 callersMethodas_type
通过kv_serializer将数据序列化为(Key, Value) Args: kv_serializer (callable): 序列化函数 Returns: SequenceFile: 返回sel
bigflow_python/python/bigflow/output.py:387
↓ 2 callersMethodcheck_parallelize
no comment
bigflow_python/python/bigflow/pipeline/test/pipeline_test.py:383
↓ 2 callersMethodclear
flume/util/bitset.h:151
↓ 2 callersMethodclear_result
bigflow_python/functors/py_functor_caller.cpp:48
↓ 2 callersMethodclose_prior_outputs
flume/runtime/common/executor_impl.h:345
↓ 2 callersMethodclose_prior_outputs
flume/runtime/common/shuffle_executor.h:230
↓ 2 callersMethodcombine_with
(self, node)
bigflow_python/python/bigflow/core/logical_plan.py:263
↓ 2 callersFunctionconcat_record
flume/runtime/common/file_cache_manager_test.cpp:67
↓ 2 callersFunctionconcat_record
flume/runtime/common/cache_iterator_test.cpp:70
↓ 2 callersMethodconfig
return config
bigflow_python/python/bigflow/core/entity.py:146
↓ 2 callersFunctioncp_object
bigflow_python/common/barshal_objector.cpp:214
↓ 2 callersFunctioncp_pstring
bigflow_python/common/barshal_objector.cpp:174
↓ 2 callersFunctioncp_short
bigflow_python/common/barshal_objector.cpp:112
↓ 2 callersFunctioncp_string
bigflow_python/common/barshal_objector.cpp:166
↓ 2 callersMethodcreate
根据用户所指定的后端引擎类型以及基本配置构造一个Pipeline实例 Args: pipeline_type (str): 指定Pipeline类型，目前支持``"local"``和``"hadoop"`` **job_c
bigflow_python/python/bigflow/base.py:71
↓ 2 callersMethodcurrent_scope_level
flume/runtime/common/executor_impl.h:59
↓ 2 callersMethoddebug_info
(self)
bigflow_python/python/bigflow/core/logical_plan.py:165
↓ 2 callersMethoddecoder
flume/runtime/common/transfer_encoding_test.cpp:133
↓ 2 callersMethoddefault_encoding_check
(self, encoding)
bigflow_python/python/bigflow/pipeline/test/pipeline_test.py:686
↓ 2 callersMethoddeserialize
deserialize
bigflow_python/python/bigflow/future/fields.py:49
↓ 2 callersFunctiondict_of
Return an optional dict serde
bigflow_python/python/bigflow/serde.py:761
↓ 2 callersMethoddone
flume/runtime/common/executor_impl.h:211
↓ 2 callersMethoddump
(self, obj)
bigflow_python/python/bigflow/core/serde/cloudpickle.py:131
↓ 2 callersFunctionenable_pretty_logging
Turns on formatted logging output as configured.
bigflow_python/python/bigflow/util/log.py:204
↓ 2 callersMethodencode
flume/runtime/common/transfer_encoding.cpp:257
↓ 2 callersMethodencode
flume/runtime/common/transfer_encoding_test.cpp:207
↓ 2 callersMethodencoder
flume/runtime/common/transfer_encoding_test.cpp:99
↓ 2 callersMethodextract_keys
提取给定PTable中所有的key，等价于 ``transforms.extract_keys(self, options)`` Args: **options: 可配置选项 Returns: PColle
bigflow_python/python/bigflow/ptable.py:160
↓ 2 callersMethodextract_values
提取给定PTable中所有的value，等价于 ``transforms.extract_values(self, options)`` Args: **options: 可配置选项 Returns: P
bigflow_python/python/bigflow/ptable.py:171
↓ 2 callersFunctionf
(num)
test/src/generator/pyspark_group_top_n.py:23
↓ 2 callersMethodfinalize_interpreter
bigflow_python/python_interpreter.cpp:167
← previousnext →801–900 of 5,490, ranked by callers