OmniSciDB  85c2d10cdc
 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Friends Macros Pages
Public Member Functions | Static Public Member Functions | Private Member Functions | Private Attributes | Static Private Attributes | List of all members
com.mapd.parser.server.test.TestServer Class Reference
+ Collaboration diagram for com.mapd.parser.server.test.TestServer:

Public Member Functions

void testThreadedCall ()
 
void testSimpleCall ()
 
void testRandomCall ()
 

Static Public Member Functions

static void startServer ()
 
static void stopServer ()
 

Private Member Functions

void randomCalciteCall ()
 
void callCalciteCheck (String query, String result)
 

Private Attributes

volatile int threadsRun = 0
 
volatile boolean threadHadFailure = false
 
volatile AssertionError ae
 

Static Private Attributes

static final Logger MAPDLOGGER = LoggerFactory.getLogger(TestServer.class)
 
static final int TEST_THREAD_COUNT = 3
 
static CalciteServerWrapper csw = null
 
static SockTransportProperties client_skT = null
 
static SockTransportProperties server_skT = null
 

Detailed Description

Definition at line 43 of file TestServer.java.

Member Function Documentation

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().

240  {
241  try {
242  TTransport transport;
243  transport = new TSocket("localhost", 11000);
244  transport.open();
245  TProtocol protocol = new TBinaryProtocol(transport);
246  CalciteServer.Client client = new CalciteServer.Client(protocol);
247  TPlanResult algebra = client.process("user",
248  "passwd",
249  "SALES",
250  query,
251  new ArrayList<>(),
252  false,
253  false,
254  false,
255  null);
256  transport.close();
257  try {
258  assertEquals(algebra.plan_result, result);
259  } catch (AssertionError s) {
260  MAPDLOGGER.error("error during callCalciteCheck");
261  throw s;
262  }
263  } catch (TException x) {
264  fail("Exception occurred " + x.toString());
265  }
266  }
run_benchmark_import.result
dictionary result
Definition: run_benchmark_import.py:441

+ Here is the caller graph for this function:

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(), and test_fsi.r.

Referenced by com.mapd.parser.server.test.TestServer.testRandomCall(), and com.mapd.parser.server.test.TestServer.testThreadedCall().

147  {
148  Random r = new Random();
149  int aliasID = r.nextInt(100000) + 1000000;
150  callCalciteCheck(
151  String.format(
152  "Select TABALIAS%d.ENAME AS COLALIAS%d from EMP TABALIAS%d LIMIT %d",
153  aliasID,
154  aliasID,
155  aliasID,
156  aliasID),
157  String.format("{\n"
158  + " \"rels\": [\n"
159  + " {\n"
160  + " \"id\": \"0\",\n"
161  + " \"relOp\": \"LogicalTableScan\",\n"
162  + " \"fieldNames\": [\n"
163  + " \"EMPNO\",\n"
164  + " \"ENAME\",\n"
165  + " \"JOB\",\n"
166  + " \"MGR\",\n"
167  + " \"HIREDATE\",\n"
168  + " \"SAL\",\n"
169  + " \"COMM\",\n"
170  + " \"DEPTNO\",\n"
171  + " \"SLACKER\",\n"
172  + " \"SLACKARR1\",\n"
173  + " \"SLACKARR2\"\n"
174  + " ],\n"
175  + " \"table\": [\n"
176  + " \"CATALOG\",\n"
177  + " \"SALES\",\n"
178  + " \"EMP\"\n"
179  + " ],\n"
180  + " \"inputs\": []\n"
181  + " },\n"
182  + " {\n"
183  + " \"id\": \"1\",\n"
184  + " \"relOp\": \"LogicalProject\",\n"
185  + " \"fields\": [\n"
186  + " \"COLALIAS%d\"\n"
187  + " ],\n"
188  + " \"exprs\": [\n"
189  + " {\n"
190  + " \"input\": 1\n"
191  + " }\n"
192  + " ]\n"
193  + " },\n"
194  + " {\n"
195  + " \"id\": \"2\",\n"
196  + " \"relOp\": \"LogicalSort\",\n"
197  + " \"collation\": [],\n"
198  + " \"fetch\": {\n"
199  + " \"literal\": %d,\n"
200  + " \"type\": \"DECIMAL\",\n"
201  + " \"scale\": 0,\n"
202  + " \"precision\": 7,\n"
203  + " \"type_scale\": 0,\n"
204  + " \"type_precision\": 10\n"
205  + " }\n"
206  + " },\n"
207  + " {\n"
208  + " \"id\": \"3\",\n"
209  + " \"relOp\": \"LogicalProject\",\n"
210  + " \"fields\": [\n"
211  + " \"COLALIAS%d\"\n"
212  + " ],\n"
213  + " \"exprs\": [\n"
214  + " {\n"
215  + " \"input\": 0\n"
216  + " }\n"
217  + " ]\n"
218  + " },\n"
219  + " {\n"
220  + " \"id\": \"4\",\n"
221  + " \"relOp\": \"LogicalSort\",\n"
222  + " \"collation\": [],\n"
223  + " \"fetch\": {\n"
224  + " \"literal\": %d,\n"
225  + " \"type\": \"DECIMAL\",\n"
226  + " \"scale\": 0,\n"
227  + " \"precision\": 7,\n"
228  + " \"type_scale\": 0,\n"
229  + " \"type_precision\": 10\n"
230  + " }\n"
231  + " }\n"
232  + " ]\n"
233  + "}",
234  aliasID,
235  aliasID,
236  aliasID,
237  aliasID));
238  }
test_fsi.r
tuple r
Definition: test_fsi.py:16
com.mapd.parser.server.test.TestServer.callCalciteCheck
void callCalciteCheck(String query, String result)
Definition: TestServer.java:240

