See: Description
| Class | Description |
|---|---|
| DatastoreIO |
DatastoreIO provides an API for reading from and writing to Google Cloud Datastore over different
versions of the Cloud Datastore Client libraries. |
| DatastoreV1 |
DatastoreV1 provides an API to Read, Write and Delete PCollections of
Google Cloud Datastore version v1 Entity objects. |
| DatastoreV1.DeleteEntity |
A
PTransform that deletes Entities from Cloud Datastore. |
| DatastoreV1.DeleteEntityWithSummary |
A
PTransform that deletes Entities from Cloud Datastore and returns
DatastoreV1.WriteSuccessSummary for each successful write. |
| DatastoreV1.DeleteKey | |
| DatastoreV1.DeleteKeyWithSummary |
A
PTransform that deletes Entities associated with the given Keys from Cloud Datastore and returns DatastoreV1.WriteSuccessSummary for each successful delete. |
| DatastoreV1.Read |
A
PTransform that reads the result rows of a Cloud Datastore query as Entity
objects. |
| DatastoreV1.Write |
A
PTransform that writes Entity objects to Cloud Datastore. |
| DatastoreV1.WriteSuccessSummary |
Summary object produced when a number of writes are successfully written to Datastore in a
single Mutation.
|
| DatastoreV1.WriteWithSummary |
A
PTransform that writes Entity objects to Cloud Datastore and returns DatastoreV1.WriteSuccessSummary for each successful write. |
| DataStoreV1SchemaIOProvider |
An implementation of
SchemaIOProvider for reading and writing payloads with DatastoreIO. |
| DataStoreV1SchemaIOProvider.DataStoreV1SchemaIO |
An abstraction to create schema aware IOs.
|
| EntityToRow | |
| RampupThrottlingFn<T> |
An implementation of a client-side throttler that enforces a gradual ramp-up, broadly in line
with Datastore best practices.
|
| RowToEntity |