- 首页 > it技术 > >
import org.apache.hadoop.hive.common.auth.HiveAuthUtils;
import org.apache.hive.service.rpc.thrift.TCLIService;
import org.apache.thrift.protocol.TBinaryProtocol;
import org.apache.thrift.server.TThreadPoolServer;
import org.apache.thrift.transport.*;
import java.util.concurrent.TimeUnit;
public class MyHiveServer {public static void main(String[] args) throws Exception{//PlainSaslHelper.getPlainTransportFactory//TSaslServerTransport.Factory saslFactory = new TSaslServerTransport.Factory();
//
//saslFactory.addServerDefinition("PLAIN", "CUSTOM", null, new HashMap(),new PlainSaslHelper.PlainServerCallbackHandler("CUSTOM"))//源码HiveAuthFactory 第160行try {
System.out.println("服务端开启");
//transportFactory = new TTransportFactory();
TCLIService.Processor processor = new TCLIService.Processor<>(new ServiceFaceImpl());
TServerSocket serverSocket = HiveAuthUtils.getServerSocket("127.0.0.1", 10000);
TThreadPoolServer.Args sargs = new TThreadPoolServer.Args(serverSocket).processor(processor)
.transportFactory(new TTransportFactory()).protocolFactory(new TBinaryProtocol.Factory())
.inputProtocolFactory(new TBinaryProtocol.Factory(true, true, 100*1024*1024, 100*1024*1024))
.requestTimeout(100000).requestTimeoutUnit(TimeUnit.SECONDS);
TThreadPoolServer server = new TThreadPoolServer(sargs);
// TCP Server
server.serve();
} catch (TTransportException e) {
e.printStackTrace();
}System.out.println("服务端已启动：10000");
}}
public class ServiceFaceImpl implements TCLIService.Iface {
private static final TStatus OK_STATUS = new TStatus(TStatusCode.SUCCESS_STATUS);
@Override
public TOpenSessionResp OpenSession(TOpenSessionReq req) throws TException {TOpenSessionResp resp = new TOpenSessionResp();
TSessionHandle tSessionHandle = new TSessionHandle(new HandleIdentifier().toTHandleIdentifier());
resp.setSessionHandle(tSessionHandle);
System.out.println("OpenSession");
HashMap configurationMap = new HashMap<>();
configurationMap.put("","");
resp.setConfiguration(configurationMap);
//resp.setServerProtocolVersion(TProtocolVersion.HIVE_CLI_SERVICE_PROTOCOL_V9);
resp.setStatus(OK_STATUS);
return resp;
}@Override
public TCloseSessionResp CloseSession(TCloseSessionReq req) throws TException {
System.out.println("CloseSession");
return null;
}@Override
public TGetInfoResp GetInfo(TGetInfoReq req) throws TException {
System.out.println("GetInfo");
return null;
}@Override
public TExecuteStatementResp ExecuteStatement(TExecuteStatementReq req) throws TException {String statement = req.getStatement();
System.out.println(statement);
System.out.println("ExecuteStatement");
return null;
}@Override
public TGetTypeInfoResp GetTypeInfo(TGetTypeInfoReq req) throws TException {
return null;
}@Override
public TGetCatalogsResp GetCatalogs(TGetCatalogsReq req) throws TException {
return null;
}@Override
public TGetSchemasResp GetSchemas(TGetSchemasReq req) throws TException {
return null;
}@Override
public TGetTablesResp GetTables(TGetTablesReq req) throws TException {
return null;
}@Override
public TGetTableTypesResp GetTableTypes(TGetTableTypesReq req) throws TException {
return null;
}@Override
public TGetColumnsResp GetColumns(TGetColumnsReq req) throws TException {
return null;
}@Override
public TGetFunctionsResp GetFunctions(TGetFunctionsReq req) throws TException {
return null;
}@Override
public TGetPrimaryKeysResp GetPrimaryKeys(TGetPrimaryKeysReq req) throws TException {
return null;
}@Override
public TGetCrossReferenceResp GetCrossReference(TGetCrossReferenceReq req) throws TException {
return null;
}@Override
public TGetOperationStatusResp GetOperationStatus(TGetOperationStatusReq req) throws TException {
return null;
}@Override
public TCancelOperationResp CancelOperation(TCancelOperationReq req) throws TException {
return null;
}@Override
public TCloseOperationResp CloseOperation(TCloseOperationReq req) throws TException {
return null;
}@Override
public TGetResultSetMetadataResp GetResultSetMetadata(TGetResultSetMetadataReq req) throws TException {
return null;
}@Override
public TFetchResultsResp FetchResults(TFetchResultsReq req) throws TException {
return null;
}@Override
public TGetDelegationTokenResp GetDelegationToken(TGetDelegationTokenReq req) throws TException {
return null;
}@Override
public TCancelDelegationTokenResp CancelDelegationToken(TCancelDelegationTokenReq req) throws TException {
return null;
}@Override
public TRenewDelegationTokenResp RenewDelegationToken(TRenewDelegationTokenReq req) throws TException {
return null;
}
}
推荐阅读
