public class SimpleRiverDataTests extends AbstractSimpleRiverTest
context, sourcecluster, index, logger, type| Constructor and Description |
|---|
SimpleRiverDataTests() |
| Modifier and Type | Method and Description |
|---|---|
SimpleRiverContext |
newRiverContext() |
RiverSource |
newRiverSource() |
void |
testSimpleRiverMaxrows(String riverResource,
String sql)
Product table
|
void |
testSimpleRiverOnce(String riverResource,
String sql)
Start the river and execute a simple star query
|
void |
testSimpleRiverRandom(String riverResource,
String sql)
Product table (star query)
|
afterMethod, beforeMethod, createRandomProducts, createRandomProductsJob, createRiver, createTimestampedLogs, performRiver, waitForActiveRiver, waitForActiveRiver, waitForInactiveRiver, waitForInactiveRiver, waitForRiver, waitForRiverassertHits, assertTimestampSort, buildNode, client, getClusterName, getNodeSettings, setClusterName, startNode, startNodes, stopNodes, waitForYellowassertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEquals, assertEqualsNoOrder, assertEqualsNoOrder, assertFalse, assertFalse, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertTrue, assertTrue, fail, fail, failpublic SimpleRiverDataTests()
public RiverSource newRiverSource()
newRiverSource in class AbstractSimpleRiverTestpublic SimpleRiverContext newRiverContext()
newRiverContext in class AbstractSimpleRiverTestpublic void testSimpleRiverOnce(String riverResource, String sql) throws Exception
Exception - if test failspublic void testSimpleRiverRandom(String riverResource, String sql) throws Exception
riverResource - the river resourceException - if test failspublic void testSimpleRiverMaxrows(String riverResource, String sql) throws Exception
riverResource - the riversql - the SQL statementException - if test failselasticsearch-river-jdbc