Pipeline
Pipeline.input()
Pipeline.output()
Pipeline.map()
Pipeline.concat()
Pipeline.flat_map()
Pipeline.filter()
Pipeline.window()
Pipeline.window_all()
Pipeline.reduce()
Pipeline.time_window()
AutoConfig
AutoConfig.load_config()
AutoConfig.LocalCPUConfig()
AutoConfig.LocalGPUConfig()
AutoConfig.TritonCPUConfig()
AutoConfig.TritonGPUConfig()
AutoPipes