#include <pubsub_location.h>

Inheritance diagram for google_dataflow_api::PubsubLocation:

Public Member Functions
	PubsubLocation (const Json::Value &storage)

	PubsubLocation (Json::Value *storage)

virtual	~PubsubLocation ()

const StringPiece	GetTypeName () const

bool	has_drop_late_data () const

void	clear_drop_late_data ()

bool	get_drop_late_data () const

void	set_drop_late_data (bool value)

bool	has_id_label () const

void	clear_id_label ()

const StringPiece	get_id_label () const

void	set_id_label (const StringPiece &value)

bool	has_subscription () const

void	clear_subscription ()

const StringPiece	get_subscription () const

void	set_subscription (const StringPiece &value)

bool	has_timestamp_label () const

void	clear_timestamp_label ()

const StringPiece	get_timestamp_label () const

void	set_timestamp_label (const StringPiece &value)

bool	has_topic () const

void	clear_topic ()

const StringPiece	get_topic () const

void	set_topic (const StringPiece &value)

bool	has_tracking_subscription () const

void	clear_tracking_subscription ()

const StringPiece	get_tracking_subscription () const

void	set_tracking_subscription (const StringPiece &value)

bool	has_with_attributes () const

void	clear_with_attributes ()

bool	get_with_attributes () const

void	set_with_attributes (bool value)

Static Public Member Functions
static PubsubLocation *	New ()

Detailed Description

Identifies a pubsub location to use for transferring data into or out of a streaming Dataflow job.

Constructor & Destructor Documentation

◆ PubsubLocation() [1/2]

google_dataflow_api::PubsubLocation::PubsubLocation ( const Json::Value & storage )

explicit

Standard constructor for an immutable data object instance.

Parameters

[in] storage The underlying data storage for this instance.

◆ PubsubLocation() [2/2]

google_dataflow_api::PubsubLocation::PubsubLocation ( Json::Value * storage )

explicit

Standard constructor for a mutable data object instance.

Parameters

[in] storage The underlying data storage for this instance.

◆ ~PubsubLocation()

google_dataflow_api::PubsubLocation::~PubsubLocation ( )

virtual

Standard destructor.

Member Function Documentation

◆ clear_drop_late_data()

void google_dataflow_api::PubsubLocation::clear_drop_late_data ( )

inline

Clears the 'dropLateData' attribute.

◆ clear_id_label()

void google_dataflow_api::PubsubLocation::clear_id_label ( )

inline

Clears the 'idLabel' attribute.

◆ clear_subscription()

void google_dataflow_api::PubsubLocation::clear_subscription ( )

inline

Clears the 'subscription' attribute.

◆ clear_timestamp_label()

void google_dataflow_api::PubsubLocation::clear_timestamp_label ( )

inline

Clears the 'timestampLabel' attribute.

◆ clear_topic()

void google_dataflow_api::PubsubLocation::clear_topic ( )

inline

Clears the 'topic' attribute.

◆ clear_tracking_subscription()

void google_dataflow_api::PubsubLocation::clear_tracking_subscription ( )

inline

Clears the 'trackingSubscription' attribute.

◆ clear_with_attributes()

void google_dataflow_api::PubsubLocation::clear_with_attributes ( )

inline

Clears the 'withAttributes' attribute.

◆ get_drop_late_data()

bool google_dataflow_api::PubsubLocation::get_drop_late_data ( ) const

inline

Get the value of the 'dropLateData' attribute.

◆ get_id_label()

const StringPiece google_dataflow_api::PubsubLocation::get_id_label ( ) const

inline

Get the value of the 'idLabel' attribute.

◆ get_subscription()

const StringPiece google_dataflow_api::PubsubLocation::get_subscription ( ) const

inline

Get the value of the 'subscription' attribute.

◆ get_timestamp_label()

const StringPiece google_dataflow_api::PubsubLocation::get_timestamp_label ( ) const

inline

Get the value of the 'timestampLabel' attribute.

◆ get_topic()

const StringPiece google_dataflow_api::PubsubLocation::get_topic ( ) const

inline

Get the value of the 'topic' attribute.

◆ get_tracking_subscription()

const StringPiece google_dataflow_api::PubsubLocation::get_tracking_subscription ( ) const

inline

Get the value of the 'trackingSubscription' attribute.

◆ get_with_attributes()

bool google_dataflow_api::PubsubLocation::get_with_attributes ( ) const

inline

Get the value of the 'withAttributes' attribute.

◆ GetTypeName()

const StringPiece google_dataflow_api::PubsubLocation::GetTypeName ( ) const

inline

Returns a string denoting the type of this data object.

Returns: google_dataflow_api::PubsubLocation

◆ has_drop_late_data()

bool google_dataflow_api::PubsubLocation::has_drop_late_data ( ) const

inline

