| /* |
| * Licensed to the Apache Software Foundation (ASF) under one or more |
| * contributor license agreements. See the NOTICE file distributed with |
| * this work for additional information regarding copyright ownership. |
| * The ASF licenses this file to You under the Apache License, Version 2.0 |
| * (the "License"); you may not use this file except in compliance with |
| * the License. You may obtain a copy of the License at |
| * |
| * http://www.apache.org/licenses/LICENSE-2.0 |
| * |
| * Unless required by applicable law or agreed to in writing, software |
| * distributed under the License is distributed on an "AS IS" BASIS, |
| * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. |
| * See the License for the specific language governing permissions and |
| * limitations under the License. |
| */ |
| |
| package org.apache.uniffle.client.api; |
| |
| import org.apache.uniffle.client.request.RssAppHeartBeatRequest; |
| import org.apache.uniffle.client.request.RssFinishShuffleRequest; |
| import org.apache.uniffle.client.request.RssGetInMemoryShuffleDataRequest; |
| import org.apache.uniffle.client.request.RssGetShuffleDataRequest; |
| import org.apache.uniffle.client.request.RssGetShuffleIndexRequest; |
| import org.apache.uniffle.client.request.RssGetShuffleResultForMultiPartRequest; |
| import org.apache.uniffle.client.request.RssGetShuffleResultRequest; |
| import org.apache.uniffle.client.request.RssRegisterShuffleRequest; |
| import org.apache.uniffle.client.request.RssReportShuffleResultRequest; |
| import org.apache.uniffle.client.request.RssSendCommitRequest; |
| import org.apache.uniffle.client.request.RssSendShuffleDataRequest; |
| import org.apache.uniffle.client.request.RssUnregisterShuffleByAppIdRequest; |
| import org.apache.uniffle.client.request.RssUnregisterShuffleRequest; |
| import org.apache.uniffle.client.response.RssAppHeartBeatResponse; |
| import org.apache.uniffle.client.response.RssFinishShuffleResponse; |
| import org.apache.uniffle.client.response.RssGetInMemoryShuffleDataResponse; |
| import org.apache.uniffle.client.response.RssGetShuffleDataResponse; |
| import org.apache.uniffle.client.response.RssGetShuffleIndexResponse; |
| import org.apache.uniffle.client.response.RssGetShuffleResultResponse; |
| import org.apache.uniffle.client.response.RssRegisterShuffleResponse; |
| import org.apache.uniffle.client.response.RssReportShuffleResultResponse; |
| import org.apache.uniffle.client.response.RssSendCommitResponse; |
| import org.apache.uniffle.client.response.RssSendShuffleDataResponse; |
| import org.apache.uniffle.client.response.RssUnregisterShuffleByAppIdResponse; |
| import org.apache.uniffle.client.response.RssUnregisterShuffleResponse; |
| |
| public interface ShuffleServerClient { |
| |
| RssUnregisterShuffleResponse unregisterShuffle(RssUnregisterShuffleRequest request); |
| |
| RssRegisterShuffleResponse registerShuffle(RssRegisterShuffleRequest request); |
| |
| RssUnregisterShuffleByAppIdResponse unregisterShuffleByAppId( |
| RssUnregisterShuffleByAppIdRequest request); |
| |
| RssSendShuffleDataResponse sendShuffleData(RssSendShuffleDataRequest request); |
| |
| RssSendCommitResponse sendCommit(RssSendCommitRequest request); |
| |
| RssAppHeartBeatResponse sendHeartBeat(RssAppHeartBeatRequest request); |
| |
| RssFinishShuffleResponse finishShuffle(RssFinishShuffleRequest request); |
| |
| RssReportShuffleResultResponse reportShuffleResult(RssReportShuffleResultRequest request); |
| |
| RssGetShuffleResultResponse getShuffleResult(RssGetShuffleResultRequest request); |
| |
| RssGetShuffleResultResponse getShuffleResultForMultiPart( |
| RssGetShuffleResultForMultiPartRequest request); |
| |
| RssGetShuffleIndexResponse getShuffleIndex(RssGetShuffleIndexRequest request); |
| |
| RssGetShuffleDataResponse getShuffleData(RssGetShuffleDataRequest request); |
| |
| RssGetInMemoryShuffleDataResponse getInMemoryShuffleData( |
| RssGetInMemoryShuffleDataRequest request); |
| |
| String getDesc(); |
| |
| void close(); |
| |
| String getClientInfo(); |
| } |