apache_beam.io.gcp.datastore package

Subpackages

• apache_beam.io.gcp.datastore.v1new package
  • Submodules
    • apache_beam.io.gcp.datastore.v1new.datastore_write_it_pipeline module
      • new_pipeline_with_job_name()
      • EntityWrapper
      • run()
    • apache_beam.io.gcp.datastore.v1new.datastoreio module
      • ReadFromDatastore
      • WriteToDatastore
      • DeleteFromDatastore
    • apache_beam.io.gcp.datastore.v1new.helper module
      • get_client()
      • retry_on_rpc_error()
      • create_entities()
      • create_client_entities()
    • apache_beam.io.gcp.datastore.v1new.query_splitter module
      • QuerySplitterError
      • SplitNotPossibleError
      • get_splits()
    • apache_beam.io.gcp.datastore.v1new.rampup_throttling_fn module
      • RampupThrottlingFn
    • apache_beam.io.gcp.datastore.v1new.types module
      • Query
      • Key
      • Entity
    • apache_beam.io.gcp.datastore.v1new.util module
      • MovingSum
      • DynamicBatchSizer