/**
* 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个子文件） 
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
评论0