Apache Flink Runtime Web

import org.apache.flink.runtime.webmonitor.utils.WebFrontendBootstrap;
import org.apache.flink.runtime.webmonitor.history.HistoryServer;
import org.apache.flink.runtime.webmonitor.WebSubmissionExtension;
import org.apache.flink.runtime.rest.handler.router.Router;
import org.apache.flink.configuration.Configuration;
import org.slf4j.Logger;
import java.io.File;

import org.apache.flink.runtime.webmonitor.handlers.*;

import org.apache.flink.runtime.webmonitor.utils.WebFrontendBootstrap;
import org.apache.flink.configuration.Configuration;
import org.apache.flink.shaded.netty4.io.netty.handler.ssl.util.SelfSignedCertificate;
import java.io.File;

// Create web frontend bootstrap
Configuration config = new Configuration();
File uploadDir = new File("/tmp/flink-web-upload");
WebFrontendBootstrap bootstrap = new WebFrontendBootstrap(
    router,
    logger,
    uploadDir,
    null, // SSL handler factory
    "localhost",
    8081,
    config
);

// Get server details
int port = bootstrap.getServerPort();
String address = bootstrap.getRestAddress();

// Shutdown when done
bootstrap.shutdown();

import org.apache.flink.runtime.webmonitor.history.HistoryServer;
import org.apache.flink.configuration.Configuration;

// Start history server
Configuration config = new Configuration();
HistoryServer historyServer = new HistoryServer(config);
historyServer.run();

public class WebFrontendBootstrap {
    public WebFrontendBootstrap(
        Router router,
        Logger logger,
        File uploadDir,
        SSLHandlerFactory sslHandlerFactory,
        String address,
        int port,
        Configuration configuration
    );
    
    public ServerBootstrap getBootstrap();
    public int getServerPort();
    public String getRestAddress();
    public void shutdown();
}

public class JarUploadHandler extends AbstractRestHandler<RestfulGateway, EmptyRequestBody, JarUploadResponseBody, EmptyMessageParameters> {
    public JarUploadHandler(
        GatewayRetriever<? extends RestfulGateway> leaderRetriever,
        Time timeout,
        Map<String, String> responseHeaders,
        MessageHeaders<EmptyRequestBody, JarUploadResponseBody, EmptyMessageParameters> messageHeaders,
        Path jarDir,
        Executor executor
    );
}

public class JarRunHandler extends AbstractRestHandler<RestfulGateway, JarRunRequestBody, JarRunResponseBody, JarRunMessageParameters> {
    // POST /jars/:jarId/run
}

public class JarListHandler extends AbstractRestHandler<RestfulGateway, EmptyRequestBody, JarListInfo, EmptyMessageParameters> {
    // GET /jars
}

public class HistoryServer {
    public HistoryServer(Configuration configuration);
    public HistoryServer(Configuration configuration, Consumer<ArchiveEvent> eventListener);
    
    public static void main(String[] args);
    public void run();
}

public class HistoryServerArchiveFetcher {
    // Archive management functionality
}

public class JarUploadHeaders implements MessageHeaders<EmptyRequestBody, JarUploadResponseBody, EmptyMessageParameters> {
    // POST /jars/upload specification
}

public class JarRunHeaders implements MessageHeaders<JarRunRequestBody, JarRunResponseBody, JarRunMessageParameters> {
    // POST /jars/:jarId/run specification
}

public class JarIdPathParameter extends MessagePathParameter<String> {
    // Path parameter for JAR ID
}

public abstract class JarRequestBody implements RequestBody {
    public String getEntryClassName();
    public List<String> getProgramArguments();
    public Integer getParallelism();
    public JobID getJobId();
}

public class JarRunRequestBody extends JarRequestBody {
    public Boolean getAllowNonRestoredState();
    public String getSavepointPath();
}

public class JarUploadResponseBody implements ResponseBody {
    public JarUploadResponseBody(String filename);
    public String getStatus();
    public String getFilename();
}

public class JarHandlerUtils {
    public static List<String> tokenizeArguments(String args);
    
    public static class JarHandlerContext {
        public static JarHandlerContext fromRequest(HandlerRequest<JarRequestBody, ?> request, Path jarDir);
        public void applyToConfiguration(Configuration configuration);
        public JobGraph toJobGraph(ClassLoader classLoader);
        public PackagedProgram toPackagedProgram(ClassLoader classLoader);
    }
}

public class WebSubmissionExtension implements WebMonitorExtension {
    public Collection<Tuple2<RestHandlerSpecification, ChannelInboundHandler>> getHandlers();
    public CompletableFuture<Void> closeAsync();
}