"import org.apache.thrift.protocol.TTupleProtocol;\n" +
"import org.apache.thrift.protocol.TProtocolException;\n" +
"import org.apache.thrift.EncodingUtils;\n" +
+ "import org.apache.thrift.TException;\n" +
"import java.util.List;\n" +
"import java.util.ArrayList;\n" +
"import java.util.Map;\n" +
(in_class ? "static " : "") << "class " << tstruct->get_name() << " ";
if (is_exception) {
- out << "extends Exception ";
+ out << "extends TException ";
}
out << "implements org.apache.thrift.TBase<" << tstruct->get_name() << ", " << tstruct->get_name() << "._Fields>, java.io.Serializable, Cloneable";
private Thread serverThread;
private TServer server;
- private static final int NUM_QUERIES = 10000;
+ private static final int NUM_QUERIES = 1000;
protected TServer getServer(TProcessor processor, TNonblockingServerSocket socket, TProtocolFactory protoFactory, TTransportFactory factory) {
final Args args = new Args(socket).processor(processor).protocolFactory(protoFactory);