Package google.registry.beam.rde

Class RdePipeline.TupleTags

java.lang.Object

google.registry.beam.rde.RdePipeline.TupleTags

Enclosing class:

RdePipeline

protected abstract static class RdePipeline.TupleTags
extends Object

A utility class that contains TupleTags when PCollectionTuples and CoGbkResults are used.

Field Summary

Fields

Modifier and Type	Field	Description
protected static final org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.KV<PendingDeposit,DepositFragment>>	DOMAIN_FRAGMENTS
protected static final org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.KV<PendingDeposit,DepositFragment>>	EXTERNAL_HOST_FRAGMENTS
protected static final org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.KV<String,org.apache.beam.sdk.transforms.join.CoGbkResult>>	HOST_TO_PENDING_DEPOSIT
protected static final org.apache.beam.sdk.values.TupleTag<PendingDeposit>	PENDING_DEPOSIT
protected static final org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.KV<String,PendingDeposit>>	REFERENCED_CONTACTS
protected static final org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.KV<String,PendingDeposit>>	REFERENCED_HOSTS
protected static final org.apache.beam.sdk.values.TupleTag<Long>	REVISION_ID
protected static final org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.KV<String,org.apache.beam.sdk.values.KV<String,org.apache.beam.sdk.transforms.join.CoGbkResult>>>	SUPERORDINATE_DOMAINS

Constructor Summary

Constructors

Modifier	Constructor	Description
protected	TupleTags()

Method Summary

Methods inherited from class java.lang.Object

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

Field Details

DOMAIN_FRAGMENTS

protected static final org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.KV<PendingDeposit,DepositFragment>> DOMAIN_FRAGMENTS

REFERENCED_CONTACTS

protected static final org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.KV<String,PendingDeposit>> REFERENCED_CONTACTS

REFERENCED_HOSTS

protected static final org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.KV<String,PendingDeposit>> REFERENCED_HOSTS

SUPERORDINATE_DOMAINS

protected static final org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.KV<String,org.apache.beam.sdk.values.KV<String,org.apache.beam.sdk.transforms.join.CoGbkResult>>> SUPERORDINATE_DOMAINS

EXTERNAL_HOST_FRAGMENTS

protected static final org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.KV<PendingDeposit,DepositFragment>> EXTERNAL_HOST_FRAGMENTS

PENDING_DEPOSIT

protected static final org.apache.beam.sdk.values.TupleTag<PendingDeposit> PENDING_DEPOSIT

HOST_TO_PENDING_DEPOSIT

protected static final org.apache.beam.sdk.values.TupleTag<org.apache.beam.sdk.values.KV<String,org.apache.beam.sdk.transforms.join.CoGbkResult>> HOST_TO_PENDING_DEPOSIT

REVISION_ID

protected static final org.apache.beam.sdk.values.TupleTag<Long> REVISION_ID

Constructor Details

TupleTags

protected TupleTags()