public class RiverMockTests extends AbstractSimpleRiverTest
context, sourcecluster, index, type| Constructor and Description |
|---|
RiverMockTests() |
| Modifier and Type | Method and Description |
|---|---|
SimpleRiverContext |
newRiverContext() |
RiverSource |
newRiverSource() |
void |
testMockBill(String sql) |
void |
testMockDepartments(String sql) |
void |
testMockHighBills(String sql) |
void |
testMockIndexId(String sql) |
void |
testMockTimePeriod(String sql) |
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 RiverMockTests()
public RiverSource newRiverSource()
newRiverSource in class AbstractSimpleRiverTestpublic SimpleRiverContext newRiverContext()
newRiverContext in class AbstractSimpleRiverTestpublic void testMockBill(String sql) throws Exception
Exceptionpublic void testMockDepartments(String sql) throws Exception
Exceptionpublic void testMockHighBills(String sql) throws Exception
Exceptionpublic void testMockTimePeriod(String sql) throws Exception
Exceptionpublic void testMockIndexId(String sql) throws Exception
Exceptionelasticsearch-river-jdbc