public class SimpleRiverScriptTests extends AbstractSimpleRiverTest
context, source
cluster, index, logger, type
Constructor and Description |
---|
SimpleRiverScriptTests() |
Modifier and Type | Method and Description |
---|---|
SimpleRiverContext |
newRiverContext() |
RiverSource |
newRiverSource() |
void |
testSimpleRiverOnce(String riverResource)
Orders table (star query)
|
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 SimpleRiverScriptTests()
public RiverSource newRiverSource()
newRiverSource
in class AbstractSimpleRiverTest
public SimpleRiverContext newRiverContext()
newRiverContext
in class AbstractSimpleRiverTest
public void testSimpleRiverOnce(String riverResource) throws Exception
riverResource
- the river definitionException
- if test failselasticsearch-river-jdbc