Package org.apache.beam.sdk.io.gcp.datastore

Class DataStoreV1SchemaIOProvider.DataStoreV1SchemaIO

java.lang.Object

org.apache.beam.sdk.io.gcp.datastore.DataStoreV1SchemaIOProvider.DataStoreV1SchemaIO

All Implemented Interfaces:

Serializable, SchemaIO

Enclosing class:

DataStoreV1SchemaIOProvider

public static class DataStoreV1SchemaIOProvider.DataStoreV1SchemaIO
extends Object
implements SchemaIO, Serializable

An abstraction to create schema aware IOs.

See Also:

• Serialized Form

Field Summary

Fields

Modifier and Type	Field	Description
protected final Schema	dataSchema
protected final String	keyField
protected final String	kind
protected final String	location
protected final String	projectId

Method Summary

Modifier and Type	Method	Description
PTransform<PBegin,PCollection<Row>>	buildReader()	Returns a schema aware reader.
PTransform<PCollection<Row>,POutput>	buildWriter()	Returns a schema aware writer.
String	getKind()
String	getProjectId()
Schema	schema()	Returns the schema of the data.

Methods inherited from class java.lang.Object

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

Field Details

dataSchema

protected final Schema dataSchema

location

protected final String location

kind

protected final String kind

projectId

protected final String projectId

keyField

protected final String keyField

Method Details

schema

public Schema schema()

Description copied from interface: SchemaIO

Returns the schema of the data.

Specified by:

schema in interface SchemaIO

buildReader

public PTransform<PBegin,PCollection<Row>> buildReader()

Description copied from interface: SchemaIO

Returns a schema aware reader.

Specified by:

buildReader in interface SchemaIO

buildWriter

public PTransform<PCollection<Row>,POutput> buildWriter()

Description copied from interface: SchemaIO

Returns a schema aware writer.

Specified by:

buildWriter in interface SchemaIO

getProjectId

public String getProjectId()

getKind

public String getKind()