bigflow package

Bigflow Python API

Submodules

• PipelineFactory
• Counter
• Exceptions
• Input
• Output
• PCollection
• PObject
• PTable
• PType
• Serde
• Transforms

Subpackages

• bigflow.pipeline package
  • Submodules
    • LocalPipeline
    • BasePipeline
• bigflow.util package
  • Submodules
    • BroadcastUtil
    • Decorators
    • HadoopClient
    • Logging
    • PTypeInfo
    • ReIterables
    • SideInputUtil
    • Others