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

Class ExternalRead.Configuration

java.lang.Object

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

Enclosing class:

ExternalRead

public static class ExternalRead.Configuration
extends Object

Parameters class to expose the transform to an external SDK.

Constructor Summary

Constructors

Constructor	Description
Configuration()

Method Summary

Modifier and Type	Method	Description
void	setIdLabel(@Nullable String idAttribute)
void	setSubscription(@Nullable String subscription)
void	setTimestampAttribute(@Nullable String timestampAttribute)
void	setTopic(@Nullable String topic)
void	setWithAttributes(Boolean needsAttributes)

Methods inherited from class java.lang.Object

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

Constructor Details

Configuration

public Configuration()

Method Details

setTopic

public void setTopic(@Nullable String topic)

setSubscription

public void setSubscription(@Nullable String subscription)

setIdLabel

public void setIdLabel(@Nullable String idAttribute)

setTimestampAttribute

public void setTimestampAttribute(@Nullable String timestampAttribute)

setWithAttributes

public void setWithAttributes(Boolean needsAttributes)