Index

A

accumulate() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) add_archive() (bigflow.pipeline.pipeline_base.PipelineBase 方法) add_cache_id() (bigflow.pipeline.pipeline_base.PipelineBase 方法) add_directory() (bigflow.pipeline.pipeline_base.PipelineBase 方法) add_egg_file() (bigflow.pipeline.pipeline_base.PipelineBase 方法) add_file() (bigflow.pipeline.local_pipeline.LocalPipeline 方法) (bigflow.pipeline.pipeline_base.PipelineBase 方法) advance_logger() (在 bigflow.util.decorators 模块中) agg() (bigflow.pcollection.PCollection 方法) (在 bigflow.future.fields 模块中) aggregate() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中)

any() (在 bigflow.serde 模块中) apply() (bigflow.ptype.PType 方法) apply_key_values() (bigflow.ptable.PTable 方法) apply_values() (bigflow.ptable.PTable 方法) as_pcollection() (bigflow.pobject.PObject 方法) as_pobject() (bigflow.pcollection.PCollection 方法) as_schema() (bigflow.pcollection.PCollection 方法) as_type() (bigflow.input.SequenceFile 方法) (bigflow.input.SequenceFileStream 方法) (bigflow.output.SequenceFile 方法) async_run() (bigflow.pipeline.pipeline_base.PipelineBase 方法)

B

begin_process() (bigflow.base.Transformer 方法) bigflow (模块), [1] bigflow.base (模块), [1] bigflow.counter (模块), [1] bigflow.error (模块), [1] bigflow.example (模块) bigflow.example.pagerank (模块) bigflow.example.word_cnt (模块) bigflow.future.fields (模块) bigflow.input (模块) bigflow.lazy_var (模块) bigflow.output (模块) bigflow.pcollection (模块), [1] bigflow.pipeline (模块), [1] bigflow.pipeline.local_pipeline (模块) bigflow.pipeline.pipeline_base (模块) bigflow.pobject (模块), [1] bigflow.ptable (模块), [1] bigflow.ptype (模块), [1]

bigflow.serde (模块) bigflow.transform_impls (模块) bigflow.transforms (模块) bigflow.util (模块), [1] bigflow.util.broadcast (模块) bigflow.util.decorators (模块) bigflow.util.hadoop_client (模块) bigflow.util.log (模块) bigflow.util.ptype_info (模块) bigflow.util.reiterable_input (模块) bigflow.util.side_input_util (模块) bigflow.util.utils (模块) BigflowHDFSException BigflowPlanningException BigflowRPCException BigflowRuntimeException bool_() (在 bigflow.serde 模块中) BoolSerde (bigflow.serde 中的类) broadcast_to() (在 bigflow.util.broadcast 模块中)

C

cache() (bigflow.ptype.PType 方法) cartesian() (bigflow.pcollection.PCollection 方法) (bigflow.pobject.PObject 方法) (在 bigflow.transforms 模块中) ceil() (bigflow.pobject.PObject 方法) ChainSerde (bigflow.serde 中的类) close() (bigflow.output.UserOutputBase 方法) cogroup() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) combine() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中)

common_serde() (在 bigflow.serde 模块中) compression_types (bigflow.output.TextFile 属性) config() (bigflow.pipeline.pipeline_base.PipelineBase 方法) construct() (在 bigflow.util.utils 模块中) count() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) count_words() (在 bigflow.example.word_cnt 模块中) CPickleSerde (bigflow.serde 中的类) CppSerde (bigflow.serde 中的类) create() (bigflow.base.Pipeline 静态方法)

D

