Package sherpa.server

Examples of sherpa.server.DummySherpaServer.shutdown()

53
54
55
56
57
58
59
60
61
62
63
           
      logger.info("Read {} rows", counter);
      Assert.assertEquals(resultRows, counter);
     
    } finally {
      server.shutdown();
    }
  }

  @Test
  public void testIterator() throws Exception {
View Full Code Here
97
98
99
100
101
102
103
104
105
106
      }
    } catch (Throwable t) {
      t.printStackTrace();
      throw t;
    } finally {
      server.shutdown();
    }   
  }
}
 
View Full Code Here
99
100
101
102
103
104
105
106
107
108
109
     
      logger.info("Read {} rows", counter);
      Assert.assertEquals(resultRows, counter);

    } finally {
      server.shutdown();
    }
  }
 
  public void helpCheckRows(List<Map<String,RDFNode>> data, int size) {
    Assert.assertEquals(size, data.size());
View Full Code Here
126
127
128
129
130
131
132
133
134
135
136
      while (iter.hasNext()) {
        data.add(iter.next());
      }
      helpCheckRows(data, rows);
    } finally {
      server.shutdown();
    }
  }
 
  public void helpTestIteratorParanoid(int rows, int batchSize) {
    DummySherpaServer server = new DummySherpaServer(rows);
View Full Code Here
146
147
148
149
150
151
152
153
154
155
156
        data.add(iter.next());
        Assert.assertEquals(data.size() < rows, iter.hasNext());
      }
      helpCheckRows(data, rows);
    } finally {
      server.shutdown();
    }
  }
 
  public void helpTestIteratorCount(int rows, int batchSize) {
    DummySherpaServer server = new DummySherpaServer(rows);
View Full Code Here
164
165
166
167
168
169
170
171
172
173
174
        data.add(iter.next());
      }
      Assert.assertFalse(iter.hasNext());
      helpCheckRows(data, rows);
    } finally {
      server.shutdown();
    }
  }
 
  @Test
  public void testCursor() {
View Full Code Here
204
205
206
207
208
209
210
211
212
213
214
      // Kind of tricky here - the keys and values are now Avro Utf8 instances which don't compare equal to Strings
      Map<CharSequence,CharSequence> serverProps = (Map<CharSequence,CharSequence>)results.get(0);
      Assert.assertEquals(new Utf8("1234"), serverProps.get(new Utf8(QueryExecution.TIMEOUT)));
     
    } finally {
      server.shutdown();
    }

  }
 
  @Test
View Full Code Here
243
244
245
246
247
248
249
250
251
252
253
      Assert.assertEquals(lit2, s.getLiteral("c"));     
      Assert.assertEquals(20, s.getInt("c"));
     
      Assert.assertFalse(s.next());
    } finally {
      server.shutdown();
    }
  }
 
  @Test
  public void testDatatypes() {
View Full Code Here
342
343
344
345
346
347
348
349
350
351
352
      Assert.assertNull(s.getLiteral(var));
      Assert.assertNull(s.getBlankNode(var));
     
      Assert.assertFalse(s.next());
    } finally {
      server.shutdown();
    }
  }
 
  @Test
  public void testIterator() {
View Full Code Here
TOP
Copyright © 2018 www.massapi.com. All rights reserved.
All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.