Package | Description |
---|---|
org.apache.flink.client.cli | |
org.apache.flink.client.program |
Modifier and Type | Method and Description |
---|---|
protected void |
CliFrontend.executeProgram(PackagedProgram program,
ClusterClient<?> client,
int parallelism) |
Modifier and Type | Method and Description |
---|---|
JobSubmissionResult |
ClusterClient.run(PackagedProgram prog,
int parallelism)
General purpose method to run a user jar from the CliFrontend in either blocking or detached mode, depending
on whether
setDetached(true) or setDetached(false) . |
Copyright © 2014–2019 The Apache Software Foundation. All rights reserved.