Definition at line 43 of file TestServer.java.
void com.mapd.parser.server.test.TestServer.callCalciteCheck |
( |
String |
query, |
|
|
String |
result |
|
) |
| |
|
inlineprivate |
Definition at line 240 of file TestServer.java.
Referenced by com.mapd.parser.server.test.TestServer.randomCalciteCall(), and com.mapd.parser.server.test.TestServer.testSimpleCall().
242 TTransport transport;
243 transport =
new TSocket(
"localhost", 11000);
245 TProtocol protocol =
new TBinaryProtocol(transport);
246 CalciteServer.Client client =
new CalciteServer.Client(protocol);
247 TPlanResult algebra = client.process(
248 "user",
"passwd",
"SALES", query,
new ArrayList<>(),
false,
false,
false);
251 assertEquals(algebra.plan_result,
result);
252 }
catch (AssertionError s) {
253 MAPDLOGGER.error(
"error during callCalciteCheck");
256 }
catch (TException x) {
257 fail(
"Exception occurred " + x.toString());
void com.mapd.parser.server.test.TestServer.randomCalciteCall |
( |
| ) |
|
|
inlineprivate |
Definition at line 147 of file TestServer.java.
References com.mapd.parser.server.test.TestServer.callCalciteCheck().
Referenced by com.mapd.parser.server.test.TestServer.testRandomCall(), and com.mapd.parser.server.test.TestServer.testThreadedCall().
148 Random r =
new Random();
149 int aliasID = r.nextInt(100000) + 1000000;
152 "Select TABALIAS%d.ENAME AS COLALIAS%d from EMP TABALIAS%d LIMIT %d",
160 +
" \"id\": \"0\",\n"
161 +
" \"relOp\": \"LogicalTableScan\",\n"
162 +
" \"fieldNames\": [\n"
172 +
" \"SLACKARR1\",\n"
180 +
" \"inputs\": []\n"
183 +
" \"id\": \"1\",\n"
184 +
" \"relOp\": \"LogicalProject\",\n"
186 +
" \"COLALIAS%d\"\n"
195 +
" \"id\": \"2\",\n"
196 +
" \"relOp\": \"LogicalSort\",\n"
197 +
" \"collation\": [],\n"
199 +
" \"literal\": %d,\n"
200 +
" \"type\": \"DECIMAL\",\n"
202 +
" \"precision\": 7,\n"
203 +
" \"type_scale\": 0,\n"
204 +
" \"type_precision\": 10\n"
208 +
" \"id\": \"3\",\n"
209 +
" \"relOp\": \"LogicalProject\",\n"
211 +
" \"COLALIAS%d\"\n"
220 +
" \"id\": \"4\",\n"
221 +
" \"relOp\": \"LogicalSort\",\n"
222 +
" \"collation\": [],\n"
224 +
" \"literal\": %d,\n"
225 +
" \"type\": \"DECIMAL\",\n"
227 +
" \"precision\": 7,\n"
228 +
" \"type_scale\": 0,\n"
229 +
" \"type_precision\": 10\n"
void callCalciteCheck(String query, String result)
static void com.mapd.parser.server.test.TestServer.startServer |
( |
| ) |
|
|
inlinestatic |
static void com.mapd.parser.server.test.TestServer.stopServer |
( |
| ) |
|
|
inlinestatic |
void com.mapd.parser.server.test.TestServer.testRandomCall |
( |
| ) |
|
|
inline |
void com.mapd.parser.server.test.TestServer.testSimpleCall |
( |
| ) |
|
|
inline |
Definition at line 99 of file TestServer.java.
References com.mapd.parser.server.test.TestServer.callCalciteCheck().
104 +
" \"id\": \"0\",\n"
105 +
" \"relOp\": \"LogicalTableScan\",\n"
106 +
" \"fieldNames\": [\n"
116 +
" \"SLACKARR1\",\n"
124 +
" \"inputs\": []\n"
127 +
" \"id\": \"1\",\n"
128 +
" \"relOp\": \"LogicalProject\",\n"
void callCalciteCheck(String query, String result)
void com.mapd.parser.server.test.TestServer.testThreadedCall |
( |
| ) |
|
|
inline |
volatile AssertionError com.mapd.parser.server.test.TestServer.ae |
|
private |
final Logger com.mapd.parser.server.test.TestServer.MAPDLOGGER = LoggerFactory.getLogger(TestServer.class) |
|
staticprivate |
final int com.mapd.parser.server.test.TestServer.TEST_THREAD_COUNT = 3 |
|
staticprivate |
volatile boolean com.mapd.parser.server.test.TestServer.threadHadFailure = false |
|
private |
volatile int com.mapd.parser.server.test.TestServer.threadsRun = 0 |
|
private |
The documentation for this class was generated from the following file:
- /home/jenkins-slave/workspace/core-os-doxygen/java/calcite/src/test/java/com/mapd/parser/server/test/TestServer.java