declare() (在 bigflow.lazy_var 模块中) DEFAULT (bigflow.base.Options.Explain 属性) DEFAULT_COLORS (bigflow.util.log.LogFormatter 属性) DEFAULT_DATE_FORMAT (bigflow.util.log.LogFormatter 属性) DEFAULT_FORMAT (bigflow.util.log.LogFormatter 属性) default_objector() (bigflow.pipeline.pipeline_base.PipelineBase 方法) DefaultSerde (bigflow.serde 中的类) deserialize() (bigflow.future.fields.FieldsDictSerde 方法) (bigflow.serde.BoolSerde 方法) (bigflow.serde.ChainSerde 方法) (bigflow.serde.DictSerde 方法) (bigflow.serde.FloatSerde 方法) (bigflow.serde.IdlPacketSerde 方法) (bigflow.serde.IntSerde 方法) (bigflow.serde.Optional 方法) (bigflow.serde.ProtobufSerde 方法) (bigflow.serde.SameTypeListSerde 方法) (bigflow.serde.SetSerde 方法) (bigflow.serde.StrSerde 方法) (bigflow.serde.TupleLikeListSerde 方法) (bigflow.serde.TupleSerde 方法)

detect_ptype() (在 bigflow.util.utils 模块中) dict_of() (在 bigflow.serde 模块中) DictSerde (bigflow.serde 中的类) diff() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) distinct() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中)

E

enable_pretty_logging() (在 bigflow.util.log 模块中) enable_pretty_logging_at_debug() (在 bigflow.util.log 模块中) end_process() (bigflow.base.Transformer 方法) Error extract_elem() (在 bigflow.serde 模块中)

extract_fs_name_from_path() (在 bigflow.util.hadoop_client 模块中) extract_keys() (bigflow.ptable.PTable 方法) (在 bigflow.transforms 模块中) extract_values() (bigflow.ptable.PTable 方法) (在 bigflow.transforms 模块中)

F

FastPbSerdeFactory (bigflow.serde 中的类) FieldsDictSerde (bigflow.future.fields 中的类) FileBase (bigflow.input 中的类) (bigflow.output 中的类) filter() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) first() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) flat_map() (bigflow.pcollection.PCollection 方法) (bigflow.pobject.PObject 方法) (在 bigflow.transforms 模块中) flatten() (bigflow.ptable.PTable 方法) (在 bigflow.future.fields 模块中) (在 bigflow.transforms 模块中) flatten_runtime_value() (在 bigflow.util.utils 模块中) flatten_values() (bigflow.ptable.PTable 方法) (在 bigflow.transforms 模块中)

float_() (在 bigflow.serde 模块中) FloatSerde (bigflow.serde 中的类) floor() (bigflow.pobject.PObject 方法) foreach() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) format() (bigflow.util.log.LogFormatter 方法) fs_dus() (bigflow.util.hadoop_client.HadoopClient 方法) fs_get() (bigflow.util.hadoop_client.HadoopClient 方法) fs_mkdir() (bigflow.util.hadoop_client.HadoopClient 方法) fs_mv() (bigflow.util.hadoop_client.HadoopClient 方法) fs_put() (bigflow.util.hadoop_client.HadoopClient 方法) fs_rmr() (bigflow.util.hadoop_client.HadoopClient 方法) fs_test() (bigflow.util.hadoop_client.HadoopClient 方法) full_join() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中)

G

get() (bigflow.lazy_var.LazyVariable 方法) (bigflow.pipeline.pipeline_base.PipelineBase 方法) (bigflow.ptype.PType 方法) get_args() (bigflow.serde.ChainSerde 方法) (bigflow.serde.TupleSerde 方法) get_commiter() (bigflow.output.UserOutputBase 方法) get_dealt_side_inputs_tuple() (bigflow.util.side_input_util.SideInputsUtil 静态方法) get_entity_config() (bigflow.serde.CppSerde 方法) (bigflow.serde.ObjectorSerde 方法) (bigflow.serde.Serde 方法) get_entity_name() (bigflow.serde.CppSerde 方法) (bigflow.serde.ObjectorSerde 方法) (bigflow.serde.Serde 方法) get_fields() (bigflow.serde.ListSerde 方法) get_input() (bigflow.util.side_input_util.SideInputsUtil 方法)

