Has same interface as boost::dynamic_bitset<>

left default value 0 as invalid value

indicate this unit is already 'claimed' by its father, so no extra unit is needed to execute this unit.

用于支持None的序列化/反序列化

使用CPickle去做序列化/反序列化的Serde

inner function

Use for the dict with know fields. Args: fields_to_types (dict): key字段名, vaule相应字段所用的serde。 如果只传入字段名

* @brief For one scope, if any flow streamed out of it streames back into it, * we call it a scope cycle. * * For example, in t

默认的序列化/反序列化器

A wrapper of serializable operators of Flume.

value serde

Log formatter used in Tornado. Key features of this formatter are: * Color support when logging to a terminal that supports it. * Timest

用于表示具有分布式Key-Value映射关系的 :class:`bigflow.ptype.PType` Constructor .. note:: 用户不应当直接使用其构造方法 Args: value (PType): PTable的Value

Serde for protobuf

测试str类型序列化/反序列化器

value serde

inner function

Bigflow等待指定运行状态超时

bool类型序列化/反序列化器

Serde for dict

Use for the dict with know fields

float类型序列化/反序列化器

FlumeIteratorDelegator is used to wrap flume::core::Iterator*. It act like a Python Iterator by: 1. Exposing next() method 2. Throwing an StopIterati

A Processor for foreach

Hadoop Cmd

int类型序列化/反序列化器

indicate this scope has partitioner

for val

Lazy Variable，用于加载字典等外部数据 Examples: >>> # coding: utf-8 >>> from bigflow import base, lazy_var >>> >>> ""

list序列化/反序列化器

inner class

Mock logging handler to hold all the output logging for further assertion or checking Logged messages are available through the instance's ```mes

test

list序列化/反序列化器，要求list中元素均为同一类型

inner

Serde for set

inner

str类型序列化/反序列化器

测试int类型序列化/反序列化器

tuple类型序列化/反序列化器