protocol ExampleProtocol {
int add(int a, int b);
}
tajo-rpc-compiler.sh -idl example.proto
tajo-rpc-conf.xml
<configuration>
<tajo.rpc.client.protocol>avro</tajo.rpc.client.protocol>
<tajo.rpc.client.addr>localhost</tajo.rpc.client.addr>
<tajo.rpc.client.port>8080</tajo.rpc.client.port>
</configuration>
import tajo.rpc.example.ExampleProtocol;
import tajo.rpc.example.ExampleProtocolImpl;
import org.apache.tajo.rpc.NettyClientBase;
import org.apache.tajo.rpc.protocolrecords.PrimitiveProtos;
public class RPCClientExample {
public static void main(String[] args) throws Exception {
TajoProtos.IntegerProto integerValue = PrimitiveProtos.IntegerProto.newBuilder()
.setValue(10)
.build();
NettyClientBase client = new NettyClientBase();
ExampleProtocol proxy = client.getProxy(ExampleProtocol.class, ExampleProtocolImpl.class);
int result = proxy.add(integerValue);
System.out.println("Result: " + result);
}
}
tajo-rpc-conf.xml
<configuration>
<tajo.rpc.client.protocol>avro</tajo.rpc.client.protocol>
<tajo.rpc.client.addr>localhost</tajo.rpc.client.addr>
<tajo.rpc.client.port>8080</tajo.rpc.client.port>
</configuration>
