Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.runners.inprocess
Interface ModelEnforcementFactory
-
public interface ModelEnforcementFactory
CreatesModelEnforcement
instances for anAppliedPTransform
on an inputbundle
.ModelEnforcement
instances are created before theTransformEvaluator
is created.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method and Description <T> ModelEnforcement<T>
forBundle(InProcessPipelineRunner.CommittedBundle<T> input, AppliedPTransform<?,?,?> consumer)
-
-
-
Method Detail
-
forBundle
<T> ModelEnforcement<T> forBundle(InProcessPipelineRunner.CommittedBundle<T> input, AppliedPTransform<?,?,?> consumer)
-
-