import org.apache.tajo.rpc.RpcClient; public class RpcClientExample { private RpcClient rpcClient; public RpcClientExample() { rpcClient = new RpcClient(); } public void sendMessage(String message) { rpcClient.sendMessage(message); } }