Definition at line 40 of file TestMapDServer.java.
void com.mapd.parser.server.test.TestMapDServer.closeMapDConnection |
( |
ConnInfo |
conn | ) |
|
|
inlineprivate |
ConnInfo com.mapd.parser.server.test.TestMapDServer.createMapDConnection |
( |
| ) |
|
|
inlineprivate |
Definition at line 110 of file TestMapDServer.java.
Referenced by com.mapd.parser.server.test.TestMapDServer.testThreadedCall().
112 TTransport transport = null;
113 OmniSci.Client client = null;
115 transport =
new TSocket(
"localhost", 6274);
117 TProtocol protocol =
new TBinaryProtocol(transport);
118 client =
new OmniSci.Client(protocol);
119 session = client.connect(
"admin",
"HyperInteractive",
"omnisci");
120 }
catch (TException x) {
121 fail(
"Exception on create occurred " + x.toString());
123 return new ConnInfo(session, transport, client);
void com.mapd.parser.server.test.TestMapDServer.executeQuery |
( |
ConnInfo |
conn, |
|
|
String |
query, |
|
|
int |
resultCount |
|
) |
| |
|
inlineprivate |
Definition at line 126 of file TestMapDServer.java.
References run_benchmark_import.res.
Referenced by com.mapd.parser.server.test.TestMapDServer.randomMapDCall().
128 TQueryResult
res = conn.client.sql_execute(conn.session, query,
true, null, -1, -1);
129 if (resultCount != res.row_set.columns.get(0).nulls.size()) {
130 fail(
"result doesn't match " + resultCount
131 +
" != " + res.row_set.columns.get(0).nulls.size());
133 }
catch (TOmniSciException x) {
134 fail(
"Exception on EXECUTE " + x.toString());
135 }
catch (TException x) {
136 fail(
"Exception on EXECUTE " + x.toString());
void com.mapd.parser.server.test.TestMapDServer.randomMapDCall |
( |
ConnInfo |
conn | ) |
|
|
inlineprivate |
Definition at line 97 of file TestMapDServer.java.
References com.mapd.parser.server.test.TestMapDServer.executeQuery().
Referenced by com.mapd.parser.server.test.TestMapDServer.testThreadedCall().
98 Random r =
new Random();
99 int aliasID = r.nextInt(100000) + 1000000;
100 int limit = r.nextInt(20) + 1;
106 "SELECT date_trunc(day, arr_timestamp) as key0,CASE when carrier_name IN ('Southwest Airlines','American Airlines','Skywest Airlines','American Eagle Airlines','US Airways') then carrier_name ELSE 'other' END as key1,COUNT(*) AS val FROM flights_2008_7m WHERE (arr_timestamp >= TIMESTAMP(0) '2008-01-01 00:57:00' AND arr_timestamp < TIMESTAMP(0) '2009-01-01 18:27:00') GROUP BY key0, key1 ORDER BY key0,key1",
void executeQuery(ConnInfo conn, String query, int resultCount)
void com.mapd.parser.server.test.TestMapDServer.testThreadedCall |
( |
| ) |
|
|
inline |
volatile AssertionError com.mapd.parser.server.test.TestMapDServer.ae |
|
private |
final Logger com.mapd.parser.server.test.TestMapDServer.MAPDLOGGER = LoggerFactory.getLogger(TestMapDServer.class) |
|
staticprivate |
final int com.mapd.parser.server.test.TestMapDServer.TEST_THREAD_COUNT = 2 |
|
staticprivate |
volatile boolean com.mapd.parser.server.test.TestMapDServer.threadHadFailure = false |
|
private |
volatile int com.mapd.parser.server.test.TestMapDServer.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/TestMapDServer.java