Method get

bigflow_python/python/bigflow/pipeline/pipeline_base.py:349–360 · view source on GitHub ↗

将一个P类型表示的数据汇聚为内存变量，相当于调用pvalue.get()。改方法隐式调用pvalue.cache() 并立即触发Pipeline.run() Args: pvalue (PType): P类型实例 Returns: object: 内存变量

(self, pvalue)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

__init__Method · 0.45

parallelizeMethod · 0.45

_get_fs_confMethod · 0.45

wait_statusMethod · 0.45

test_normalMethod · 0.45

test_multi_inputMethod · 0.45

test_side_inputMethod · 0.45

test_in_apply_valuesMethod · 0.45

test_overwriteMethod · 0.45

test_add_fileMethod · 0.45

test_add_directoryMethod · 0.45

test_add_directory_with_hidden_pathMethod · 0.45

no outgoing calls

test_normalMethod · 0.36

test_multi_inputMethod · 0.36

test_side_inputMethod · 0.36

test_in_apply_valuesMethod · 0.36

test_overwriteMethod · 0.36

test_add_fileMethod · 0.36

test_add_directoryMethod · 0.36

test_add_directory_with_hidden_pathMethod · 0.36

test_cacheMethod · 0.36

test_seqfileMethod · 0.36

test_seq_file_new_apiMethod · 0.36

test_partitionMethod · 0.36