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 java.lang.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 and Description
PTransform<PCollection<RequestT>,Result<KV<RequestT,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,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 Detail

of

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

getRead

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

getWrite

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