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

Class ExternalWrite.Configuration

java.lang.Object

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

Enclosing class:

ExternalWrite

public static class ExternalWrite.Configuration
extends java.lang.Object

Parameters class to expose the transform to an external SDK.

Constructor Summary

Constructors

Constructor and Description
Configuration()

Method Summary

Modifier and Type	Method and Description
void	setIdLabel(@Nullable java.lang.String idAttribute)
void	setTimestampAttribute(@Nullable java.lang.String timestampAttribute)
void	setTopic(java.lang.String topic)

Methods inherited from class java.lang.Object

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

Constructor Detail

Configuration

public Configuration()

Method Detail

setTopic

public void setTopic(java.lang.String topic)

setIdLabel

public void setIdLabel(@Nullable java.lang.String idAttribute)

setTimestampAttribute

public void setTimestampAttribute(@Nullable java.lang.String timestampAttribute)