Google Cloud Dataflow SDK for Java, version 1.9.1
com.google.cloud.dataflow.sdk.transforms
Interface DoFnWithContext.ExtraContextFactory<InputT,OutputT>
-
- Enclosing class:
- DoFnWithContext<InputT,OutputT>
public static interface DoFnWithContext.ExtraContextFactory<InputT,OutputT>
Interface for runner implementors to provide implementations of extra context information.The methods on this interface are called by
DoFnReflector
before invoking an annotatedDoFnWithContext.StartBundle
,DoFnWithContext.ProcessElement
orDoFnWithContext.FinishBundle
method that has indicated it needs the given extra context.In the case of
DoFnWithContext.ProcessElement
it is called once per invocation ofDoFnWithContext.ProcessElement
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method and Description BoundedWindow
window()
Construct theBoundedWindow
to use within aDoFnWithContext
that needs it.com.google.cloud.dataflow.sdk.util.WindowingInternals<InputT,OutputT>
windowingInternals()
Construct theWindowingInternals
to use within aDoFnWithContext
that needs it.
-
-
-
Method Detail
-
window
BoundedWindow window()
Construct theBoundedWindow
to use within aDoFnWithContext
that needs it. This is called if theDoFnWithContext.ProcessElement
method has a parameter of typeBoundedWindow
.- Returns:
BoundedWindow
of the element currently being processed.
-
windowingInternals
com.google.cloud.dataflow.sdk.util.WindowingInternals<InputT,OutputT> windowingInternals()
Construct theWindowingInternals
to use within aDoFnWithContext
that needs it. This is called if theDoFnWithContext.ProcessElement
method has a parameter of typeWindowingInternals
.
-
-