Class DoFnInvokers
- java.lang.Object
-
- org.apache.beam.sdk.transforms.reflect.DoFnInvokers
-
@Internal public class DoFnInvokers extends java.lang.Object
Static utilities for working withDoFnInvoker
.
-
-
Method Summary
All Methods Static Methods Concrete Methods Modifier and Type Method Description static <InputT,OutputT>
DoFnInvoker<InputT,OutputT>invokerFor(DoFn<InputT,OutputT> fn)
static <InputT,OutputT>
DoFnInvoker<InputT,OutputT>tryInvokeSetupFor(DoFn<InputT,OutputT> fn, PipelineOptions options)
Tries to invoke setup on the givenDoFn
.
-
-
-
Method Detail
-
invokerFor
public static <InputT,OutputT> DoFnInvoker<InputT,OutputT> invokerFor(DoFn<InputT,OutputT> fn)
Returns anDoFnInvoker
for the givenDoFn
, using a default choice ofDoFnInvokerFactory
.The default is permitted to change at any time. Users of this method may not depend on any details
DoFnInvokerFactory
-specific details of the invoker. Today it isByteBuddyDoFnInvokerFactory
.
-
tryInvokeSetupFor
public static <InputT,OutputT> DoFnInvoker<InputT,OutputT> tryInvokeSetupFor(DoFn<InputT,OutputT> fn, PipelineOptions options)
Tries to invoke setup on the givenDoFn
. If setup throws any exception, the givenDoFn
will be torn down immediately and the exception rethrown.On success returns an
DoFnInvoker
for the givenDoFn
.
-
-