PTransformMatcher that matches a PTransform if the class of the
PTransform is equal to the Class provided ot this matcher.Coders.PTransformOverrideFactory that will apply a flatten where no element appears in the
input PCollectionList more than once.PTransformOverrideFactory that provides an empty Create to replace a Flatten.PCollections that takes no input PCollections.PTransformMatcher which matches a Flatten.PCollections which
consumes a single input PCollection multiple times.PTransform overrides, which behave identically to the
delegate transform but with overridden methods.RunnerApi.WindowingStrategy accompanied by RunnerApi.Components
to the SDK's WindowingStrategy.RunnerApi.WindowingStrategy to the SDK's WindowingStrategy using
the provided components to dereferences identifiers found in the proto.coders within a coder.AppliedPTransform, ignoring any additional inputs
returned by PTransform.getAdditionalInputs().matchesScope(actualScope, scopes) returns true if the scope of a metric is matched
by any of the filters in scopes.PTransformMatcher which matches a ParDo.SingleOutput or ParDo.MultiOutput where the DoFn is of the provided type.PCollections to and from Runner API protos.Create that returns a primitive PCollection.PTransformOverrideFactory that creates instances of PrimitiveCreate.PTransformMatcher that matches PTransforms based on the class of the
transform.PTransforms to and from Runner API
protocol buffers.PTransform application and produces the appropriate
FunctionSpec for a distinguished or primitive transform within the Beam runner API.PTransformOverrideFactory.ReplacementOutput for known styles of POutput.PTransformMatcher that matches a ParDo.MultiOutput containing a DoFn
that is splittable, as signified by DoFnSignature.ProcessElementMethod.isSplittable().PTransformMatcher that matches a ParDo.SingleOutput containing a DoFn
that is splittable, as signified by DoFnSignature.ProcessElementMethod.isSplittable().PTransformMatcher that matches a ParDo.MultiOutput containing a DoFn
that uses state or timers, as specified by DoFnSignature.usesState() and
DoFnSignature.usesTimers().PTransformMatcher that matches a ParDo.SingleOutput containing a DoFn
that uses state or timers, as specified by DoFnSignature.usesState() and DoFnSignature.usesTimers().subPathMatches(haystack, needle) returns true if needle
represents a path within haystack.WindowingStrategy into a RunnerApi.MessageWithComponents where
RunnerApi.MessageWithComponents#getWindowingStrategy() ()} is a RunnerApi.WindowingStrategy (proto) for the input WindowingStrategy.WindowingStrategy into a RunnerApi.WindowingStrategy, registering
any components in the provided SdkComponents.Triggers.PTransform that performs an unbounded read from a BoundedSource.BoundedSource to UnboundedSource adapter.PTransformOverrideFactory that throws an exception when a call to
UnsupportedOverrideFactory.getReplacementTransform(AppliedPTransform) is made.WindowingStrategies.Copyright © 2016–2017 The Apache Software Foundation. All rights reserved.