com.google.cloud.dataflow.sdk.util

Class StateFetcher

java.lang.Object

com.google.cloud.dataflow.sdk.util.StateFetcher

public class StateFetcher
extends Object

Class responsible for fetching state from the windmill server.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	StateFetcher.SideInputState Indicates the caller's knowledge of whether a particular side input has been computed.

Constructor Summary

Constructors

Constructor and Description
StateFetcher(MetricTrackingWindmillServerStub server)
StateFetcher(MetricTrackingWindmillServerStub server, com.google.common.cache.Cache<com.google.cloud.dataflow.sdk.util.StateFetcher.SideInputId,com.google.cloud.dataflow.sdk.util.StateFetcher.SideInputCacheEntry> sideInputCache)

Method Summary

Modifier and Type	Method and Description
<T,SideWindowT extends BoundedWindow> T	fetchSideInput(PCollectionView<T> view, SideWindowT sideWindow, String stateFamily, StateFetcher.SideInputState state) Fetch the given side input, storing it in a process-level cache.

Methods inherited from class java.lang.Object

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

Constructor Detail

StateFetcher

public StateFetcher(MetricTrackingWindmillServerStub server)

StateFetcher

public StateFetcher(MetricTrackingWindmillServerStub server,
                    com.google.common.cache.Cache<com.google.cloud.dataflow.sdk.util.StateFetcher.SideInputId,com.google.cloud.dataflow.sdk.util.StateFetcher.SideInputCacheEntry> sideInputCache)

Method Detail

fetchSideInput

public <T,SideWindowT extends BoundedWindow> T fetchSideInput(PCollectionView<T> view,
                                                              SideWindowT sideWindow,
                                                              String stateFamily,
                                                              StateFetcher.SideInputState state)

Fetch the given side input, storing it in a process-level cache.

If state is KNOWN_READY, attempt to fetch the data regardless of whether a not-ready entry was cached.