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
    • EntityWrapper.make_entity()
  • run()
• apache_beam.io.gcp.datastore.v1new.datastoreio module
  • ReadFromDatastore
    • ReadFromDatastore.expand()
    • ReadFromDatastore.display_data()
  • 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
    • RampupThrottlingFn.process()
• apache_beam.io.gcp.datastore.v1new.types module
  • Query
    • Query.clone()
  • Key
    • Key.from_client_key()
    • Key.to_client_key()
  • Entity
    • Entity.set_properties()
    • Entity.from_client_entity()
    • Entity.to_client_entity()
• apache_beam.io.gcp.datastore.v1new.util module
  • MovingSum
    • MovingSum.sum()
    • MovingSum.add()
    • MovingSum.count()
    • MovingSum.has_data()
  • DynamicBatchSizer
    • DynamicBatchSizer.get_batch_size()
    • DynamicBatchSizer.report_latency()