Send feedback
Class PubsubLocation (0.51.0)
Stay organized with collections
Save and categorize content based on your preferences.
Version 0.51.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
Inherited Members
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT)
com.google.protobuf.GeneratedMessageV3.<ListT>makeMutableCopy(ListT,int)
com.google.protobuf.GeneratedMessageV3.<T>emptyList(java.lang.Class<T>)
com.google.protobuf.GeneratedMessageV3.internalGetMapFieldReflection(int)
Static Fields
DROP_LATE_DATA_FIELD_NUMBER
public static final int DROP_LATE_DATA_FIELD_NUMBER
Field Value
Type Description
int
ID_LABEL_FIELD_NUMBER
public static final int ID_LABEL_FIELD_NUMBER
Field Value
Type Description
int
SUBSCRIPTION_FIELD_NUMBER
public static final int SUBSCRIPTION_FIELD_NUMBER
Field Value
Type Description
int
TIMESTAMP_LABEL_FIELD_NUMBER
public static final int TIMESTAMP_LABEL_FIELD_NUMBER
Field Value
Type Description
int
TOPIC_FIELD_NUMBER
public static final int TOPIC_FIELD_NUMBER
Field Value
Type Description
int
TRACKING_SUBSCRIPTION_FIELD_NUMBER
public static final int TRACKING_SUBSCRIPTION_FIELD_NUMBER
Field Value
Type Description
int
WITH_ATTRIBUTES_FIELD_NUMBER
public static final int WITH_ATTRIBUTES_FIELD_NUMBER
Field Value
Type Description
int
Static Methods
getDefaultInstance()
public static PubsubLocation getDefaultInstance ()
getDescriptor()
public static final Descriptors . Descriptor getDescriptor ()
newBuilder()
public static PubsubLocation . Builder newBuilder ()
newBuilder(PubsubLocation prototype)
public static PubsubLocation . Builder newBuilder ( PubsubLocation prototype )
public static PubsubLocation parseDelimitedFrom ( InputStream input )
public static PubsubLocation parseDelimitedFrom ( InputStream input , ExtensionRegistryLite extensionRegistry )
parseFrom(byte[] data)
public static PubsubLocation parseFrom ( byte [] data )
Parameter
Name Description
databyte []
parseFrom(byte[] data, ExtensionRegistryLite extensionRegistry)
public static PubsubLocation parseFrom ( byte [] data , ExtensionRegistryLite extensionRegistry )
parseFrom(ByteString data)
public static PubsubLocation parseFrom ( ByteString data )
parseFrom(ByteString data, ExtensionRegistryLite extensionRegistry)
public static PubsubLocation parseFrom ( ByteString data , ExtensionRegistryLite extensionRegistry )
public static PubsubLocation parseFrom ( CodedInputStream input )
public static PubsubLocation parseFrom ( CodedInputStream input , ExtensionRegistryLite extensionRegistry )
public static PubsubLocation parseFrom ( InputStream input )
public static PubsubLocation parseFrom ( InputStream input , ExtensionRegistryLite extensionRegistry )
parseFrom(ByteBuffer data)
public static PubsubLocation parseFrom ( ByteBuffer data )
parseFrom(ByteBuffer data, ExtensionRegistryLite extensionRegistry)
public static PubsubLocation parseFrom ( ByteBuffer data , ExtensionRegistryLite extensionRegistry )
parser()
public static Parser<PubsubLocation> parser ()
Methods
equals(Object obj)
public boolean equals ( Object obj )
Parameter
Name Description
objObject
Overrides
getDefaultInstanceForType()
public PubsubLocation getDefaultInstanceForType ()
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
Type Description
ByteString The bytes for idLabel.
getParserForType()
public Parser<PubsubLocation> getParserForType ()
Overrides
getSerializedSize()
public int getSerializedSize ()
Returns
Type Description
int
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
Type Description
ByteString The bytes for topic.
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.
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
Type Description
int
Overrides
internalGetFieldAccessorTable()
protected GeneratedMessageV3 . FieldAccessorTable internalGetFieldAccessorTable ()
Overrides
isInitialized()
public final boolean isInitialized ()
Overrides
newBuilderForType()
public PubsubLocation . Builder newBuilderForType ()
newBuilderForType(GeneratedMessageV3.BuilderParent parent)
protected PubsubLocation . Builder newBuilderForType ( GeneratedMessageV3 . BuilderParent parent )
Overrides
newInstance(GeneratedMessageV3.UnusedPrivateParameter unused)
protected Object newInstance ( GeneratedMessageV3 . UnusedPrivateParameter unused )
Returns
Type Description
Object
Overrides
toBuilder()
public PubsubLocation . Builder toBuilder ()
writeTo(CodedOutputStream output)
public void writeTo ( CodedOutputStream output )
Overrides
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-01-27 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-01-27 UTC."],[],[]]
