import org.apache.tajo.ipc.TajoClientProtocol; import org.apache.tajo.rpc.NettyClientBase; public class TajoClient { private NettyClientBase rpcClient; private TajoClientProtocol.TajoClientProtocolService.Interface stub; public TajoClient(String hostname, int port) { rpcClient = new NettyClientBase(); rpcClient.init(ConfVars.DEFAULT_CLIENT_RPC_MAX_IDLETIME, TajoConstants.DEFAULT_RETRY_NUM); stub = rpcClient.getStub(TajoClientProtocol.TajoClientProtocolService.Interface.class, new InetSocketAddress(hostname, port)); } public String getQueryResult(String query) { TajoClientProtocol.GetQueryResultResponse response = stub.getQueryResult(null, TajoClientProtocol.GetQueryResultRequest.newBuilder() .setQuery(query) .setQueryId(TajoIdUtils.createQueryId(System.currentTimeMillis(), 0)) .build()); } public void close() { rpcClient.close(); } }