apache_beam.runners.dask package

Submodules

• apache_beam.runners.dask.dask_runner module
  • DaskOptions
  • DaskRunnerResult
    • DaskRunnerResult.distributed
    • DaskRunnerResult.client
    • DaskRunnerResult.futures
    • DaskRunnerResult.wait_until_finish()
    • DaskRunnerResult.cancel()
    • DaskRunnerResult.metrics()
  • DaskRunner
    • DaskRunner.to_dask_bag_visitor()
    • DaskRunner.is_fnapi_compatible()
    • DaskRunner.run_pipeline()
• apache_beam.runners.dask.overrides module
  • dask_overrides()
• apache_beam.runners.dask.transform_evaluator module
  • DaskBagOp
    • DaskBagOp.applied
    • DaskBagOp.transform
    • DaskBagOp.apply()
  • NoOp
    • NoOp.apply()
  • Create
    • Create.apply()
  • ParDo
    • ParDo.apply()
  • Map
    • Map.apply()
  • GroupByKey
    • GroupByKey.apply()
  • Flatten
    • Flatten.apply()