源码类别
热门源码
 当前位置：源码 > Java源码 >

Java源码示例：org.apache.flink.runtime.webmonitor.handlers.JarUploadHandler

示例1
public WebSubmissionExtension(
		Configuration configuration,
		GatewayRetriever<? extends DispatcherGateway> leaderRetriever,
		Map<String, String> responseHeaders,
		CompletableFuture<String> localAddressFuture,
		Path jarDir,
		Executor executor,
		Time timeout) throws Exception {

	webSubmissionHandlers = new ArrayList<>(5);

	final JarUploadHandler jarUploadHandler = new JarUploadHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarUploadHeaders.getInstance(),
		jarDir,
		executor);

	final JarListHandler jarListHandler = new JarListHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarListHeaders.getInstance(),
		localAddressFuture,
		jarDir.toFile(),
		executor);

	final JarRunHandler jarRunHandler = new JarRunHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarRunHeaders.getInstance(),
		jarDir,
		configuration,
		executor);

	final JarDeleteHandler jarDeleteHandler = new JarDeleteHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarDeleteHeaders.getInstance(),
		jarDir,
		executor);

	final JarPlanHandler jarPlanHandler = new JarPlanHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarPlanHeaders.getInstance(),
		jarDir,
		configuration,
		executor
	);

	webSubmissionHandlers.add(Tuple2.of(JarUploadHeaders.getInstance(), jarUploadHandler));
	webSubmissionHandlers.add(Tuple2.of(JarListHeaders.getInstance(), jarListHandler));
	webSubmissionHandlers.add(Tuple2.of(JarRunHeaders.getInstance(), jarRunHandler));
	webSubmissionHandlers.add(Tuple2.of(JarDeleteHeaders.getInstance(), jarDeleteHandler));
	webSubmissionHandlers.add(Tuple2.of(JarPlanHeaders.getInstance(), jarPlanHandler));
}
示例2
public WebSubmissionExtension(
		Configuration configuration,
		GatewayRetriever<? extends DispatcherGateway> leaderRetriever,
		Map<String, String> responseHeaders,
		CompletableFuture<String> localAddressFuture,
		Path jarDir,
		Executor executor,
		Time timeout) throws Exception {

	webSubmissionHandlers = new ArrayList<>(5);

	final JarUploadHandler jarUploadHandler = new JarUploadHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarUploadHeaders.getInstance(),
		jarDir,
		executor);

	final JarListHandler jarListHandler = new JarListHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarListHeaders.getInstance(),
		localAddressFuture,
		jarDir.toFile(),
		executor);

	final JarRunHandler jarRunHandler = new JarRunHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarRunHeaders.getInstance(),
		jarDir,
		configuration,
		executor);

	final JarDeleteHandler jarDeleteHandler = new JarDeleteHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarDeleteHeaders.getInstance(),
		jarDir,
		executor);

	final JarPlanHandler jarPlanHandler = new JarPlanHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarPlanGetHeaders.getInstance(),
		jarDir,
		configuration,
		executor
	);

	final JarPlanHandler postJarPlanHandler = new JarPlanHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarPlanPostHeaders.getInstance(),
		jarDir,
		configuration,
		executor
	);

	webSubmissionHandlers.add(Tuple2.of(JarUploadHeaders.getInstance(), jarUploadHandler));
	webSubmissionHandlers.add(Tuple2.of(JarListHeaders.getInstance(), jarListHandler));
	webSubmissionHandlers.add(Tuple2.of(JarRunHeaders.getInstance(), jarRunHandler));
	webSubmissionHandlers.add(Tuple2.of(JarDeleteHeaders.getInstance(), jarDeleteHandler));
	webSubmissionHandlers.add(Tuple2.of(JarPlanGetHeaders.getInstance(), jarPlanHandler));
	webSubmissionHandlers.add(Tuple2.of(JarPlanGetHeaders.getInstance(), postJarPlanHandler));
}
示例3
public WebSubmissionExtension(
		Configuration configuration,
		GatewayRetriever<? extends DispatcherGateway> leaderRetriever,
		Map<String, String> responseHeaders,
		CompletableFuture<String> localAddressFuture,
		Path jarDir,
		Executor executor,
		Time timeout) throws Exception {

	webSubmissionHandlers = new ArrayList<>();

	final JarUploadHandler jarUploadHandler = new JarUploadHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarUploadHeaders.getInstance(),
		jarDir,
		executor);

	final JarListHandler jarListHandler = new JarListHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarListHeaders.getInstance(),
		localAddressFuture,
		jarDir.toFile(),
		configuration,
		executor);

	final JarRunHandler jarRunHandler = new JarRunHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarRunHeaders.getInstance(),
		jarDir,
		configuration,
		executor,
		() -> new DetachedApplicationRunner(true));

	final JarDeleteHandler jarDeleteHandler = new JarDeleteHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarDeleteHeaders.getInstance(),
		jarDir,
		executor);

	final JarPlanHandler jarPlanHandler = new JarPlanHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarPlanGetHeaders.getInstance(),
		jarDir,
		configuration,
		executor
	);

	final JarPlanHandler postJarPlanHandler = new JarPlanHandler(
		leaderRetriever,
		timeout,
		responseHeaders,
		JarPlanPostHeaders.getInstance(),
		jarDir,
		configuration,
		executor
	);

	webSubmissionHandlers.add(Tuple2.of(JarUploadHeaders.getInstance(), jarUploadHandler));
	webSubmissionHandlers.add(Tuple2.of(JarListHeaders.getInstance(), jarListHandler));
	webSubmissionHandlers.add(Tuple2.of(JarRunHeaders.getInstance(), jarRunHandler));
	webSubmissionHandlers.add(Tuple2.of(JarDeleteHeaders.getInstance(), jarDeleteHandler));
	webSubmissionHandlers.add(Tuple2.of(JarPlanGetHeaders.getInstance(), jarPlanHandler));
	webSubmissionHandlers.add(Tuple2.of(JarPlanPostHeaders.getInstance(), postJarPlanHandler));
}