public class SimpleRiverSourceTests extends AbstractSimpleRiverTest
context, source
cluster, 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, waitForRiver
assertHits, assertTimestampSort, buildNode, client, getClusterName, getNodeSettings, setClusterName, startNode, startNodes, stopNodes, waitForYellow
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, assertEquals, assertEqualsNoOrder, assertEqualsNoOrder, assertFalse, assertFalse, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotEquals, assertNotNull, assertNotNull, assertNotSame, assertNotSame, assertNull, assertNull, assertSame, assertSame, assertTrue, assertTrue, fail, fail, fail
public SimpleRiverSourceTests()
public RiverSource newRiverSource()
newRiverSource
in class AbstractSimpleRiverTest
public SimpleRiverContext newRiverContext()
newRiverContext
in class AbstractSimpleRiverTest
public void testSimpleConnectionClose() throws Exception
Exception
public void testSimpleSQL(String sql) throws Exception
Exception
public void testSimpleStarQuery(String sql, Integer n) throws Exception
Exception
public void testSimpleNullInteger(String sql) throws Exception
Exception
elasticsearch-river-jdbc