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

Class PubsubIO.Read.External.Configuration

java.lang.Object

org.apache.beam.sdk.io.gcp.pubsub.PubsubIO.Read.External.Configuration

Enclosing class:

PubsubIO.Read.External

public static class PubsubIO.Read.External.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(java.lang.String idAttribute)
void	setSubscription(java.lang.String subscription)
void	setTimestampAttribute(java.lang.String timestampAttribute)
void	setTopic(java.lang.String topic)
void	setWithAttributes(java.lang.Boolean needsAttributes)

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(@Nullable
                     java.lang.String topic)

setSubscription

public void setSubscription(@Nullable
                            java.lang.String subscription)

setIdLabel

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

setTimestampAttribute

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

setWithAttributes

public void setWithAttributes(java.lang.Boolean needsAttributes)