Package org.apache.beam.sdk.transforms.reflect

Class DoFnInvoker.FakeArgumentProvider<InputT,OutputT>

java.lang.Object

org.apache.beam.sdk.transforms.reflect.DoFnInvoker.BaseArgumentProvider<InputT,OutputT>

org.apache.beam.sdk.transforms.reflect.DoFnInvoker.FakeArgumentProvider<InputT,OutputT>

All Implemented Interfaces:

DoFnInvoker.ArgumentProvider<InputT,OutputT>

Enclosing interface:

DoFnInvoker<InputT,OutputT>

@Internal
public static class DoFnInvoker.FakeArgumentProvider<InputT,OutputT>
extends DoFnInvoker.BaseArgumentProvider<InputT,OutputT>

A fake DoFnInvoker.ArgumentProvider used during testing. Throws UnsupportedOperationException for all methods.

Constructor Summary

Constructors

Constructor	Description
FakeArgumentProvider()

Method Summary

Modifier and Type	Method	Description
java.lang.String	getErrorContext()	Return a human readable representation of the current call context to be used during error reporting.

Methods inherited from class org.apache.beam.sdk.transforms.reflect.DoFnInvoker.BaseArgumentProvider

bundleFinalizer, element, finishBundleContext, key, onTimerContext, outputReceiver, outputRowReceiver, paneInfo, pipelineOptions, processContext, restriction, restrictionTracker, schemaElement, sideInput, startBundleContext, state, taggedOutputReceiver, timeDomain, timer, timerFamily, timerId, timestamp, watermarkEstimator, watermarkEstimatorState, window

Methods inherited from class java.lang.Object

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

Constructor Detail

FakeArgumentProvider

public FakeArgumentProvider()

Method Detail

getErrorContext

public java.lang.String getErrorContext()

Description copied from class: DoFnInvoker.BaseArgumentProvider

Return a human readable representation of the current call context to be used during error reporting.

Specified by:

getErrorContext in class DoFnInvoker.BaseArgumentProvider<InputT,OutputT>