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:

java.io.Serializable, SchemaIO

Enclosing class:

DataStoreV1SchemaIOProvider

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

An abstraction to create schema aware IOs.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Schema	dataSchema
protected java.lang.String	keyField
protected java.lang.String	kind
protected java.lang.String	location
protected java.lang.String	projectId

Method Summary

Modifier and Type	Method and Description
PTransform<PBegin,PCollection<Row>>	buildReader() Returns a schema aware reader.
PTransform<PCollection<Row>,POutput>	buildWriter() Returns a schema aware writer.
java.lang.String	getKind()
java.lang.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 Detail

dataSchema

protected final Schema dataSchema

location

protected final java.lang.String location

kind

protected final java.lang.String kind

projectId

protected final java.lang.String projectId

keyField

protected final java.lang.String keyField

Method Detail

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 java.lang.String getProjectId()

getKind

public java.lang.String getKind()