get_log_type() (bigflow.serde.IdlPacketSerde 方法) get_msg_type() (bigflow.serde.ProtobufSerde 方法) get_out_fields_serde() (在 bigflow.future.fields 模块中) get_serde() (bigflow.input.UserInputBase 方法) (bigflow.serde.FastPbSerdeFactory 方法) get_serde_of_field() (在 bigflow.future.fields 模块中) get_serde_of_fields() (在 bigflow.future.fields 模块中) get_size() (bigflow.input.FileBase 方法) (bigflow.input.UserInputBase 方法) get_value_serde() (bigflow.serde.SetSerde 方法) group_by() (bigflow.pcollection.PCollection 方法) (在 bigflow.future.fields 模块中) (在 bigflow.transforms 模块中) group_by_key() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中)

H

HadoopClient (bigflow.util.hadoop_client 中的类)

I

id() (bigflow.pipeline.pipeline_base.PipelineBase 方法) idl_to_str() (在 bigflow.transforms 模块中) IdlPacketSerde (bigflow.serde 中的类) increase() (在 bigflow.counter 模块中) init_log() (在 bigflow.util.log 模块中) inner_most_type() (bigflow.ptable.PTable 方法) input() (bigflow.util.reiterable_input.ReIterableInput 方法) int_() (在 bigflow.serde 模块中) intersection() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中)

IntSerde (bigflow.serde 中的类) InvalidConfException InvalidDataException InvalidLogicalPlanException InvalidSeqSerdeException is_empty() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) is_infinite() (在 bigflow.util.utils 模块中) is_ptype() (在 bigflow.util.utils 模块中) is_same_working_scope() (在 bigflow.util.broadcast 模块中)

J

join() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中)

K

key_serdes() (bigflow.ptable.PTable 方法)

L

LazyVariable (bigflow.lazy_var 中的类) left_join() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) list_of() (在 bigflow.serde 模块中)

ListSerde (bigflow.serde 中的类) load() (bigflow.input.UserInputBase 方法) LocalPipeline (bigflow.pipeline.local_pipeline 中的类) LogFormatter (bigflow.util.log 中的类)

M

make_tuple() (在 bigflow.transforms 模块中) map() (bigflow.pcollection.PCollection 方法) (bigflow.pobject.PObject 方法) (在 bigflow.transforms 模块中) max() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中)

max_elements() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) min() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) min_elements() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中)

N

nested_level() (bigflow.ptable.PTable 方法) node() (bigflow.ptable.PTable 方法) (bigflow.ptype.PType 方法)

not_() (bigflow.pobject.PObject 方法)

O

ObjectorSerde (bigflow.serde 中的类) of() (在 bigflow.future.fields 模块中) (在 bigflow.serde 模块中) OFF (bigflow.base.Options.Explain 属性) ON (bigflow.base.Options.Explain 属性)

open() (bigflow.output.UserOutputBase 方法) Optional (bigflow.serde 中的类) Options (bigflow.base 中的类) Options.Explain (bigflow.base 中的类) origin() (在 bigflow.serde 模块中) origin_serde() (bigflow.serde.Optional 方法)

P

pagerank_algo() (在 bigflow.example.pagerank 模块中) parallelize() (bigflow.pipeline.pipeline_base.PipelineBase 方法) partition() (bigflow.output.FileBase 方法) partition_fn() (bigflow.output.UserOutputBase 方法) partition_number() (bigflow.output.UserOutputBase 方法) PCollection (bigflow.pcollection 中的类) pipe() (在 bigflow.transforms 模块中) Pipeline (bigflow.base 中的类) pipeline() (bigflow.ptype.PType 方法) PipelineBase (bigflow.pipeline.pipeline_base 中的类)

plan() (bigflow.pipeline.pipeline_base.PipelineBase 方法) PObject (bigflow.pobject 中的类) post_process() (bigflow.input.UserInputBase 方法) pre_process() (bigflow.output.UserOutputBase 方法) process() (bigflow.base.Transformer 方法) process_with_side_inputs() (bigflow.util.side_input_util.SideInputsUtil 方法) proto_of() (在 bigflow.serde 模块中) ProtobufSerde (bigflow.serde 中的类) PTable (bigflow.ptable 中的类) PType (bigflow.ptype 中的类) PTypeInfo (bigflow.util.ptype_info 中的类)

R

