com.google.cloud.dataflow.sdk.util.state

Class WindmillStateInternals

java.lang.Object

com.google.cloud.dataflow.sdk.util.state.MergingStateInternals

com.google.cloud.dataflow.sdk.util.state.WindmillStateInternals

All Implemented Interfaces:

StateInternals

public class WindmillStateInternals
extends MergingStateInternals

Implementation of StateInternals using Windmill to manage the underlying data.

Constructor Summary

Constructors

Constructor and Description
WindmillStateInternals(String prefix, boolean useStateFamilies, WindmillStateReader reader)

Method Summary

Modifier and Type	Method and Description
void	persist(com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.WorkItemCommitRequest.Builder commitBuilder)
<T extends State> T	state(StateNamespace namespace, StateTag<T> address) Return the state associated with address in the specified namespace.

Methods inherited from class com.google.cloud.dataflow.sdk.util.state.MergingStateInternals

mergedState

Methods inherited from class java.lang.Object

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

Constructor Detail

WindmillStateInternals

public WindmillStateInternals(String prefix,
                              boolean useStateFamilies,
                              WindmillStateReader reader)

Method Detail

persist

public void persist(com.google.cloud.dataflow.sdk.runners.worker.windmill.Windmill.WorkItemCommitRequest.Builder commitBuilder)

state

public <T extends State> T state(StateNamespace namespace,
                                 StateTag<T> address)

Description copied from interface: StateInternals

Return the state associated with address in the specified namespace.