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

Class PubsubWriteSchemaTransformConfiguration.TargetConfiguration

java.lang.Object

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

Enclosing class:

PubsubWriteSchemaTransformConfiguration

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

Nested Class Summary

Nested Classes

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

Constructor Summary

Constructors

Constructor and Description
TargetConfiguration()

Method Summary

Modifier and Type	Method and Description
abstract java.lang.String	getTimestampAttributeKey() The attribute key to assign the PubsubMessage stringified timestamp value.

Methods inherited from class java.lang.Object

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

Constructor Detail

TargetConfiguration

public TargetConfiguration()

Method Detail

getTimestampAttributeKey

public abstract java.lang.String getTimestampAttributeKey()

The attribute key to assign the PubsubMessage stringified timestamp value. PubsubWriteSchemaTransformConfiguration.builder() method defaults value to PubsubWriteSchemaTransformConfiguration.DEFAULT_TIMESTAMP_ATTRIBUTE.