|Constructor and Description|
Deploys a table program on the cluster.
public ProgramDeployer(ExecutionContext<C> context, String jobName, JobGraph jobGraph, Result<C> result, boolean awaitJobResult)
context- context with deployment information
jobName- job name of the Flink job to be submitted
jobGraph- Flink job graph
result- result that receives information about the target cluster
awaitJobResult- block for a job execution result from the cluster
Copyright © 2014–2020 The Apache Software Foundation. All rights reserved.