com.google.cloud.dataflow.sdk.io

Class DatastoreIO.Read

java.lang.Object

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

Enclosing class:

DatastoreIO

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

A PTransform that reads from a Datastore query and returns a PCollection<Entity> containing each of the rows of the table.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	DatastoreIO.Read.Bound A PTransform that reads from a Datastore query and returns a bounded PCollection<Entity>.

Constructor Summary

Constructors

Constructor and Description
DatastoreIO.Read()

Method Summary

Methods

Modifier and Type	Method and Description
static DatastoreIO.Read.Bound	from(java.lang.String datasetId, com.google.api.services.datastore.DatastoreV1.Query query) Reads entities retrieved from the dataset and a given query.
static DatastoreIO.Read.Bound	named(java.lang.String name) Returns a DatastoreIO.Read PTransform with the given step name.
static DatastoreIO.Read.Bound	withHost(java.lang.String host) Returns a DatastoreIO.Read 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.Read

public DatastoreIO.Read()

Method Detail

named

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

Returns a DatastoreIO.Read PTransform with the given step name.

from

public static DatastoreIO.Read.Bound from(java.lang.String datasetId,
                          com.google.api.services.datastore.DatastoreV1.Query query)

Reads entities retrieved from the dataset and a given query.

withHost

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

Returns a DatastoreIO.Read PTransform with specified host.