Package org.apache.beam.sdk.io.iceberg.cdc.sink

Class DestinationShard

java.lang.Object

org.apache.beam.sdk.io.iceberg.cdc.sink.DestinationShard

@DefaultSchema(AutoValueSchema.class)
public abstract class DestinationShard
extends Object

The shuffle key of one write group: a destination and one of its shards.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	DestinationShard.Builder

Constructor Summary

Constructors

Constructor	Description
DestinationShard()

Method Summary

Modifier and Type	Method	Description
static DestinationShard.Builder	builder()
static Coder<DestinationShard>	coder()	A deterministic coder, so the key can drive a GroupByKey.
abstract String	getDestination()
abstract int	getShard()
static DestinationShard	of(String destination, int shard)

Methods inherited from class java.lang.Object

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

Constructor Details

DestinationShard

public DestinationShard()

Method Details

getDestination

public abstract String getDestination()

getShard

public abstract int getShard()

builder

public static DestinationShard.Builder builder()

of

public static DestinationShard of(String destination,
 int shard)

coder

public static Coder<DestinationShard> coder()

A deterministic coder, so the key can drive a GroupByKey.