+ Here is the call graph for this function:

+ Here is the caller graph for this function:

static void com.mapd.parser.server.test.TestServer.startServer ( )
inlinestatic

Definition at line 54 of file TestServer.java.

References com.mapd.parser.server.test.TestServer.client_skT, com.mapd.parser.server.test.TestServer.csw, and com.mapd.parser.server.test.TestServer.server_skT.

54  {
55  csw = new CalciteServerWrapper(11000, 11001, "/data", null, client_skT, server_skT);
56  new Thread(csw).start();
57  }
com.mapd.parser.server.test.TestServer.csw
static CalciteServerWrapper csw
Definition: TestServer.java:49
com.mapd.parser.server.test.TestServer.client_skT
static SockTransportProperties client_skT
Definition: TestServer.java:50
com.mapd.parser.server.test.TestServer.server_skT
static SockTransportProperties server_skT
Definition: TestServer.java:51
static void com.mapd.parser.server.test.TestServer.stopServer ( )
inlinestatic

Definition at line 60 of file TestServer.java.

60  {
61  csw.stopServer();
62  }
void com.mapd.parser.server.test.TestServer.testRandomCall ( )
inline

Definition at line 143 of file TestServer.java.

References com.mapd.parser.server.test.TestServer.randomCalciteCall().

143  {
144  randomCalciteCall();
145  }

+ Here is the call graph for this function:

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().

99  {
100  callCalciteCheck("Select ENAME from EMP",
101  "{\n"
102  + " \"rels\": [\n"
103  + " {\n"
104  + " \"id\": \"0\",\n"
105  + " \"relOp\": \"LogicalTableScan\",\n"
106  + " \"fieldNames\": [\n"
107  + " \"EMPNO\",\n"
108  + " \"ENAME\",\n"
109  + " \"JOB\",\n"
110  + " \"MGR\",\n"
111  + " \"HIREDATE\",\n"
112  + " \"SAL\",\n"
113  + " \"COMM\",\n"
114  + " \"DEPTNO\",\n"
115  + " \"SLACKER\",\n"
116  + " \"SLACKARR1\",\n"
117  + " \"SLACKARR2\"\n"
118  + " ],\n"
119  + " \"table\": [\n"
120  + " \"CATALOG\",\n"
121  + " \"SALES\",\n"
122  + " \"EMP\"\n"
123  + " ],\n"
124  + " \"inputs\": []\n"
125  + " },\n"
126  + " {\n"
127  + " \"id\": \"1\",\n"
128  + " \"relOp\": \"LogicalProject\",\n"
129  + " \"fields\": [\n"
130  + " \"ENAME\"\n"
131  + " ],\n"
132  + " \"exprs\": [\n"
133  + " {\n"
134  + " \"input\": 1\n"
135  + " }\n"
136  + " ]\n"
137  + " }\n"
138  + " ]\n"
139  + "}");
140  }
com.mapd.parser.server.test.TestServer.callCalciteCheck
void callCalciteCheck(String query, String result)
Definition: TestServer.java:240

