com.google.cloud.dataflow.sdk.io

Class DatastoreIO.Write

java.lang.Object

com.google.cloud.dataflow.sdk.io.DatastoreIO.Write

Enclosing class:

DatastoreIO

public static class DatastoreIO.Write
extends java.lang.Object

A PTransform that writes a PCollection<Entity> containing entities to a Datastore kind.

Current version only supports Write operation running on DirectPipelineRunner. If Write is used on DataflowPipelineRunner, it throws UnsupportedOperationException and won't continue on the operation.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DatastoreIO.Write.Bound A PTransform that writes a bounded PCollection<Entities> to a Datastore.

Constructor Summary

Constructors

Constructor and Description
DatastoreIO.Write()

Method Summary

Methods

Modifier and Type	Method and Description
static DatastoreIO.Write.Bound	named(java.lang.String name) Returns a DatastoreIO.Write PTransform with the name associated with this PTransform.
static DatastoreIO.Write.Bound	to(java.lang.String datasetId) Returns a DatastoreIO.Write PTransform with given datasetId.
static DatastoreIO.Write.Bound	withHost(java.lang.String host) Returns a DatastoreIO.Write PTransform with specified host.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

DatastoreIO.Write

public DatastoreIO.Write()

Method Detail

named

public static DatastoreIO.Write.Bound named(java.lang.String name)

Returns a DatastoreIO.Write PTransform with the name associated with this PTransform.

to

public static DatastoreIO.Write.Bound to(java.lang.String datasetId)

Returns a DatastoreIO.Write PTransform with given datasetId.

withHost

public static DatastoreIO.Write.Bound withHost(java.lang.String host)

Returns a DatastoreIO.Write PTransform with specified host.