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

Class UuidDeduplicationOptions

java.lang.Object

org.apache.beam.sdk.io.gcp.pubsublite.UuidDeduplicationOptions

All Implemented Interfaces:

Serializable

public abstract class UuidDeduplicationOptions
extends Object
implements Serializable

Options for deduplicating Pub/Sub Lite messages based on the UUID they were published with.

See Also:

• Serialized Form

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	UuidDeduplicationOptions.Builder

Field Summary

Fields

Modifier and Type	Field	Description
static final Duration	DEFAULT_DEDUPLICATE_DURATION
static final TimeDomain	DEFAULT_TIME_DOMAIN
static final SerializableFunction<com.google.cloud.pubsublite.proto.SequencedMessage,Uuid>	DEFAULT_UUID_EXTRACTOR

Constructor Summary

Constructors

Constructor	Description
UuidDeduplicationOptions()

Method Summary

Modifier and Type	Method	Description
abstract Deduplicate.KeyedValues<Uuid,com.google.cloud.pubsublite.proto.SequencedMessage>	deduplicate()
static UuidDeduplicationOptions.Builder	newBuilder()
abstract SerializableFunction<com.google.cloud.pubsublite.proto.SequencedMessage,Uuid>	uuidExtractor()

Methods inherited from class java.lang.Object

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

Field Details

DEFAULT_UUID_EXTRACTOR

public static final SerializableFunction<com.google.cloud.pubsublite.proto.SequencedMessage,Uuid> DEFAULT_UUID_EXTRACTOR

DEFAULT_TIME_DOMAIN

public static final TimeDomain DEFAULT_TIME_DOMAIN

DEFAULT_DEDUPLICATE_DURATION

public static final Duration DEFAULT_DEDUPLICATE_DURATION

Constructor Details

UuidDeduplicationOptions

public UuidDeduplicationOptions()

Method Details

uuidExtractor

public abstract SerializableFunction<com.google.cloud.pubsublite.proto.SequencedMessage,Uuid> uuidExtractor()

deduplicate

public abstract Deduplicate.KeyedValues<Uuid,com.google.cloud.pubsublite.proto.SequencedMessage> deduplicate()

newBuilder

public static UuidDeduplicationOptions.Builder newBuilder()