/**
* Autogenerated by Thrift Compiler (0.9.3)
*
* DO NOT EDIT UNLESS YOU ARE SURE THAT YOU KNOW WHAT YOU ARE DOING
* @generated
*/
package org.apache.doris.thrift;
import org.apache.thrift.scheme.IScheme;
import org.apache.thrift.scheme.SchemeFactory;
import org.apache.thrift.scheme.StandardScheme;
import org.apache.thrift.scheme.TupleScheme;
import org.apache.thrift.protocol.TTupleProtocol;
import org.apache.thrift.protocol.TProtocolException;
import org.apache.thrift.EncodingUtils;
import org.apache.thrift.TException;
import org.apache.thrift.async.AsyncMethodCallback;
import org.apache.thrift.server.AbstractNonblockingServer.*;
import java.util.List;
import java.util.ArrayList;
import java.util.Map;
import java.util.HashMap;
import java.util.EnumMap;
import java.util.Set;
import java.util.HashSet;
import java.util.EnumSet;
import java.util.Collections;
import java.util.BitSet;
import java.nio.ByteBuffer;
import java.util.Arrays;
import javax.annotation.Generated;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
@SuppressWarnings({"cast", "rawtypes", "serial", "unchecked"})
@Generated(value = "Autogenerated by Thrift Compiler (0.9.3)", date = "2020-09-12")
public class TPaloBrokerService {
public interface Iface {
public TBrokerListResponse listPath(TBrokerListPathRequest request) throws org.apache.thrift.TException;
public TBrokerOperationStatus deletePath(TBrokerDeletePathRequest request) throws org.apache.thrift.TException;
public TBrokerOperationStatus renamePath(TBrokerRenamePathRequest request) throws org.apache.thrift.TException;
public TBrokerCheckPathExistResponse checkPathExist(TBrokerCheckPathExistRequest request) throws org.apache.thrift.TException;
public TBrokerOpenReaderResponse openReader(TBrokerOpenReaderRequest request) throws org.apache.thrift.TException;
public TBrokerReadResponse pread(TBrokerPReadRequest request) throws org.apache.thrift.TException;
public TBrokerOperationStatus seek(TBrokerSeekRequest request) throws org.apache.thrift.TException;
public TBrokerOperationStatus closeReader(TBrokerCloseReaderRequest request) throws org.apache.thrift.TException;
public TBrokerOpenWriterResponse openWriter(TBrokerOpenWriterRequest request) throws org.apache.thrift.TException;
public TBrokerOperationStatus pwrite(TBrokerPWriteRequest request) throws org.apache.thrift.TException;
public TBrokerOperationStatus closeWriter(TBrokerCloseWriterRequest request) throws org.apache.thrift.TException;
public TBrokerOperationStatus ping(TBrokerPingBrokerRequest request) throws org.apache.thrift.TException;
}
public interface AsyncIface {
public void listPath(TBrokerListPathRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void deletePath(TBrokerDeletePathRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void renamePath(TBrokerRenamePathRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void checkPathExist(TBrokerCheckPathExistRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void openReader(TBrokerOpenReaderRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void pread(TBrokerPReadRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void seek(TBrokerSeekRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void closeReader(TBrokerCloseReaderRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void openWriter(TBrokerOpenWriterRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void pwrite(TBrokerPWriteRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void closeWriter(TBrokerCloseWriterRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
public void ping(TBrokerPingBrokerRequest request, org.apache.thrift.async.AsyncMethodCallback resultHandler) throws org.apache.thrift.TException;
}
public static class Client extends org.apache.thrift.TServiceClient implements Iface {
public static class Factory implements org.apache.thrift.TServiceClientFactory<Client> {
public Factory() {}
public Client getClient(org.apache.thrift.protocol.TProtocol prot) {
return new Client(prot);
}
public Client getClient(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
return new Client(iprot, oprot);
}
}
public Client(org.apache.thrift.protocol.TProtocol prot)
{
super(prot, prot);
}
public Client(org.apache.thrift.protocol.TProtocol iprot, org.apache.thrift.protocol.TProtocol oprot) {
super(iprot, oprot);
}
public TBrokerListResponse listPath(TBrokerListPathRequest request) throws org.apache.thrift.TException
{
send_listPath(request);
return recv_listPath();
}
public void send_listPath(TBrokerListPathRequest request) throws org.apache.thrift.TException
{
listPath_args args = new listPath_args();
args.setRequest(request);
sendBase("listPath", args);
}
public TBrokerListResponse recv_listPath() throws org.apache.thrift.TException
{
listPath_result result = new listPath_result();
receiveBase(result, "listPath");
if (result.isSetSuccess()) {
return result.success;
}
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "listPath failed: unknown result");
}
public TBrokerOperationStatus deletePath(TBrokerDeletePathRequest request) throws org.apache.thrift.TException
{
send_deletePath(request);
return recv_deletePath();
}
public void send_deletePath(TBrokerDeletePathRequest request) throws org.apache.thrift.TException
{
deletePath_args args = new deletePath_args();
args.setRequest(request);
sendBase("deletePath", args);
}
public TBrokerOperationStatus recv_deletePath() throws org.apache.thrift.TException
{
deletePath_result result = new deletePath_result();
receiveBase(result, "deletePath");
if (result.isSetSuccess()) {
return result.success;
}
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "deletePath failed: unknown result");
}
public TBrokerOperationStatus renamePath(TBrokerRenamePathRequest request) throws org.apache.thrift.TException
{
send_renamePath(request);
return recv_renamePath();
}
public void send_renamePath(TBrokerRenamePathRequest request) throws org.apache.thrift.TException
{
renamePath_args args = new renamePath_args();
args.setRequest(request);
sendBase("renamePath", args);
}
public TBrokerOperationStatus recv_renamePath() throws org.apache.thrift.TException
{
renamePath_result result = new renamePath_result();
receiveBase(result, "renamePath");
if (result.isSetSuccess()) {
return result.success;
}
throw new org.apache.thrift.TApplicationException(org.apache.thrift.TApplicationException.MISSING_RESULT, "renamePath failed: unknown result");
}
public TBrokerCheckPathExistResponse checkPathExist(TBrokerCheckPathExistRequest request) throws org.apache.thrift.TException
{
send_checkPathExist(request);
return recv
没有合适的资源?快使用搜索试试~ 我知道了~
apache-doris-0.12.0-incubating-src.tar.gz-hdfs_broker.zip 编译ok
共596个文件
class:371个
jar:164个
java:40个
需积分: 9 0 下载量 198 浏览量
2021-12-07
14:33:02
上传
评论
收藏 101.65MB ZIP 举报
温馨提示
apache-doris-0.12.0-incubating-src.tar.gz-hdfs_broker.zip 编译ok
资源详情
资源评论
资源推荐
收起资源包目录
apache-doris-0.12.0-incubating-src.tar.gz-hdfs_broker.zip 编译ok (596个子文件)
FileSystemManager.class 24KB
TBrokerOpenReaderRequest.class 17KB
TBrokerOpenWriterRequest.class 17KB
TBrokerListPathRequest.class 17KB
TBrokerRenamePathRequest.class 16KB
TBrokerPWriteRequest.class 15KB
TPaloBrokerService$Client.class 15KB
TBrokerPReadRequest.class 15KB
TBrokerCheckPathExistRequest.class 14KB
TBrokerDeletePathRequest.class 14KB
TBrokerFileStatus.class 14KB
TBrokerOpenReaderResponse.class 14KB
TBrokerSeekRequest.class 13KB
TBrokerListResponse.class 13KB
HDFSBrokerServiceImpl.class 13KB
TBrokerCheckPathExistResponse.class 12KB
TBrokerReadResponse.class 12KB
TBrokerCloseReaderRequest.class 12KB
TBrokerCloseWriterRequest.class 12KB
TBrokerOpenWriterResponse.class 12KB
TBrokerPingBrokerRequest.class 12KB
TBrokerOperationStatus.class 12KB
TPaloBrokerService$1.class 12KB
TBrokerFD.class 11KB
TPaloBrokerService$checkPathExist_result.class 11KB
TPaloBrokerService$checkPathExist_args.class 10KB
TPaloBrokerService$closeWriter_result.class 10KB
TPaloBrokerService$closeReader_result.class 10KB
TPaloBrokerService$openWriter_result.class 10KB
TPaloBrokerService$openReader_result.class 10KB
TPaloBrokerService$renamePath_result.class 10KB
TPaloBrokerService$deletePath_result.class 10KB
TPaloBrokerService$closeWriter_args.class 10KB
TPaloBrokerService$closeReader_args.class 10KB
TPaloBrokerService$openWriter_args.class 10KB
TPaloBrokerService$renamePath_args.class 10KB
TPaloBrokerService$openReader_args.class 10KB
TPaloBrokerService$deletePath_args.class 10KB
TPaloBrokerService$listPath_result.class 10KB
TPaloBrokerService$pwrite_result.class 10KB
TPaloBrokerService$listPath_args.class 10KB
TPaloBrokerService$pread_result.class 10KB
TPaloBrokerService$ping_result.class 10KB
TPaloBrokerService$seek_result.class 10KB
TPaloBrokerService$pwrite_args.class 10KB
TPaloBrokerService$ping_args.class 10KB
TPaloBrokerService$pread_args.class 10KB
TPaloBrokerService$seek_args.class 10KB
TPaloBrokerService$AsyncClient.class 10KB
TestFileSystemManager.class 7KB
ClientContextManager.class 7KB
ConfigBase.class 7KB
LoggerMessageFormat.class 6KB
TBrokerOpenReaderRequest$TBrokerOpenReaderRequestStandardScheme.class 5KB
TBrokerListPathRequest$TBrokerListPathRequestStandardScheme.class 5KB
TBrokerOpenWriterRequest$TBrokerOpenWriterRequestStandardScheme.class 5KB
TBrokerRenamePathRequest$TBrokerRenamePathRequestStandardScheme.class 5KB
TBrokerCheckPathExistRequest$TBrokerCheckPathExistRequestStandardScheme.class 5KB
TBrokerDeletePathRequest$TBrokerDeletePathRequestStandardScheme.class 5KB
ThriftServer.class 4KB
ClientContextManager$ClientResourceContext.class 4KB
TBrokerPWriteRequest$TBrokerPWriteRequestStandardScheme.class 4KB
TBrokerPReadRequest$TBrokerPReadRequestStandardScheme.class 4KB
BrokerBootstrap.class 4KB
TBrokerListPathRequest$TBrokerListPathRequestTupleScheme.class 4KB
TBrokerListResponse$TBrokerListResponseStandardScheme.class 4KB
TBrokerFileStatus$TBrokerFileStatusStandardScheme.class 4KB
TBrokerSeekRequest$TBrokerSeekRequestStandardScheme.class 4KB
TPaloBrokerService$AsyncProcessor$checkPathExist.class 4KB
TBrokerOpenWriterRequest$TBrokerOpenWriterRequestTupleScheme.class 4KB
TPaloBrokerService$AsyncProcessor.class 4KB
TPaloBrokerService$AsyncProcessor$closeWriter.class 4KB
TPaloBrokerService$AsyncProcessor$closeReader.class 4KB
TPaloBrokerService$AsyncProcessor$openWriter.class 4KB
TPaloBrokerService$AsyncProcessor$openReader.class 4KB
TPaloBrokerService$AsyncProcessor$renamePath.class 4KB
TPaloBrokerService$AsyncProcessor$deletePath.class 4KB
TBrokerOpenReaderRequest$TBrokerOpenReaderRequestTupleScheme.class 4KB
TPaloBrokerService$AsyncProcessor$listPath.class 4KB
TPaloBrokerService$AsyncProcessor$pwrite.class 4KB
TPaloBrokerService$AsyncProcessor$ping.class 4KB
TPaloBrokerService$AsyncProcessor$pread.class 4KB
TPaloBrokerService$AsyncProcessor$seek.class 4KB
TBrokerCheckPathExistResponse$TBrokerCheckPathExistResponseStandardScheme.class 4KB
TPaloBrokerService$Processor.class 4KB
TBrokerRenamePathRequest$TBrokerRenamePathRequestTupleScheme.class 4KB
TPaloBrokerService$AsyncClient$checkPathExist_call.class 4KB
TBrokerCheckPathExistRequest$TBrokerCheckPathExistRequestTupleScheme.class 3KB
TPaloBrokerService$AsyncClient$closeWriter_call.class 3KB
TPaloBrokerService$AsyncClient$closeReader_call.class 3KB
TPaloBrokerService$AsyncClient$openReader_call.class 3KB
TPaloBrokerService$AsyncClient$openWriter_call.class 3KB
TPaloBrokerService$AsyncClient$deletePath_call.class 3KB
TPaloBrokerService$AsyncClient$renamePath_call.class 3KB
TBrokerOpenReaderResponse$TBrokerOpenReaderResponseStandardScheme.class 3KB
TPaloBrokerService$AsyncClient$listPath_call.class 3KB
TBrokerDeletePathRequest$TBrokerDeletePathRequestTupleScheme.class 3KB
TPaloBrokerService$AsyncProcessor$checkPathExist$1.class 3KB
TPaloBrokerService$AsyncClient$pwrite_call.class 3KB
TPaloBrokerService$AsyncClient$ping_call.class 3KB
共 596 条
- 1
- 2
- 3
- 4
- 5
- 6
数据修行
- 粉丝: 1
- 资源: 2
上传资源 快速赚钱
- 我的内容管理 展开
- 我的资源 快来上传第一个资源
- 我的收益 登录查看自己的收益
- 我的积分 登录查看自己的积分
- 我的C币 登录后查看C币余额
- 我的收藏
- 我的下载
- 下载帮助
安全验证
文档复制为VIP权益,开通VIP直接复制
信息提交成功
评论0