read() (bigflow.pipeline.pipeline_base.PipelineBase 方法) reduce() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) ReIterableInput (bigflow.util.reiterable_input 中的类) reset_all_counters() (bigflow.pipeline.pipeline_base.PipelineBase 方法)

reset_counter() (bigflow.pipeline.pipeline_base.PipelineBase 方法) right_join() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) round() (bigflow.pobject.PObject 方法) run() (bigflow.pipeline.local_pipeline.LocalPipeline 方法) (bigflow.pipeline.pipeline_base.PipelineBase 方法)

S

SameTypeListSerde (bigflow.serde 中的类) sample() (在 bigflow.serde 模块中) SchemaTextFile (bigflow.input 中的类) (bigflow.output 中的类) select() (bigflow.pcollection.PCollection 方法) (在 bigflow.future.fields 模块中) select_cols() (在 bigflow.future.fields 模块中) SequenceFile (bigflow.input 中的类) (bigflow.output 中的类) SequenceFileStream (bigflow.input 中的类) Serde (bigflow.serde 中的类) serde() (bigflow.ptype.PType 方法) serialize() (bigflow.future.fields.FieldsDictSerde 方法) (bigflow.serde.BoolSerde 方法) (bigflow.serde.ChainSerde 方法) (bigflow.serde.DictSerde 方法) (bigflow.serde.FloatSerde 方法) (bigflow.serde.IdlPacketSerde 方法) (bigflow.serde.IntSerde 方法) (bigflow.serde.Optional 方法) (bigflow.serde.ProtobufSerde 方法) (bigflow.serde.SameTypeListSerde 方法) (bigflow.serde.SetSerde 方法) (bigflow.serde.StrSerde 方法) (bigflow.serde.TupleLikeListSerde 方法) (bigflow.serde.TupleSerde 方法)

set_fini_hook() (bigflow.pipeline.pipeline_base.PipelineBase 方法) set_init_hook() (bigflow.pipeline.pipeline_base.PipelineBase 方法) set_of() (在 bigflow.serde 模块中) SetSerde (bigflow.serde 中的类) SideInputsUtil (bigflow.util.side_input_util 中的类) singleton() (在 bigflow.util.decorators 模块中) sink() (bigflow.output.UserOutputBase 方法) sort() (bigflow.output.FileBase 方法) (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) sort_by() (bigflow.output.FileBase 方法) (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) split() (bigflow.input.UserInputBase 方法) str_() (在 bigflow.serde 模块中) str_to_idl() (在 bigflow.transforms 模块中) StrSerde (bigflow.serde 中的类) substract() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) subtract() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) sum() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中)

T

take() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) TextFile (bigflow.input 中的类) (bigflow.output 中的类) TextFileStream (bigflow.input 中的类) to_list_pobject() (在 bigflow.transforms 模块中) to_pobject() (在 bigflow.transforms 模块中) transform() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中) transform_from_node() (bigflow.input.SchemaTextFile 方法) (bigflow.input.SequenceFile 方法) (bigflow.input.SequenceFileStream 方法) (bigflow.input.TextFile 方法) (bigflow.input.TextFileStream 方法)

transform_to_node() (bigflow.output.SchemaTextFile 方法) (bigflow.output.SequenceFile 方法) (bigflow.output.TextFile 方法) Transformer (bigflow.base 中的类) tuple_of() (在 bigflow.serde 模块中) TupleLikeListSerde (bigflow.serde 中的类) TupleSerde (bigflow.serde 中的类)

U

union() (bigflow.pcollection.PCollection 方法) (bigflow.pobject.PObject 方法) (在 bigflow.transforms 模块中)

user_define_format() (在 bigflow.input 模块中) (在 bigflow.output 模块中) UserInputBase (bigflow.input 中的类) UserOutputBase (bigflow.output 中的类)

W

window_into() (bigflow.pcollection.PCollection 方法) (在 bigflow.transforms 模块中)

with_compression() (bigflow.output.TextFile 方法) working_scope() (在 bigflow.util.broadcast 模块中) write() (bigflow.pipeline.pipeline_base.PipelineBase 方法)