public class FlinkPortableClientEntryPoint
extends java.lang.Object
Designed for non-interactive Flink REST client and container with Beam job server jar and SDK client (for example when using the FlinkK8sOperator). In the future it would be possible to support driver program execution in a separate (sidecar) container by introducing a client environment abstraction similar to how it exists for SDK workers.
Using this entry point eliminates the need to build jar files with materialized pipeline protos offline. Allows the driver program to access actual execution environment and services, on par with code executed by SDK workers.
The entry point starts the job server and provides the endpoint to the driver program.
The external driver program constructs the Beam pipeline and submits it to the job service.
The job service defers execution of the pipeline to the plan environment and returns the "detached" status to the driver program.
Upon arrival of the job invocation, the entry point executes the runner, which prepares ("executes") the Flink job through the plan environment.
Finally Flink launches the job.
| Constructor and Description |
|---|
FlinkPortableClientEntryPoint(java.lang.String driverCmd) |
| Modifier and Type | Method and Description |
|---|---|
static void |
main(java.lang.String[] args)
Main method to be called standalone or by Flink (CLI or REST API).
|