Determine if the 'dropLateData' attribute was set.

Returns: true if the 'dropLateData' attribute was set.

◆ has_id_label()

bool google_dataflow_api::PubsubLocation::has_id_label ( ) const

inline

Determine if the 'idLabel' attribute was set.

Returns: true if the 'idLabel' attribute was set.

◆ has_subscription()

bool google_dataflow_api::PubsubLocation::has_subscription ( ) const

inline

Determine if the 'subscription' attribute was set.

Returns: true if the 'subscription' attribute was set.

◆ has_timestamp_label()

bool google_dataflow_api::PubsubLocation::has_timestamp_label ( ) const

inline

Determine if the 'timestampLabel' attribute was set.

Returns: true if the 'timestampLabel' attribute was set.

◆ has_topic()

bool google_dataflow_api::PubsubLocation::has_topic ( ) const

inline

Determine if the 'topic' attribute was set.

Returns: true if the 'topic' attribute was set.

◆ has_tracking_subscription()

bool google_dataflow_api::PubsubLocation::has_tracking_subscription ( ) const

inline

Determine if the 'trackingSubscription' attribute was set.

Returns: true if the 'trackingSubscription' attribute was set.

◆ has_with_attributes()

bool google_dataflow_api::PubsubLocation::has_with_attributes ( ) const

inline

Determine if the 'withAttributes' attribute was set.

Returns: true if the 'withAttributes' attribute was set.

◆ New()

PubsubLocation * google_dataflow_api::PubsubLocation::New ( )

static

Creates a new default instance.

Returns: Ownership is passed back to the caller.

◆ set_drop_late_data()

void google_dataflow_api::PubsubLocation::set_drop_late_data ( bool value )

inline

Change the 'dropLateData' attribute.

Indicates whether the pipeline allows late-arriving data.

Parameters

[in] value The new value.

◆ set_id_label()

void google_dataflow_api::PubsubLocation::set_id_label ( const StringPiece & value )

inline

Change the 'idLabel' attribute.

If set, contains a pubsub label from which to extract record ids. If left empty, record deduplication will be strictly best effort.

Parameters

[in] value The new value.

◆ set_subscription()

void google_dataflow_api::PubsubLocation::set_subscription ( const StringPiece & value )

inline

Change the 'subscription' attribute.

A pubsub subscription, in the form of "pubsub.googleapis.com/subscriptions//".

Parameters

[in] value The new value.

◆ set_timestamp_label()

void google_dataflow_api::PubsubLocation::set_timestamp_label ( const StringPiece & value )

inline

Change the 'timestampLabel' attribute.

If set, contains a pubsub label from which to extract record timestamps. If left empty, record timestamps will be generated upon arrival.

Parameters

[in] value The new value.

◆ set_topic()

void google_dataflow_api::PubsubLocation::set_topic ( const StringPiece & value )

inline

Change the 'topic' attribute.

A pubsub topic, in the form of "pubsub.googleapis.com/topics//".

Parameters

[in] value The new value.

◆ set_tracking_subscription()

void google_dataflow_api::PubsubLocation::set_tracking_subscription ( const StringPiece & value )

inline

Change the 'trackingSubscription' attribute.

If set, specifies the pubsub subscription that will be used for tracking custom time timestamps for watermark estimation.

Parameters

[in] value The new value.

◆ set_with_attributes()

void google_dataflow_api::PubsubLocation::set_with_attributes ( bool value )

inline

Change the 'withAttributes' attribute.

If true, then the client has requested to get pubsub attributes.

Parameters

[in] value The new value.

The documentation for this class was generated from the following files:

google/dataflow_api/pubsub_location.h
google/dataflow_api/pubsub_location.cc

Public Member Functions

Static Public Member Functions

Detailed Description

Constructor & Destructor Documentation

◆ PubsubLocation() [1/2]

◆ PubsubLocation() [2/2]

◆ ~PubsubLocation()

Member Function Documentation

◆ clear_drop_late_data()

◆ clear_id_label()

◆ clear_subscription()

◆ clear_timestamp_label()

◆ clear_topic()

◆ clear_tracking_subscription()

◆ clear_with_attributes()

◆ get_drop_late_data()

◆ get_id_label()

◆ get_subscription()

◆ get_timestamp_label()

◆ get_topic()

◆ get_tracking_subscription()

◆ get_with_attributes()

◆ GetTypeName()

◆ has_drop_late_data()

◆ has_id_label()

◆ has_subscription()

◆ has_timestamp_label()

◆ has_topic()

◆ has_tracking_subscription()

◆ has_with_attributes()

◆ New()

◆ set_drop_late_data()

◆ set_id_label()

◆ set_subscription()

◆ set_timestamp_label()

◆ set_topic()

◆ set_tracking_subscription()

◆ set_with_attributes()