+ Here is the call graph for this function:

void com.mapd.parser.server.test.TestServer.testThreadedCall ( )
inline

Definition at line 65 of file TestServer.java.

References com.mapd.parser.server.test.TestServer.ae, i, test_fsi.r, com.mapd.parser.server.test.TestServer.randomCalciteCall(), run, com.mapd.parser.server.test.TestServer.TEST_THREAD_COUNT, com.mapd.parser.server.test.TestServer.threadHadFailure, and com.mapd.parser.server.test.TestServer.threadsRun.

65  {
66  final ExecutorService pool = Executors.newFixedThreadPool(TEST_THREAD_COUNT);
67 
68  Runnable r = new Runnable() {
69  @Override
70  public void run() {
71  try {
72  for (int i = 1; i <= 5; i++) {
73  randomCalciteCall();
74  }
75  } catch (AssertionError x) {
76  MAPDLOGGER.error("error during Runnable");
77  threadHadFailure = true;
78  ae = x;
79  }
80  threadsRun++;
81  if (threadsRun >= TEST_THREAD_COUNT) {
82  pool.shutdown();
83  }
84  }
85  };
86 
87  for (int i = 0; i < TEST_THREAD_COUNT; i++) {
88  pool.submit(r);
89  }
90  while (!pool.isShutdown()) {
91  // stay alive
92  }
93  if (threadHadFailure) {
94  throw ae;
95  }
96  }
test_fsi.r
tuple r
Definition: test_fsi.py:16
i
int i
Definition: Parser_wnd_pregen.cpp:2082
run
static bool run
Definition: KafkaImporter.cpp:50

+ Here is the call graph for this function:

Member Data Documentation

volatile AssertionError com.mapd.parser.server.test.TestServer.ae
private

Definition at line 48 of file TestServer.java.

Referenced by com.mapd.parser.server.test.TestServer.testThreadedCall().

SockTransportProperties com.mapd.parser.server.test.TestServer.client_skT = null
staticprivate

Definition at line 50 of file TestServer.java.

Referenced by com.mapd.parser.server.test.TestServer.startServer().

CalciteServerWrapper com.mapd.parser.server.test.TestServer.csw = null
staticprivate

Definition at line 49 of file TestServer.java.

Referenced by com.mapd.parser.server.test.TestServer.startServer().

final Logger com.mapd.parser.server.test.TestServer.MAPDLOGGER = LoggerFactory.getLogger(TestServer.class)
staticprivate

Definition at line 44 of file TestServer.java.

SockTransportProperties com.mapd.parser.server.test.TestServer.server_skT = null
staticprivate

Definition at line 51 of file TestServer.java.

Referenced by com.mapd.parser.server.test.TestServer.startServer().

final int com.mapd.parser.server.test.TestServer.TEST_THREAD_COUNT = 3
staticprivate

Definition at line 45 of file TestServer.java.

Referenced by com.mapd.parser.server.test.TestServer.testThreadedCall().

volatile boolean com.mapd.parser.server.test.TestServer.threadHadFailure = false
private

Definition at line 47 of file TestServer.java.

Referenced by com.mapd.parser.server.test.TestServer.testThreadedCall().

volatile int com.mapd.parser.server.test.TestServer.threadsRun = 0
private

Definition at line 46 of file TestServer.java.

Referenced by com.mapd.parser.server.test.TestServer.testThreadedCall().

The documentation for this class was generated from the following file: