Method _key

bigflow_python/python/bigflow/ptable.py:97–128 · view source on GitHub ↗

内部函数 ensure_keep_group的话，则返回至少发一条数据给reduce，确保每个group都保留着。否则，依赖于其它结点产生group。

(self, ensure_keep_group=False)

Source from the content-addressed store, hash-verified

source not stored for this graph (policy: none)

apply_key_valuesMethod · 0.95

__lt__Method · 0.80

_valueMethod · 0.95

key_serdesMethod · 0.95

process_byMethod · 0.80

allow_partial_processingMethod · 0.80

flatten_valuesMethod · 0.80

TakeProcessorMethod · 0.80

GetLastKeyProcessorMethod · 0.80

set_debug_infoMethod · 0.45

as_typeMethod · 0.45

doneMethod · 0.45

inputMethod · 0.45

nodeMethod · 0.45

no test coverage detected