A B C D E F G I L M N O P R S T U V W

A

AbstractColumnRiverTest - Class in org.xbib.elasticsearch.river.jdbc.strategy.column

AbstractColumnRiverTest() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

AbstractNodeTestHelper - Class in org.xbib.elasticsearch.support.helper

AbstractNodeTestHelper() - Constructor for class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

AbstractSimpleRiverTest - Class in org.xbib.elasticsearch.river.jdbc.strategy.simple

AbstractSimpleRiverTest() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

afterFetch() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

afterFetch() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

afterMethod(String, String, String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

afterMethod(String, String, String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

afterRows(ResultSet, KeyValueStreamListener) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

afterRows(SQLCommand, ResultSet, KeyValueStreamListener) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

assertHits(String, int) - Method in class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

assertTimestampSort(String, int) - Method in class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

B

beforeFetch() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

beforeFetch() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

beforeMethod(String, String, String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

beforeMethod(String, String, String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

beforeRows(ResultSet, KeyValueStreamListener) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

beforeRows(SQLCommand, ResultSet, KeyValueStreamListener) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

bind(PreparedStatement, List<Object>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

buildNode(String) - Method in class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

C

client(String) - Method in class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

close(ResultSet) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

close(Statement) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

closeReading() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

closeWriting() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

cluster - Variable in class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

ColumnRiverFlowTests - Class in org.xbib.elasticsearch.river.jdbc.strategy.column

ColumnRiverFlowTests() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverFlowTests

ColumnRiverSourceTests - Class in org.xbib.elasticsearch.river.jdbc.strategy.column

ColumnRiverSourceTests() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverSourceTests

context - Static variable in class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

context - Static variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

createRandomProducts(String, int) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

createRandomProductsJob(String, int) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

createRiver(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

createRiver(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

createTimestampedLogs(String, int, String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

cron() - Method in class org.xbib.cron.CronTest

CronTest - Class in org.xbib.cron

CronTest() - Constructor for class org.xbib.cron.CronTest

D

data() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

delete(IndexableObject) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

E

end(IndexableObject) - Method in class org.xbib.elasticsearch.river.jdbc.support.StringKeyValueStreamListener

The object is complete.

executeQuery(PreparedStatement) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

executeQuery(Statement, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

executeUpdate(PreparedStatement) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

executeUpdate(Statement, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

F

fetch() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

flush() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

G

getClusterName() - Method in class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

getConnectionForReading() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

getConnectionForWriting() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

getCounter() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

getDefinition() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

getId() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

getIndex() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

getLocale() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

getMetric() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

getMetric() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

getNodeSettings() - Method in class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

getRiverMouth() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

getRiverSource() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

getRiverState() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

getSupplierOfCoffee(String, String[]) - Static method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.storedprocedure.StoredProcedureJavaDBSample

getTimeZone() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

getType() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

I

index(IndexableObject, boolean) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

index - Variable in class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

insertWithSelect() - Method in class org.xbib.elasticsearch.river.plugin.SQLCommandTests

L

Listener - Class in org.xbib.elasticsearch.river.jdbc

Listener() - Constructor for class org.xbib.elasticsearch.river.jdbc.Listener

logger - Static variable in class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

M

MockRiverContext - Class in org.xbib.elasticsearch.river.jdbc.strategy.mock

MockRiverContext() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

MockRiverMouth - Class in org.xbib.elasticsearch.river.jdbc.strategy.mock

MockRiverMouth() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

MockRiverSource - Class in org.xbib.elasticsearch.river.jdbc.strategy.mock

MockRiverSource() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

N

newInstance() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

newInstance() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

newRiverContext() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

newRiverContext() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverFlowTests

newRiverContext() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverSourceTests

newRiverContext() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.RiverMockTests

newRiverContext() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

newRiverContext() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverDataTests

newRiverContext() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverJobTests

newRiverContext() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverScheduleTests

newRiverContext() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverScriptTests

newRiverContext() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSourceTests

newRiverContext() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverStoredProcedureTests

newRiverSource() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

newRiverSource() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverFlowTests

newRiverSource() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverSourceTests

newRiverSource() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.RiverMockTests

newRiverSource() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

newRiverSource() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverDataTests

newRiverSource() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverJobTests

newRiverSource() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverScheduleTests

newRiverSource() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverScriptTests

newRiverSource() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSourceTests

newRiverSource() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverStoredProcedureTests

nextRow(ResultSet, KeyValueStreamListener) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

nextRow(SQLCommand, ResultSet, KeyValueStreamListener) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

O

onFinish(ITestContext) - Method in class org.xbib.elasticsearch.river.jdbc.Listener

onStart(ITestContext) - Method in class org.xbib.elasticsearch.river.jdbc.Listener

onTestFailedButWithinSuccessPercentage(ITestResult) - Method in class org.xbib.elasticsearch.river.jdbc.Listener

onTestFailure(ITestResult) - Method in class org.xbib.elasticsearch.river.jdbc.Listener

onTestSkipped(ITestResult) - Method in class org.xbib.elasticsearch.river.jdbc.Listener

onTestStart(ITestResult) - Method in class org.xbib.elasticsearch.river.jdbc.Listener

onTestSuccess(ITestResult) - Method in class org.xbib.elasticsearch.river.jdbc.Listener

org.xbib.cron - package org.xbib.cron

org.xbib.elasticsearch.river.jdbc - package org.xbib.elasticsearch.river.jdbc

org.xbib.elasticsearch.river.jdbc.strategy.column - package org.xbib.elasticsearch.river.jdbc.strategy.column

org.xbib.elasticsearch.river.jdbc.strategy.mock - package org.xbib.elasticsearch.river.jdbc.strategy.mock

org.xbib.elasticsearch.river.jdbc.strategy.simple - package org.xbib.elasticsearch.river.jdbc.strategy.simple

org.xbib.elasticsearch.river.jdbc.strategy.simple.storedprocedure - package org.xbib.elasticsearch.river.jdbc.strategy.simple.storedprocedure

org.xbib.elasticsearch.river.jdbc.support - package org.xbib.elasticsearch.river.jdbc.support

org.xbib.elasticsearch.river.plugin - package org.xbib.elasticsearch.river.plugin

org.xbib.elasticsearch.support.helper - package org.xbib.elasticsearch.support.helper

output(RiverMouth) - Method in class org.xbib.elasticsearch.river.jdbc.support.StringKeyValueStreamListener

P

parseType(ResultSet, Integer, int, Locale) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

performRiver(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

performRiver(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

prepareQuery(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

prepareUpdate(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

R

register(CallableStatement, Map<String, Object>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

release() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

resume() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

resume() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

RiverMockTests - Class in org.xbib.elasticsearch.river.jdbc.strategy.mock

RiverMockTests() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.mock.RiverMockTests

riverSettings(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

S

setAutoCommit(boolean) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setClusterName() - Method in class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

setColumnNameMap(Map<String, Object>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setConnectionProperties(Map<String, Object>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setDefinition(Map<String, Object>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setFetchSize(int) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setId(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

setIndex(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

setIndexSettings(Settings) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

setIngestFactory(IngestFactory) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

setLocale(Locale) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

setMaxRetryWait(TimeValue) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setMaxRows(int) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setMetric(MeterMetric) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setPassword(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

setQueryTimeout(int) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setResultSetConcurrency(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setResultSetType(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setRetries(int) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setRiverContext(MockRiverContext) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

setRiverContext(MockRiverContext) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

setRiverMouth(RiverMouth) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setRiverSource(RiverSource) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setRiverState(RiverState) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setRounding(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setScale(int) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setStatements(List<SQLCommand>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

setTimeZone(TimeZone) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

setType(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

setTypeMapping(Map<String, String>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

setUrl(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

setUser(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

shouldIgnoreNull(boolean) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

shouldPrepareDatabaseMetadata(boolean) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

shouldPrepareResultSetMetadata(boolean) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

shouldTreatBinaryAsString(boolean) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverContext

showSuppliers(ResultSet[]) - Static method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.storedprocedure.StoredProcedureJavaDBSample

shutdown() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

shutdown() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

simpleQuery() - Method in class org.xbib.elasticsearch.river.plugin.SQLCommandTests

SimpleRiverDataTests - Class in org.xbib.elasticsearch.river.jdbc.strategy.simple

SimpleRiverDataTests() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverDataTests

SimpleRiverJobTests - Class in org.xbib.elasticsearch.river.jdbc.strategy.simple

SimpleRiverJobTests() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverJobTests

SimpleRiverScheduleTests - Class in org.xbib.elasticsearch.river.jdbc.strategy.simple

SimpleRiverScheduleTests() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverScheduleTests

SimpleRiverScriptTests - Class in org.xbib.elasticsearch.river.jdbc.strategy.simple

SimpleRiverScriptTests() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverScriptTests

SimpleRiverSourceTests - Class in org.xbib.elasticsearch.river.jdbc.strategy.simple

SimpleRiverSourceTests() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSourceTests

SimpleRiverStoredProcedureTests - Class in org.xbib.elasticsearch.river.jdbc.strategy.simple

SimpleRiverStoredProcedureTests() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverStoredProcedureTests

source - Static variable in class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

source - Static variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

SQLCommandTests - Class in org.xbib.elasticsearch.river.plugin

SQLCommandTests() - Constructor for class org.xbib.elasticsearch.river.plugin.SQLCommandTests

startNode(String) - Method in class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

startNodes() - Method in class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

stopNodes() - Method in class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

StoredProcedureJavaDBSample - Class in org.xbib.elasticsearch.river.jdbc.strategy.simple.storedprocedure

StoredProcedureJavaDBSample() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.simple.storedprocedure.StoredProcedureJavaDBSample

strategy() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

strategy() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

StringKeyValueStreamListener - Class in org.xbib.elasticsearch.river.jdbc.support

This class consumes pairs from a key/value stream and transports them to the river mouth.

StringKeyValueStreamListener() - Constructor for class org.xbib.elasticsearch.river.jdbc.support.StringKeyValueStreamListener

suspend() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverMouth

suspend() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.MockRiverSource

T

testArrays() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testCreateObjects(String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverSourceTests

testCreateObjects_configurationWithSqlParams(String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverSourceTests

testCreateObjects_configurationWithWherePlaceholder(String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverSourceTests

testCreateObjects_withLastRunTimeStampOverlap(String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverSourceTests

testDoubleScientificNotation() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testExpandValue() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValuesTests

testId() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testIgnoreNull() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testIgnoreNullObject() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testIgnoreNullObject2() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testJSON() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testJSONSource() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testJSONWithNull() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testMockBill(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.RiverMockTests

testMockDepartments(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.RiverMockTests

testMockHighBills(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.RiverMockTests

testMockIndexId(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.RiverMockTests

testMockTimePeriod(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.mock.RiverMockTests

testMultipleValues() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testMultipleValues() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValuesTests

testMultipleValuesNullFirst() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValuesTests

testMultipleValuesNullLast() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValuesTests

testMultipleValuesWithDuplicates() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValuesTests

testMultipleValuesWithDuplicatesAndNull() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValuesTests

testMultipleValuesWithNull() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testNestedDots() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testNestedObjects() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testOptype() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testOverlappingOps() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testReadLastRiverRunTime(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverFlowTests

testRegisterStoredProcedure(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverStoredProcedureTests

testRemoveObjects(String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverSourceTests

testRemoveObjects_configurationWithWherePlaceholder(String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverSourceTests

testSequenceObjects() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testSequenceValues() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

testSimpleArray(String, String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSourceTests

Test JDBC Array to structured object array

testSimpleConnectionClose() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSourceTests

testSimpleNullInteger(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSourceTests

testSimpleRiverJob(String, String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverJobTests

testSimpleRiverMaxrows(String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverDataTests

Product table

testSimpleRiverOnce(String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverDataTests

Start the river and execute a simple star query

testSimpleRiverOnce(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverScriptTests

Orders table (star query)

testSimpleRiverRandom(String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverDataTests

Product table (star query)

testSimpleSchedule(String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverScheduleTests

Product table star select, scheduled for more than two runs

testSimpleSQL(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSourceTests

testSimpleStarQuery(String, Integer) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSourceTests

testSimpleStoredProcedure(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverStoredProcedureTests

testSingleNull() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValuesTests

testSingleValue() - Method in class org.xbib.elasticsearch.river.jdbc.support.ValuesTests

testTimestamps(String, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverScheduleTests

Test read and write of timestamps in a table.

testTimeWindow() - Method in class org.xbib.elasticsearch.river.jdbc.support.TimeWindowedTests

testWriteLastRiverRunTime(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverFlowTests

TimeWindowedTests - Class in org.xbib.elasticsearch.river.jdbc.support

TimeWindowedTests() - Constructor for class org.xbib.elasticsearch.river.jdbc.support.TimeWindowedTests

type - Variable in class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

U

updateQueryType() - Method in class org.xbib.elasticsearch.river.plugin.SQLCommandTests

updateUpperCaseWithSelect() - Method in class org.xbib.elasticsearch.river.plugin.SQLCommandTests

updateWithSubselect() - Method in class org.xbib.elasticsearch.river.plugin.SQLCommandTests

updateWithSubselectAndLeadingWhitespace() - Method in class org.xbib.elasticsearch.river.plugin.SQLCommandTests

V

ValueListenerTests - Class in org.xbib.elasticsearch.river.jdbc.support

ValueListenerTests() - Constructor for class org.xbib.elasticsearch.river.jdbc.support.ValueListenerTests

ValuesTests - Class in org.xbib.elasticsearch.river.jdbc.support

Unit-test checking basic functionality of Values.

ValuesTests() - Constructor for class org.xbib.elasticsearch.river.jdbc.support.ValuesTests

W

waitForActiveRiver() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

waitForActiveRiver(Client, String, String, int) - Static method in class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

waitForActiveRiver() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

waitForActiveRiver(Client, String, String, int) - Static method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

waitForInactiveRiver() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

waitForInactiveRiver(Client, String, String, int) - Static method in class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

waitForInactiveRiver() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

waitForInactiveRiver(Client, String, String, int) - Static method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

waitForRiver() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

waitForRiver(Client, String, String, int) - Static method in class org.xbib.elasticsearch.river.jdbc.strategy.column.AbstractColumnRiverTest

waitForRiver() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

waitForRiver(Client, String, String, int) - Static method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.AbstractSimpleRiverTest

waitForYellow(String) - Method in class org.xbib.elasticsearch.support.helper.AbstractNodeTestHelper

A B C D E F G I L M N O P R S T U V W