public class ColumnRiverFlowTests extends AbstractColumnRiverTest
context, sourcecluster, index, logger, type| Constructor and Description |
|---|
ColumnRiverFlowTests() |
| Modifier and Type | Method and Description |
|---|---|
ColumnRiverContext |
newRiverContext() |
ColumnRiverSource |
newRiverSource() |
void |
testReadLastRiverRunTime(String riverResource) |
void |
testWriteLastRiverRunTime(String riverResource) |
afterMethod, beforeMethod, createRiver, performRiver, riverSettings, 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 ColumnRiverFlowTests()
public ColumnRiverSource newRiverSource()
newRiverSource in class AbstractColumnRiverTestpublic ColumnRiverContext newRiverContext()
newRiverContext in class AbstractColumnRiverTestpublic void testWriteLastRiverRunTime(String riverResource) throws Exception
Exceptionpublic void testReadLastRiverRunTime(String riverResource) throws Exception
Exceptionelasticsearch-river-jdbc