Package org.apache.beam.io.requestresponse

Class Cache.Pair<RequestT,ResponseT>

java.lang.Object

org.apache.beam.io.requestresponse.Cache.Pair<RequestT,ResponseT>

Enclosing class:

Cache

public static class Cache.Pair<RequestT,ResponseT>
extends Object

A simple POJO that holds both cache read and write PTransforms. Functionally, these go together and must at times be instantiated using the same inputs.

Method Summary

Modifier and Type	Method	Description
PTransform<PCollection<RequestT>,Result<KV<RequestT,@Nullable ResponseT>>>	getRead()
PTransform<PCollection<KV<RequestT,ResponseT>>,Result<KV<RequestT,ResponseT>>>	getWrite()
static <RequestT, ResponseT> Cache.Pair<RequestT,ResponseT>	of(PTransform<PCollection<RequestT>,Result<KV<RequestT,@Nullable ResponseT>>> read, PTransform<PCollection<KV<RequestT,ResponseT>>,Result<KV<RequestT,ResponseT>>> write)

Methods inherited from class java.lang.Object

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

Method Details

of

public static <RequestT,
ResponseT>
Cache.Pair<RequestT,ResponseT> of(PTransform<PCollection<RequestT>,Result<KV<RequestT,@Nullable ResponseT>>> read,
 PTransform<PCollection<KV<RequestT,ResponseT>>,Result<KV<RequestT,ResponseT>>> write)

getRead

public PTransform<PCollection<RequestT>,Result<KV<RequestT,@Nullable ResponseT>>> getRead()

getWrite

public PTransform<PCollection<KV<RequestT,ResponseT>>,Result<KV<RequestT,ResponseT>>> getWrite()