@Internal public class ClassPathPackagedProgramRetriever extends Object implements PackagedProgramRetriever
PackagedProgramRetriever
which
creates the PackagedProgram
containing
the user's main()
from a class on the class path.Modifier and Type | Class and Description |
---|---|
static class |
ClassPathPackagedProgramRetriever.Builder
A builder for the
ClassPathPackagedProgramRetriever . |
Modifier and Type | Method and Description |
---|---|
PackagedProgram |
getPackagedProgram()
Retrieve the
PackagedProgram . |
static ClassPathPackagedProgramRetriever.Builder |
newBuilder(String[] programArguments,
Configuration configuration) |
public PackagedProgram getPackagedProgram() throws FlinkException
PackagedProgramRetriever
PackagedProgram
.getPackagedProgram
in interface PackagedProgramRetriever
PackagedProgram
.FlinkException
- if the PackagedProgram
could not be retrievedpublic static ClassPathPackagedProgramRetriever.Builder newBuilder(String[] programArguments, Configuration configuration)
Copyright © 2014–2021 The Apache Software Foundation. All rights reserved.