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

Class UuidDeduplicationOptions

java.lang.Object

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

All Implemented Interfaces:

java.io.Serializable

public abstract class UuidDeduplicationOptions
extends java.lang.Object
implements java.io.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 and Description
static class	UuidDeduplicationOptions.Builder

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
UuidDeduplicationOptions()

Method Summary

Modifier and Type	Method and Description
abstract Deduplicate.KeyedValues<Uuid,com.google.cloud.pubsublite.proto.SequencedMessage>	deduplicate()
abstract int	hashPartitions()
static UuidDeduplicationOptions.Builder	newBuilder()
abstract SerializableStatusFunction<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 Detail

DEFAULT_UUID_EXTRACTOR

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

DEFAULT_HASH_PARTITIONS

public static final int DEFAULT_HASH_PARTITIONS

See Also:

Constant Field Values

DEFAULT_TIME_DOMAIN

public static final TimeDomain DEFAULT_TIME_DOMAIN

DEFAULT_DEDUPLICATE_DURATION

public static final Duration DEFAULT_DEDUPLICATE_DURATION

Constructor Detail

UuidDeduplicationOptions

public UuidDeduplicationOptions()

Method Detail

uuidExtractor

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

deduplicate

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

hashPartitions

public abstract int hashPartitions()

newBuilder

public static UuidDeduplicationOptions.Builder newBuilder()