public class SimpleRiverSourceTests extends AbstractSimpleRiverTest
context, sourcecluster, index, type| Constructor and Description |
|---|
SimpleRiverSourceTests() |
| Modifier and Type | Method and Description |
|---|---|
SimpleRiverContext |
newRiverContext() |
RiverSource |
newRiverSource() |
void |
testSimpleArray(String sql,
String res1,
String res2)
Test JDBC Array to structured object array
|
void |
testSimpleConnectionClose() |
void |
testSimpleNullInteger(String sql) |
void |
testSimpleSQL(String sql) |
void |
testSimpleStarQuery(String sql,
Integer n) |
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 SimpleRiverSourceTests()
public RiverSource newRiverSource()
newRiverSource in class AbstractSimpleRiverTestpublic SimpleRiverContext newRiverContext()
newRiverContext in class AbstractSimpleRiverTestpublic void testSimpleConnectionClose() throws Exception
Exceptionpublic void testSimpleSQL(String sql) throws Exception
Exceptionpublic void testSimpleStarQuery(String sql, Integer n) throws Exception
Exceptionpublic void testSimpleNullInteger(String sql) throws Exception
Exceptionelasticsearch-river-jdbc