@Experimental public class DataflowRunnerHooks extends java.lang.Object
DataflowRunnerto add user defined hooks to be invoked at various times during pipeline execution.
|Constructor and Description|
|Modifier and Type||Method and Description|
Allows the user to modify the environment of their job before their job is submitted to the service for execution.
public void modifyEnvironmentBeforeSubmission(Environment environment)
environment- The environment of the job. Users can make change to this instance in order to change the environment with which their job executes on the service.