Send feedback
Class PubsubLocation (0.9.0)
Stay organized with collections
Save and categorize content based on your preferences.
Version 0.9.0 keyboard_arrow_down
public final class PubsubLocation extends GeneratedMessageV3 implements PubsubLocationOrBuilder
Identifies a pubsub location to use for transferring data into or
out of a streaming Dataflow job.
Protobuf type google.dataflow.v1beta3.PubsubLocation
Static Fields
DROP_LATE_DATA_FIELD_NUMBER
public static final int DROP_LATE_DATA_FIELD_NUMBER
Field Value
ID_LABEL_FIELD_NUMBER
public static final int ID_LABEL_FIELD_NUMBER
Field Value
SUBSCRIPTION_FIELD_NUMBER
public static final int SUBSCRIPTION_FIELD_NUMBER
Field Value
TIMESTAMP_LABEL_FIELD_NUMBER
public static final int TIMESTAMP_LABEL_FIELD_NUMBER
Field Value
TOPIC_FIELD_NUMBER
public static final int TOPIC_FIELD_NUMBER
Field Value
TRACKING_SUBSCRIPTION_FIELD_NUMBER
public static final int TRACKING_SUBSCRIPTION_FIELD_NUMBER
Field Value
WITH_ATTRIBUTES_FIELD_NUMBER
public static final int WITH_ATTRIBUTES_FIELD_NUMBER
Field Value
Static Methods
getDefaultInstance()
public static PubsubLocation getDefaultInstance ()
Returns
getDescriptor()
public static final Descriptors . Descriptor getDescriptor ()
Returns
newBuilder()
public static PubsubLocation . Builder newBuilder ()
Returns
newBuilder(PubsubLocation prototype)
public static PubsubLocation . Builder newBuilder ( PubsubLocation prototype )
Parameter
Returns
public static PubsubLocation parseDelimitedFrom ( InputStream input )
Parameter
Returns
Exceptions
public static PubsubLocation parseDelimitedFrom ( InputStream input , ExtensionRegistryLite extensionRegistry )
Parameters
Returns
Exceptions
parseFrom(byte[] data)
public static PubsubLocation parseFrom ( byte [] data )
Parameter
Name Description data byte []
Returns
Exceptions
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static PubsubLocation parseFrom ( byte [] data , ExtensionRegistryLite extensionRegistry )
Parameters
Returns
Exceptions
parseFrom(ByteString data)
public static PubsubLocation parseFrom ( ByteString data )
Parameter
Returns
Exceptions
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static PubsubLocation parseFrom ( ByteString data , ExtensionRegistryLite extensionRegistry )
Parameters
Returns
Exceptions
public static PubsubLocation parseFrom ( CodedInputStream input )
Parameter
Returns
Exceptions
public static PubsubLocation parseFrom ( CodedInputStream input , ExtensionRegistryLite extensionRegistry )
Parameters
Returns
Exceptions
public static PubsubLocation parseFrom ( InputStream input )
Parameter
Returns
Exceptions
public static PubsubLocation parseFrom ( InputStream input , ExtensionRegistryLite extensionRegistry )
Parameters
Returns
Exceptions
parseFrom(ByteBuffer data)
public static PubsubLocation parseFrom ( ByteBuffer data )
Parameter
Returns
Exceptions
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static PubsubLocation parseFrom ( ByteBuffer data , ExtensionRegistryLite extensionRegistry )
Parameters
Returns
Exceptions
parser()
public static Parser<PubsubLocation> parser ()
Returns
Methods
equals(Object obj)
public boolean equals ( Object obj )
Parameter
Returns
Overrides
getDefaultInstanceForType()
public PubsubLocation getDefaultInstanceForType ()
Returns
getDropLateData()
public boolean getDropLateData ()
Indicates whether the pipeline allows late-arriving data.
bool drop_late_data = 5;
Returns
Type Description boolean The dropLateData.
getIdLabel()
public String getIdLabel ()
If set, contains a pubsub label from which to extract record ids.
If left empty, record deduplication will be strictly best effort.
string id_label = 4;
Returns
Type Description String The idLabel.
getIdLabelBytes()
public ByteString getIdLabelBytes ()
If set, contains a pubsub label from which to extract record ids.
If left empty, record deduplication will be strictly best effort.
string id_label = 4;
Returns
getParserForType()
public Parser<PubsubLocation> getParserForType ()
Returns
Overrides
getSerializedSize()
public int getSerializedSize ()
Returns
Overrides
getSubscription()
public String getSubscription ()
A pubsub subscription, in the form of
"pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>"
string subscription = 2;
Returns
Type Description String The subscription.
getSubscriptionBytes()
public ByteString getSubscriptionBytes ()
A pubsub subscription, in the form of
"pubsub.googleapis.com/subscriptions/<project-id>/<subscription-name>"
string subscription = 2;
Returns
Type Description ByteString The bytes for subscription.
getTimestampLabel()
public String getTimestampLabel ()
If set, contains a pubsub label from which to extract record timestamps.
If left empty, record timestamps will be generated upon arrival.
string timestamp_label = 3;
Returns
Type Description String The timestampLabel.
getTimestampLabelBytes()
public ByteString getTimestampLabelBytes ()
If set, contains a pubsub label from which to extract record timestamps.
If left empty, record timestamps will be generated upon arrival.
string timestamp_label = 3;
Returns
Type Description ByteString The bytes for timestampLabel.
getTopic()
A pubsub topic, in the form of
"pubsub.googleapis.com/topics/<project-id>/<topic-name>"
string topic = 1;
Returns
Type Description String The topic.
getTopicBytes()
public ByteString getTopicBytes ()
A pubsub topic, in the form of
"pubsub.googleapis.com/topics/<project-id>/<topic-name>"
string topic = 1;
Returns
getTrackingSubscription()
public String getTrackingSubscription ()
If set, specifies the pubsub subscription that will be used for tracking
custom time timestamps for watermark estimation.
string tracking_subscription = 6;
Returns
Type Description String The trackingSubscription.
getTrackingSubscriptionBytes()
public ByteString getTrackingSubscriptionBytes ()
If set, specifies the pubsub subscription that will be used for tracking
custom time timestamps for watermark estimation.
string tracking_subscription = 6;
Returns
Type Description ByteString The bytes for trackingSubscription.
getUnknownFields()
public final UnknownFieldSet getUnknownFields ()
Returns
Overrides
getWithAttributes()
public boolean getWithAttributes ()
If true, then the client has requested to get pubsub attributes.
bool with_attributes = 7;
Returns
Type Description boolean The withAttributes.
hashCode()
Returns
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3 . FieldAccessorTable internalGetFieldAccessorTable ()
Returns
Overrides
isInitialized()
public final boolean isInitialized ()
Returns
Overrides
newBuilderForType()
public PubsubLocation . Builder newBuilderForType ()
Returns
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected PubsubLocation . Builder newBuilderForType ( GeneratedMessageV3 . BuilderParent parent )
Parameter
Returns
Overrides
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance ( GeneratedMessageV3 . UnusedPrivateParameter unused )
Parameter
Returns
Overrides
toBuilder()
public PubsubLocation . Builder toBuilder ()
Returns
writeTo(CodedOutputStream output)
public void writeTo ( CodedOutputStream output )
Parameter
Overrides
Exceptions
Send feedback
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License , and code samples are licensed under the Apache 2.0 License . For details, see the Google Developers Site Policies . Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2025-02-14 UTC.
Need to tell us more?
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2025-02-14 UTC."],[],[]]
