org.apache.beam.sdk.io.gcp.pubsub

Class PubsubWriteSchemaTransformConfiguration.SourceConfiguration

java.lang.Object

org.apache.beam.sdk.io.gcp.pubsub.PubsubWriteSchemaTransformConfiguration.SourceConfiguration

Enclosing class:

PubsubWriteSchemaTransformConfiguration

@DefaultSchema(value=AutoValueSchema.class)
public abstract static class PubsubWriteSchemaTransformConfiguration.SourceConfiguration
extends java.lang.Object

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	PubsubWriteSchemaTransformConfiguration.SourceConfiguration.Builder

Constructor Summary

Constructors

Constructor and Description
SourceConfiguration()

Method Summary

Modifier and Type	Method and Description
abstract java.lang.String	getAttributesFieldName() The attributes field name of the source Row.
abstract java.lang.String	getPayloadFieldName() The payload field name of the source Row.
abstract java.lang.String	getTimestampFieldName() The timestamp field name of the source Row.

Methods inherited from class java.lang.Object

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

Constructor Detail

SourceConfiguration

public SourceConfiguration()

Method Detail

getAttributesFieldName

@Nullable
public abstract java.lang.String getAttributesFieldName()

The attributes field name of the source Row. Schema.FieldType must be a Map<String, String>

getTimestampFieldName

@Nullable
public abstract java.lang.String getTimestampFieldName()

The timestamp field name of the source Row. Schema.FieldType must be a Schema.FieldType.DATETIME.

getPayloadFieldName

@Nullable
public abstract java.lang.String getPayloadFieldName()

The payload field name of the source Row. Schema.FieldType must be either Schema.FieldType.BYTES or a Row. If null, payload serialized from user fields other than attributes. Not compatible with other payload intended fields.