import org.apache.tajo.ipc.TajoWorkerProtocol; import org.apache.tajo.rpc.NettyClientBase; public class DistributedComputationExample { public static void main(String[] args) throws Exception { NettyClientBase rpcClient = new NettyClientBase(); String serverAddress = "127.0.0.1"; int serverPort = 12345; TajoWorkerProtocol.WorkerProtocolService.BlockingInterface tajoRpcService = rpcClient.getStub(serverAddress, serverPort, TajoWorkerProtocol.WorkerProtocolService.BlockingInterface.class); // ... rpcClient.close(); } }