hub / github.com/baidu/bigflow / as_schema

Method as_schema

bigflow_python/python/bigflow/pcollection.py:675–724 · view source on GitHub ↗

根据字段，返回一个SchemaPCollection Args: fields: 类型可以是，tuple，list，dict；当fields是tuple或list时, 会判断每个元素的类型： fields中的每个元素是python基本类型或一个serde；接口将构造TupleSerde设置到PCollection每个元素 fields中的每个元素是python string，抛出

(self, fields)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

Callers 2

test_concurrencyMethod · 0.80

test_as_schemaMethod · 0.80

Calls 3

mapMethod · 0.95

default_objectorMethod · 0.80

ofMethod · 0.45

Tested by 2

test_concurrencyMethod · 0.64

test_as_schemaMethod · 0.64