zoukankan      html  css  js  c++  java
  • flink 获取上传的Jar源码



    package org.apache.flink.runtime.webmonitor.handlers;

    /**
    * Handles .jar file uploads.
    */
    public class JarUploadHandler extends
    AbstractRestHandler<RestfulGateway, EmptyRequestBody, JarUploadResponseBody, EmptyMessageParameters> {


    package org.apache.flink.runtime.rest;

    public abstract class AbstractHandler<T extends RestfulGateway, R extends RequestBody, M extends MessageParameters> extends RedirectHandler<T> {
    protected final Logger log = LoggerFactory.getLogger(getClass());
    protected static final ObjectMapper MAPPER = RestMapperUtils.getStrictObjectMapper();
    private final UntypedResponseMessageHeaders<R, M> untypedResponseMessageHeaders;
    protected AbstractHandler(
    @Nonnull CompletableFuture<String> localAddressFuture,
    @Nonnull GatewayRetriever<? extends T> leaderRetriever,
    @Nonnull Time timeout,
    @Nonnull Map<String, String> responseHeaders,
    @Nonnull UntypedResponseMessageHeaders<R, M> untypedResponseMessageHeaders) {
    super(localAddressFuture, leaderRetriever, timeout, responseHeaders);

    this.untypedResponseMessageHeaders = Preconditions.checkNotNull(untypedResponseMessageHeaders);
    }

    @Override
    protected void respondAsLeader(ChannelHandlerContext ctx, RoutedRequest routedRequest, T gateway) {
    HttpRequest httpRequest = routedRequest.getRequest();
    if (log.isTraceEnabled()) {
    log.trace("Received request " + httpRequest.uri() + '.');
    }

    FileUploads uploadedFiles = null;
    try {
    if (!(httpRequest instanceof FullHttpRequest)) {
    // The RestServerEndpoint defines a HttpObjectAggregator in the pipeline that always returns
    // FullHttpRequests.
    log.error("Implementation error: Received a request that wasn't a FullHttpRequest.");
    throw new RestHandlerException("Bad request received.", HttpResponseStatus.BAD_REQUEST);
    }

    final ByteBuf msgContent = ((FullHttpRequest) httpRequest).content();

    uploadedFiles = FileUploadHandler.getMultipartFileUploads(ctx);
  • 相关阅读:
    [Maid] Write Tasks in Markdown with Maid
    [React] Preview and edit a component live with React Live
    [React] Build a slide deck with mdx-deck using Markdown + React
    [React] Spread Component Props in JSX with React
    重载new delete操作符是怎么调用的
    oracle如何设置show parameter显示隐含参数
    Google用户登录界面 Android实现
    Jquery 动态生成表单 并将表单数据 批量通过Ajax插入到数据库
    消息机4_B
    jQuery中对 input 控件的操作
  • 原文地址:https://www.cnblogs.com/WCFGROUP/p/9779622.html
Copyright © 2011-2022 走看看