public class SimpleRiverJobTests extends AbstractSimpleRiverTest
context, source
cluster, index, logger, type
Constructor and Description |
---|
SimpleRiverJobTests() |
Modifier and Type | Method and Description |
---|---|
SimpleRiverContext |
newRiverContext() |
RiverSource |
newRiverSource() |
void |
testSimpleRiverJob(String riverResource,
String sql1,
String sql2) |
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 SimpleRiverJobTests()
public RiverSource newRiverSource()
newRiverSource
in class AbstractSimpleRiverTest
public SimpleRiverContext newRiverContext()
newRiverContext
in class AbstractSimpleRiverTest
elasticsearch-river-jdbc