Index (elasticsearch-river-jdbc 1.3.4.0 API)

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

A

AbstractResourceHandle - Class in org.xbib.elasticsearch.plugin.jdbc.classloader
AbstractResourceHandle() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.classloader.AbstractResourceHandle
AbstractURLResourceLocation - Class in org.xbib.elasticsearch.plugin.jdbc.classloader
AbstractURLResourceLocation(URL) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.classloader.AbstractURLResourceLocation
accumulateExceptions() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction
add(List<URI>) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIResourceFinder: Adds a list of uris to the end of this class loader.
addSetting(String, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
addSetting(String, Boolean) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
addSetting(String, Integer) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
addSetting(String, String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Create a key/value in the settings
addSetting(String, Boolean) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Create a key/value in the settings
addSetting(String, Integer) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Create a key/value in the settings
addSetting(String, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
addSetting(String, Boolean) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
addSetting(String, Integer) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
addToSet(int, int, int, int) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
addURI(URI) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIClassLoader: Add specified URI at the end of the search path.
addURI(URI) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIResourceFinder
addURL(URL) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIClassLoader: Deprecated.
use addURI
addValue(O) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.Values: Append value to existing values.
afterFetch() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Executed after river source fetch
afterFetch() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Executed after fetch() has been executed or threw an exception.
afterFetch(RiverContext) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow: After the river task has completed a single run, this method is called.
afterFetch() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
afterFetch() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
afterPipelineExecutions() - Method in class org.xbib.elasticsearch.plugin.jdbc.RiverThread
afterRows(ResultSet, KeyValueStreamListener) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Executed after all rows have been fetched from result set
afterRows(SQLCommand, ResultSet, KeyValueStreamListener) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: After the result set is processed, this method is called.
afterRows(ResultSet, KeyValueStreamListener) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
afterRows(SQLCommand, ResultSet, KeyValueStreamListener) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: After the rows keys and values, let the listener know about the end of the result set.
ALL_SPEC - Static variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
ALL_SPEC_INT - Static variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
asMap() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverContext
asMap() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext

B

BaseIngestTransportClient - Class in org.xbib.elasticsearch.plugin.jdbc.client
BaseIngestTransportClient() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.client.BaseIngestTransportClient
BaseTransportClient - Class in org.xbib.elasticsearch.plugin.jdbc.client
BaseTransportClient() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
beforeFetch() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Executed before river source fetch
beforeFetch() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Executed before fetch() is executed
beforeFetch(RC) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow: Before a river task (or river run) starts, this method is called.
beforeFetch() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
beforeFetch() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
beforePipelineExecutions() - Method in class org.xbib.elasticsearch.plugin.jdbc.RiverThread: Before the pipelines are executed, put the river defintions on the queue
beforeRows(ResultSet, KeyValueStreamListener) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Executed before rows are fetched from result set
beforeRows(SQLCommand, ResultSet, KeyValueStreamListener) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: This routine is executed before the result set is evaluated
beforeRows(ResultSet, KeyValueStreamListener) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
beforeRows(SQLCommand, ResultSet, KeyValueStreamListener) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Before rows are read, let the KeyValueStreamListener know about the keys.
begin() - Method in interface org.xbib.elasticsearch.plugin.jdbc.keyvalue.KeyValueStreamListener: Begin a key/value sequence
begin() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainKeyValueStreamListener
bind(PreparedStatement, List<Object>) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Bind query variables
bind(PreparedStatement, List<Object>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Bind values to prepared statement
Build - Class in org.xbib.elasticsearch.plugin.jdbc.river
build() - Method in interface org.xbib.elasticsearch.plugin.jdbc.util.IndexableObject
build() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject: Build a string that can be used for indexing.
buildExpression(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
bulkDelete(DeleteRequest) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Bulked delete request.
bulkDelete(DeleteRequest) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
bulkDelete(DeleteRequest) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
bulkIndex(IndexRequest) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Bulked index request.
bulkIndex(IndexRequest) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
bulkIndex(IndexRequest) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
BulkNodeClient - Class in org.xbib.elasticsearch.plugin.jdbc.client.node: Node client support with bulk processing
BulkNodeClient() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
BulkProcessorHelper - Class in org.xbib.elasticsearch.plugin.jdbc.client
BulkProcessorHelper() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.client.BulkProcessorHelper
BulkTransportClient - Class in org.xbib.elasticsearch.plugin.jdbc.client.transport: Client using the BulkProcessor of Elasticsearch
BulkTransportClient() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient

C

cacheUri(URI) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIResourceFinder
calendar - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
call() - Method in class org.xbib.elasticsearch.plugin.jdbc.RiverPipeline: Call this thread.
checkBlock(DeleteRiverStateRequest, ClusterState) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.TransportDeleteRiverStateAction
checkBlock(PostRiverStateRequest, ClusterState) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.TransportPostRiverStateAction
checkBlock(PutRiverStateRequest, ClusterState) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.TransportPutRiverStateAction
checkCollapsedMapLength(Map<String, Object>) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject: Check if the map is empty, after optional null value removal.
checkForSuspension() - Method in class org.xbib.elasticsearch.plugin.jdbc.RiverThread: Should be called regularly to check for a new river state, if the river is suspended.
checkNext(int, String, int, int) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
client - Variable in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
client() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
client() - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
client() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
client() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
ClientHelper - Class in org.xbib.elasticsearch.plugin.jdbc.client
ClientHelper() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.client.ClientHelper
close() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.AbstractResourceHandle
close() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.AbstractURLResourceLocation
close() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarResourceLocation
close() - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceHandle: Closes a connection to the resource indentified by this handle.
close() - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceLocation
close() - Method in class org.xbib.elasticsearch.plugin.jdbc.river.JDBCRiver: Called form Elasticsearch when river is deleted.
close(ResultSet) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Close result set
close(Statement) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Close statement
close(ResultSet) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Close result set
close(Statement) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Close statement
closeReading() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Close reading from this river source
closeReading() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Close read connection
closeWriting() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Close writing to this river source
closeWriting() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Close read connection
clusterChanged(ClusterChangedEvent) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService
clusterName(Client) - Static method in class org.xbib.elasticsearch.plugin.jdbc.client.ClientHelper
columnCreatedAt(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverContext
columnCreatedAt() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverContext
columnDeletedAt(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverContext
columnDeletedAt() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverContext
columnEscape(boolean) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverContext
columnEscape() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverContext
ColumnRiverContext - Class in org.xbib.elasticsearch.river.jdbc.strategy.column
ColumnRiverContext() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverContext
ColumnRiverFlow - Class in org.xbib.elasticsearch.river.jdbc.strategy.column: River flow implementation for the 'column' strategy
ColumnRiverFlow() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverFlow
ColumnRiverMouth - Class in org.xbib.elasticsearch.river.jdbc.strategy.column: River mouth implementation for the 'column' strategy
ColumnRiverMouth() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverMouth
ColumnRiverSource<RC extends ColumnRiverContext> - Class in org.xbib.elasticsearch.river.jdbc.strategy.column: River source implementation for the 'column' strategy
ColumnRiverSource() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverSource
columnUpdatedAt(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverContext
columnUpdatedAt() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverContext
CommandLineInterpreter - Interface in org.xbib.elasticsearch.plugin.jdbc.feeder
compareTo(RiverState) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
compareTo(IndexableObject) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
configHelper - Variable in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
ConfigHelper - Class in org.xbib.elasticsearch.plugin.jdbc.client
ConfigHelper() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.client.ConfigHelper
configure(Binder) - Method in class org.xbib.elasticsearch.plugin.jdbc.river.JDBCRiverModule
configure(Binder) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStateModule: Only one RiverStateService instance is allowed
connect() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
connect(Settings) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
context - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
context - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
ContextPipelineElement - Class in org.xbib.elasticsearch.plugin.jdbc.pipeline.element: The context pipeline element transport a RiverContext as request to a pipeline
ContextPipelineElement() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.pipeline.element.ContextPipelineElement
ControlKeys - Enum in org.xbib.elasticsearch.plugin.jdbc.util: The names of keys with a special meaning for controlling Elasticsearch indexing.
convertFileSize(double) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.VolumeFormatUtil
convertFileSize(double, Locale) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.VolumeFormatUtil
create() - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.IngestFactory
createClient(Settings) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
createResourceLocation(URL, File) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIResourceFinder
createRiverFlow(Map<String, Object>, Settings) - Method in class org.xbib.elasticsearch.plugin.jdbc.feeder.JDBCFeeder
createRiverMouth(Map<String, Object>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
createRiverSource(Map<String, Object>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
createURL(JarFile, JarEntry) - Static method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlStreamHandler
createURL(JarFile, JarEntry, URL) - Static method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlStreamHandler
CronExecutorService - Interface in org.xbib.elasticsearch.plugin.jdbc.cron: Executor service that schedules a task for execution via a cron expression.
CronExpression - Class in org.xbib.elasticsearch.plugin.jdbc.cron
CronExpression(String) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression: Constructs a new CronExpression based on the specified parameter.
CronExpression(CronExpression) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression: Constructs a new CronExpression as a copy of an existing instance.
CronThreadPoolExecutor - Class in org.xbib.elasticsearch.plugin.jdbc.cron: Scheduled thread-pool executor implementation that leverages a CronExpression to calculate future execution times for scheduled tasks.
CronThreadPoolExecutor(int) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.cron.CronThreadPoolExecutor: Constructs a new CronThreadPoolExecutor.
CronThreadPoolExecutor(int, ThreadFactory) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.cron.CronThreadPoolExecutor: Constructs a new CronThreadPoolExecutor.
CronThreadPoolExecutor(int, RejectedExecutionHandler) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.cron.CronThreadPoolExecutor: Constructs a new CronThreadPoolExecutor.
CronThreadPoolExecutor(int, ThreadFactory, RejectedExecutionHandler) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.cron.CronThreadPoolExecutor: Constructs a new CronThreadPoolExecutor.
CURRENT_RUN_STARTED_TIME - Static variable in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverFlow

D

dateTimeZone - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
DAY_OF_MONTH - Static variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
DAY_OF_WEEK - Static variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
dayMap - Static variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
daysOfMonth - Variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
daysOfWeek - Variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
defaultMapping() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.ConfigHelper
delete(String, String, String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Delete document
delete(String, String, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
delete(String, String, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
delete(IndexableObject) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Delete operation.
delete(IndexableObject) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
deleteIndex(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseIngestTransportClient
deleteIndex(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Delete index
deleteIndex(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
deleteIndex(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
deleteMapping(String, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseIngestTransportClient
deleteMapping(Client, String, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.ConfigHelper
deleteMapping(String, String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
deleteMapping(String, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
deleteRiverState(RiverStateService.DeleteRiverStateRequest, ActionListener<ClusterStateUpdateResponse>) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService: Delete river from river state management
DeleteRiverStateAction - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.delete
DeleteRiverStateRequest - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.delete
DeleteRiverStateRequest() - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateRequest
DeleteRiverStateRequestBuilder - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.delete
DeleteRiverStateRequestBuilder(ClusterAdminClient) - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateRequestBuilder
DeleteRiverStateResponse - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.delete
DeleteRiverStateResponse() - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateResponse
DeleteRiverStateResponse(boolean) - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateResponse
delimiter(char) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainKeyValueStreamListener: Set custom delimiter
description() - Method in class org.xbib.elasticsearch.plugin.jdbc.river.JDBCRiverPlugin
destroy() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIResourceFinder
DirectoryResourceHandle - Class in org.xbib.elasticsearch.plugin.jdbc.classloader.directory
DirectoryResourceHandle(String, File, File, Manifest) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.classloader.directory.DirectoryResourceHandle
DirectoryResourceLocation - Class in org.xbib.elasticsearch.plugin.jdbc.classloader.directory
DirectoryResourceLocation(File) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.classloader.directory.DirectoryResourceLocation
disableRefresh(Client, String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.client.ClientHelper
doClose() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService
doExecute(ActionListener<RunRiverResponse>) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverRequestBuilder
doExecute(ActionListener<DeleteRiverStateResponse>) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateRequestBuilder
doExecute(ActionListener<GetRiverStateResponse>) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateRequestBuilder
doExecute(ActionListener<PostRiverStateResponse>) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequestBuilder
doExecute(ActionListener<PutRiverStateResponse>) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateRequestBuilder
doStart() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService
doStop() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService
DUMMY_JAR_URL - Static variable in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
DurationFormatUtil - Class in org.xbib.elasticsearch.plugin.jdbc.util: Duration formatting utilities and constants.
DurationFormatUtil() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.util.DurationFormatUtil: DurationFormatUtils instances should NOT be constructed in standard programming.

E

elapsed() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.Metric
EMPTY - Static variable in class org.xbib.elasticsearch.plugin.jdbc.util.Strings
enableRefresh(Client, String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.client.ClientHelper
end() - Method in interface org.xbib.elasticsearch.plugin.jdbc.keyvalue.KeyValueStreamListener: End a key/value sequence
end() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainKeyValueStreamListener: End of values.
end(IndexableObject) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainKeyValueStreamListener: The object is complete
end(IndexableObject) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.RiverMouthKeyValueStreamListener: The object is complete.
equals(Object) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.AbstractURLResourceLocation
equals(Object) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
errorsTo(PrintStream) - Method in interface org.xbib.elasticsearch.plugin.jdbc.feeder.CommandLineInterpreter
errorsTo(PrintStream) - Method in class org.xbib.elasticsearch.plugin.jdbc.feeder.JDBCFeeder
execute() - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.MetricSimplePipelineExecutor
execute() - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.SimplePipelineExecutor: Execute pipelines
execute() - Method in interface org.xbib.elasticsearch.plugin.jdbc.pipeline.PipelineExecutor: Execute the pipelines.
execute(RC) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverFlow: Execute this river flow
execute(RC) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
executeQuery(PreparedStatement) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Execute query
executeQuery(Statement, String) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Execute query without binding parameters
executeQuery(PreparedStatement) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Execute prepared query statement
executeQuery(Statement, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Execute query statement
executeUpdate(PreparedStatement) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Execute insert/update
executeUpdate(Statement, String) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Execute insert update
executeUpdate(PreparedStatement) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Execute prepared update statement
executeUpdate(Statement, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Execute prepared update statement
executor() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction
executor() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.TransportDeleteRiverStateAction
executor() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.TransportGetRiverStateAction
executor() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.TransportPostRiverStateAction
executor() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.TransportPutRiverStateAction
exists(String, String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateResponse
expressionParsed - Variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression

F

FACTORY - Static variable in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStatesMetaData
fetch() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Fetch a data portion from the database and pass it to the river task for firther processing.
fetch(RiverContext) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverFlow
fetch() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverSource
fetch(RiverContext) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow: After river context and state setup, when data should be fetched from river source, this method is called.
fetch() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: River fetch.
fillRiverContext(ColumnRiverContext, RiverState, RiverSource, RiverMouth) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverFlow
fillRiverContext(RC, RiverState, RiverSource, RiverMouth) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
findClass(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIClassLoader: Finds and loads the class with the specified name.
findLibrary(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIClassLoader: Returns the absolute path name of a native library.
findNextWhiteSpace(int, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
findResource(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceFinder: Find the resource by name and return URL of it if found.
findResource(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIClassLoader: Finds the resource with the specified name.
findResource(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIResourceFinder
findResources(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceFinder: Find all resources with given name and return enumeration of their URLs.
findResources(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIClassLoader: Returns an Enumeration of URLs representing all of the resources having the specified name.
findResources(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIResourceFinder
findSettings() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
flush(BulkProcessor) - Static method in class org.xbib.elasticsearch.plugin.jdbc.client.BulkProcessorHelper
flush(Client, String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.client.ClientHelper
flush(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Flush the index
flush(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
flush(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
flush() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Flush data to the river mouth
flush() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
flushIngest() - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Flush ingest, move all pending documents to the bulk indexer
flushIngest() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
flushIngest() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
flushIngestInterval(TimeValue) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Set the flush interval for automatic flushing outstanding ingest requests
flushIngestInterval(TimeValue) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
flushIngestInterval(TimeValue) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
formatDuration(long, String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.DurationFormatUtil: Formats the time gap as a string, using the specified format, and using the default timezone.
formatDurationHMS(long) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.DurationFormatUtil: Formats the time gap as a string.
formatDurationISO(long) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.DurationFormatUtil: Formats the time gap as a string.
formatDurationWords(long, boolean, boolean) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.DurationFormatUtil: Formats an elapsed time into a plurialization correct string.
formatPeriod(long, long, String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.DurationFormatUtil: Formats the time gap as a string, using the specified format.
formatPeriod(long, long, String, TimeZone) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.DurationFormatUtil: Formats the time gap as a string, using the specified format, and the timezone may be specified.
formatPeriodISO(long, long) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.DurationFormatUtil: Formats the time gap as a string.
fromLocale(Locale) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.LocaleUtil
fromXContent(XContentParser) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
fromXContent(XContentParser) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStatesMetaData.Factory

G

get() - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.element.ContextPipelineElement
get() - Method in interface org.xbib.elasticsearch.plugin.jdbc.pipeline.element.PipelineElement
get() - Method in interface org.xbib.elasticsearch.plugin.jdbc.pipeline.PipelineProvider: Get an instance of a pipeline
getAttributes() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.AbstractResourceHandle
getAttributes() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.directory.DirectoryResourceHandle
getAttributes() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
getAttributes() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarResourceHandle
getAttributes() - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceHandle: Return the Attributes of the resource, or null if none.
getAutoCommit() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getBytes() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.AbstractResourceHandle
getBytes() - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceHandle: Returns this resource data as an array of bytes.
getCertificates() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.AbstractResourceHandle
getCertificates() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.directory.DirectoryResourceHandle: Always return null.
getCertificates() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
getCertificates() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarResourceHandle
getCertificates() - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceHandle: Return the Certificates of the resource, or null if none.
getClient() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverFlow: Get the client
getClient() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
getCodeSource() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.AbstractURLResourceLocation
getCodeSource() - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceLocation
getCodeSourceUrl() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.directory.DirectoryResourceHandle
getCodeSourceUrl() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarResourceHandle
getCodeSourceUrl() - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceHandle: Returns the CodeSource URL for the class or resource.
getColumnNameMap() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getConnectedNodes() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
getConnectedNodes(TransportClient) - Static method in class org.xbib.elasticsearch.plugin.jdbc.client.ClientHelper
getConnectedNodes() - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
getConnectedNodes() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
getConnectionForReading() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Get a connection for reading data
getConnectionForReading() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Get JDBC connection for reading
getConnectionForWriting() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Get a connection for writing data
getConnectionForWriting() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Get JDBC connection for writing.
getConnectionProperties() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getContentLength() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.directory.DirectoryResourceHandle
getContentLength() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
getContentLength() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarResourceHandle
getContentLength() - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceHandle: Returns the length of this resource data, or -1 if unknown.
getCounter() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
getCronExpression() - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
getCurrentIngest() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.Metric
getCurrentIngestNumDocs() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.Metric
getCustom() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
getDate() - Method in class org.xbib.elasticsearch.plugin.jdbc.river.Build
getDayOfWeekNumber(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
getDefinition() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Get river instance definition
getDefinition() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getEntryName() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
getExceptions() - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.SimplePipelineExecutor: Get the collected I/O exceptions that were thrown by the pipelines.
getExpressionSetSummary(Set<Integer>) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
getExpressionSetSummary(List<Integer>) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
getExpressionSummary() - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
getFailed() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.Metric
getFetchSize() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getHash() - Method in class org.xbib.elasticsearch.plugin.jdbc.river.Build
getId() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Get document identifier
getId() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
getIndex() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Get default index name of this river mouth
getIndex() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
getInputStream() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.directory.DirectoryResourceHandle
getInputStream() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
getInputStream() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarResourceHandle
getInputStream() - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceHandle: Returns and InputStream for reading this resource data.
getInstance() - Static method in class org.xbib.elasticsearch.plugin.jdbc.river.Build
getJarEntry() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
getJarFile() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
getJarFileURL() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
getLastActiveBegin() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
getLastActiveEnd() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
getLastDatabaseMetadata() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getLastDayOfMonth(int, int) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
getLastEndDate() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getLastExecutionEndDate() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getLastExecutionStartDate() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getLastModified() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
getLastResultSetMetadata() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getLastRow() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getLastRowCount() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getLastRunTimeStampOverlap() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverContext
getLastStartDate() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getLocale() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Get the current locale
getLocale() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
getMainAttributes() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
getManifest() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.AbstractResourceHandle
getManifest() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.directory.DirectoryResourceHandle
getManifest() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.directory.DirectoryResourceLocation
getManifest() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
getManifest() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarResourceHandle
getManifest() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarResourceLocation
getManifest() - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceHandle: Returns the Manifest of the JAR file from which this resource was loaded, or null if none.
getManifest() - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceLocation
getMap() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
getMappings() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
getMappings() - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
getMappings() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
getMaxRetryWait() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getMaxRows() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getMetric() - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
getMetric() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
getMetric() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
getMetric() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Get metric
getMetric() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverFlow: Get metric
getMetric() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Get the metrics of this river mouth
getMetric() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getMetric() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
getMetric() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
getMonthNumber(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
getName() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.directory.DirectoryResourceHandle
getName() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarResourceHandle
getName() - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceHandle: Return the name of the resource.
getName() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
getNextInvalidTimeAfter(Date) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression: Returns the next date/time after the given date/time which does not satisfy the expression
getNextValidTimeAfter(Date) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression: Returns the next date/time after the given date/time which satisfies the cron expression.
getNumericValue(String, int) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
getParameters() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.SQLCommand
getPermission() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
getPipelines() - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.SimplePipelineExecutor: Get the pipelines of this executor.
getPipelines() - Method in interface org.xbib.elasticsearch.plugin.jdbc.pipeline.PipelineExecutor: Return pipelines
getQueryTimeout() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getQueue() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverFlow: Get queue for RiverContext processing
getQueue() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
getRegister() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.SQLCommand: Get the parameters of a callable statement
getResource(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceFinder: Get the resource by name and, if found, open connection to it and return the handle of it.
getResource(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIResourceFinder
getResourceHandle(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.directory.DirectoryResourceLocation
getResourceHandle(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarResourceLocation
getResourceHandle(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceLocation
getResultSetConcurrency() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getResultSetType() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getRetries() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getRiverContext() - Method in class org.xbib.elasticsearch.plugin.jdbc.RiverPipeline
getRiverMouth() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Get river mouth
getRiverMouth() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getRiverName() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverRequest
getRiverName() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateRequest
getRiverName() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateRequest
getRiverName() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequest
getRiverName() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateRequest
getRiverName() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverFlow: Gets the river name
getRiverName() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
getRiverSource() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Get river source
getRiverSource() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getRiverState() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateResponse
getRiverState() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequest
getRiverState() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateRequest
getRiverState() - Method in class org.xbib.elasticsearch.plugin.jdbc.river.JDBCRiver
getRiverState() - Method in interface org.xbib.elasticsearch.plugin.jdbc.state.StatefulRiver
getRiverState() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Get river state
getRiverState() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
GetRiverStateAction - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.get
GetRiverStateRequest - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.get
GetRiverStateRequest() - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateRequest
GetRiverStateRequestBuilder - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.get
GetRiverStateRequestBuilder(ClusterAdminClient) - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateRequestBuilder
GetRiverStateResponse - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.get
GetRiverStateResponse() - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateResponse
GetRiverStateResponse(ImmutableList<RiverState>) - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateResponse
getRiverStates() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateResponse
getRiverStates() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStatesMetaData: Returns list of current river states
getRiverStates(String, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStatesMetaData: Returns a river state with a given name or null if such river doesn't exist
getRiverType() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverRequest
getRiverType() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateRequest
getRiverType() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateRequest
getRiverType() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequest
getRiverType() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateRequest
getRounding() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getScale() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getSettings() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
getSettings() - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
getSettings() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
getSettings() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverFlow: Get the settings
getSettings() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
getSettingsBuilder() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
getSettingsBuilder() - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
getSettingsBuilder() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
getShortHash() - Method in class org.xbib.elasticsearch.plugin.jdbc.river.Build
getSQL() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.SQLCommand
getStarted() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
getStatements() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
getSubmitted() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.Metric
getSucceeded() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.Metric
getThrowable() - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Return last throwable if exists.
getThrowable() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
getThrowable() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
getTimeAfter(Date) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
getTimestamp() - Method in class org.xbib.elasticsearch.plugin.jdbc.river.Build
getTimeZone() - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression: Returns the time zone for which this CronExpression will be resolved.
getTimeZone() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Get the current timezone of this river source for the JDBC setTimestamp() call
getTimeZone() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
getTotalIngest() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.Metric
getTotalIngestSizeInBytes() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.Metric
getType() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
getType() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Get default index type name of this river mouth
getType() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
getURIs() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIClassLoader
getURIs() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIResourceFinder
getUrl() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.directory.DirectoryResourceHandle
getURL() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
getUrl() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarResourceHandle
getUrl() - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceHandle: Returns the URL of the resource.
getUrl() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
getValue(int, String, int) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
getValues() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.Values: Get the values.
getVersion() - Method in class org.xbib.elasticsearch.plugin.jdbc.river.Build

H

handleRequest(RestRequest, RestChannel, Client) - Method in class org.xbib.elasticsearch.rest.action.river.jdbc.RestRiverStateAction
handleRequest(RestRequest, RestChannel, Client) - Method in class org.xbib.elasticsearch.rest.action.river.jdbc.RestRunRiverAction
hashCode() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.AbstractURLResourceLocation
hashCode() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
hasMoreElements() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceEnumeration
hasNext() - Method in class org.xbib.elasticsearch.plugin.jdbc.RiverPipeline
hasThrowable() - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
hasThrowable() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
hasThrowable() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
healthColor(Client) - Static method in class org.xbib.elasticsearch.plugin.jdbc.client.ClientHelper
HOUR - Static variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
hours - Variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression

I

id(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.util.IndexableObject: Set the ID
id() - Method in interface org.xbib.elasticsearch.plugin.jdbc.util.IndexableObject: Get the ID
id(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
id() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
id - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
ignoreNull(boolean) - Method in interface org.xbib.elasticsearch.plugin.jdbc.util.IndexableObject
ignoreNull(boolean) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
index(String, String, String, String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Index document
index(String, String, String, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
index(String, String, String, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
index(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.util.IndexableObject: Set the index
index() - Method in interface org.xbib.elasticsearch.plugin.jdbc.util.IndexableObject: Get the index
index(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
index() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
index(IndexableObject, boolean) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Index operation.
index - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
index(IndexableObject, boolean) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
IndexableObject - Interface in org.xbib.elasticsearch.plugin.jdbc.util: A structured object is composed by an object data source together with meta data about the object.
indexMappings - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
indexSettings - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
indices() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.Metric
Ingest - Interface in org.xbib.elasticsearch.plugin.jdbc.client: Interface for providing convenient administrative methods for ingesting data into Elasticsearch.
ingest - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
IngestFactory - Interface in org.xbib.elasticsearch.plugin.jdbc.client: A factory for creating ingest objects
ingestFactory - Variable in class org.xbib.elasticsearch.plugin.jdbc.feeder.JDBCFeeder
ingestFactory - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
INSTANCE - Static variable in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverAction
INSTANCE - Static variable in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateAction
INSTANCE - Static variable in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateAction
INSTANCE - Static variable in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateAction
INSTANCE - Static variable in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateAction
isAbort() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequest
isAborted() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
isBulk(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.Metric
isCallable() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.SQLCommand
isDirectory() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.directory.DirectoryResourceHandle
isDirectory() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarResourceHandle
isDirectory() - Method in interface org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceHandle: Does this resource refer to a directory.
isEmpty() - Method in interface org.xbib.elasticsearch.plugin.jdbc.util.IndexableObject
isEmpty() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
isExecuted() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverResponse
isInterrupted() - Method in class org.xbib.elasticsearch.plugin.jdbc.RiverPipeline
isLeapYear(int) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
isNull() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.Values
isNullOrEmpty(String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.Strings: Tells whether the given string is either or consists solely of whitespace characters.
ISO_EXTENDED_FORMAT_PATTERN - Static variable in class org.xbib.elasticsearch.plugin.jdbc.util.DurationFormatUtil: Pattern used with FastDateFormat and SimpleDateFormat for the ISO8601 period format used in durations.
isPersistent() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStatesMetaData.Factory
isQuery() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.SQLCommand
isResume() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequest
isSatisfiedBy(Date) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression: Indicates whether the given date satisfies the cron expression.
isShutdown() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
isShutdown() - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
isShutdown() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
isSuspend() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequest
isSuspended() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
isTimestampDiffSupported() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
isValidExpression(String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression: Indicates whether the specified cron expression can be parsed into a valid cron expression

J

JarFileUrlConnection - Class in org.xbib.elasticsearch.plugin.jdbc.classloader.jar
JarFileUrlConnection(URL, JarFile, JarEntry) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
JarFileUrlStreamHandler - Class in org.xbib.elasticsearch.plugin.jdbc.classloader.jar
JarFileUrlStreamHandler(JarFile, JarEntry) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlStreamHandler
JarResourceHandle - Class in org.xbib.elasticsearch.plugin.jdbc.classloader.jar
JarResourceHandle(JarFile, JarEntry, URL) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarResourceHandle
JarResourceLocation - Class in org.xbib.elasticsearch.plugin.jdbc.classloader.jar
JarResourceLocation(URL, File) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarResourceLocation
JDBCFeeder - Class in org.xbib.elasticsearch.plugin.jdbc.feeder: Standalone feeder for JDBC
JDBCFeeder() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.feeder.JDBCFeeder: Constructor for running this from command line
JDBCRiver - Class in org.xbib.elasticsearch.plugin.jdbc.river: JDBC river
JDBCRiver(RiverName, RiverSettings, Client) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.river.JDBCRiver
JDBCRiverModule - Class in org.xbib.elasticsearch.plugin.jdbc.river: The JDBC river module
JDBCRiverModule() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.river.JDBCRiverModule
JDBCRiverPlugin - Class in org.xbib.elasticsearch.plugin.jdbc.river
JDBCRiverPlugin(Settings) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.river.JDBCRiverPlugin
join(String[], String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.Strings: Gives a string consisting of the elements of a given array of strings, each separated by a given separator string.
join(List<String>, String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.Strings: Gives a string consisting of the string representations of the elements of a given array of objects, each separated by a given separator string.

K

keys(List<K>) - Method in interface org.xbib.elasticsearch.plugin.jdbc.keyvalue.KeyValueStreamListener: Declare the keys for the values
keys(List<K>) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainKeyValueStreamListener: Set the keys.
keyValue(K, V) - Method in interface org.xbib.elasticsearch.plugin.jdbc.keyvalue.KeyValueStreamListener: Receive key/value pair
keyValue(K, V) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainKeyValueStreamListener
KeyValueStreamListener<K,V> - Interface in org.xbib.elasticsearch.plugin.jdbc.keyvalue

L

LAST_RUN_TIME - Static variable in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverFlow
lastdayOffset - Variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
lastdayOfMonth - Variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
lastdayOfWeek - Variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
locale - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
LocaleUtil - Class in org.xbib.elasticsearch.plugin.jdbc.util
LocaleUtil() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.util.LocaleUtil
logMetrics(RiverContext, String) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverFlow: Log metrics
logMetrics(RiverContext, String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow

M

main(String[]) - Static method in class org.xbib.elasticsearch.plugin.jdbc.feeder.Runner
makeSet() - Static method in enum org.xbib.elasticsearch.plugin.jdbc.util.ControlKeys
map(K, V, IndexableObject) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainKeyValueStreamListener
mapping(String, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
mapping(String, InputStream) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
mapping(String, InputStream) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.ConfigHelper
mapping(String, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.ConfigHelper
mapping(String, InputStream) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
mapping(String, String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
mapping(String, InputStream) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
mapping(String, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
mappings() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.ConfigHelper
masterOperation(DeleteRiverStateRequest, ClusterState, ActionListener<DeleteRiverStateResponse>) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.TransportDeleteRiverStateAction
masterOperation(GetRiverStateRequest, ClusterState, ActionListener<GetRiverStateResponse>) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.TransportGetRiverStateAction
masterOperation(PostRiverStateRequest, ClusterState, ActionListener<PostRiverStateResponse>) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.TransportPostRiverStateAction
masterOperation(PutRiverStateRequest, ClusterState, ActionListener<PutRiverStateResponse>) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.TransportPutRiverStateAction
MAX_YEAR - Static variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
maxActionsPerBulkRequest(int) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Set the maximum number of actions per bulk request
maxActionsPerBulkRequest(int) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
maxActionsPerBulkRequest(int) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
maxConcurrentBulkRequests(int) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Set the maximum concurent bulk requests
maxConcurrentBulkRequests(int) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
maxConcurrentBulkRequests(int) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
maxRequestWait(TimeValue) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Set request timeout.
maxRequestWait(TimeValue) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
maxRequestWait(TimeValue) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
maxVolumePerBulkRequest(ByteSizeValue) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Set the maximum volume for bulk request before flush
maxVolumePerBulkRequest(ByteSizeValue) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
maxVolumePerBulkRequest(ByteSizeValue) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
merge(Map<String, Object>, Object, Object) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainKeyValueStreamListener
merge(SQLCommand, ResultSet, KeyValueStreamListener) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Merge key/values from JDBC result set
meta(String, String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.util.IndexableObject: Set meta data of this indexable object
meta(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.util.IndexableObject
meta(String, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
meta(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
Metric - Class in org.xbib.elasticsearch.plugin.jdbc.client
Metric() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.client.Metric
metric() - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.MetricSimplePipelineExecutor
metric - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
MetricSimplePipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>> - Class in org.xbib.elasticsearch.plugin.jdbc.pipeline.executor
MetricSimplePipelineExecutor(MeterMetric) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.MetricSimplePipelineExecutor
MILLIS_PER_DAY - Static variable in class org.xbib.elasticsearch.plugin.jdbc.util.DurationFormatUtil: Number of milliseconds in a standard day.
MILLIS_PER_HOUR - Static variable in class org.xbib.elasticsearch.plugin.jdbc.util.DurationFormatUtil: Number of milliseconds in a standard hour.
MILLIS_PER_MINUTE - Static variable in class org.xbib.elasticsearch.plugin.jdbc.util.DurationFormatUtil: Number of milliseconds in a standard minute.
MILLIS_PER_SECOND - Static variable in class org.xbib.elasticsearch.plugin.jdbc.util.DurationFormatUtil: Number of milliseconds in a standard second.
MINUTE - Static variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
minutes - Variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
modules() - Method in class org.xbib.elasticsearch.plugin.jdbc.river.JDBCRiverPlugin
MONTH - Static variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
monthMap - Static variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
months - Variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression

N

NAME - Static variable in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverAction
NAME - Static variable in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateAction
NAME - Static variable in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateAction
NAME - Static variable in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateAction
NAME - Static variable in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateAction
name() - Method in class org.xbib.elasticsearch.plugin.jdbc.river.JDBCRiverPlugin
nearestWeekday - Variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
newClient(Settings) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseIngestTransportClient
newClient(Client) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
newClient(Settings) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
newClient(Map<String, String>) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
newClient(Settings) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
newClient(Map<String, String>) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
newClient(Client) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
newClient(Client) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
newClient(Map<String, String>) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
newClient(Settings) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
newIndex(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseIngestTransportClient
newIndex(String, String, InputStream, InputStream) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseIngestTransportClient
newIndex(String, Settings, Map<String, String>) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseIngestTransportClient
newIndex(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Create a new index
newIndex(String, String, InputStream, InputStream) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
newIndex(String, Settings, Map<String, String>) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
newIndex(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
newIndex(String, String, InputStream, InputStream) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
newIndex(String, Settings, Map<String, String>) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
newIndex(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
newInstance() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverFlow
newInstance() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Create a new river mouth instance
newInstance() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Create new river source instance
newInstance() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverFlow
newInstance() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverMouth
newInstance() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverSource
newInstance() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
newInstance() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
newInstance() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
newNodeRequest() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction
newNodeRequest(String, RunRiverRequest) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction
newNodeResponse() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction
newRequest() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction
newRequest() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.TransportDeleteRiverStateAction
newRequest() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.TransportGetRiverStateAction
newRequest() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.TransportPostRiverStateAction
newRequest() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.TransportPutRiverStateAction
newRequestBuilder(ClusterAdminClient) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverAction
newRequestBuilder(ClusterAdminClient) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateAction
newRequestBuilder(ClusterAdminClient) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateAction
newRequestBuilder(ClusterAdminClient) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateAction
newRequestBuilder(ClusterAdminClient) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateAction
newResponse() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverAction
newResponse(RunRiverRequest, AtomicReferenceArray) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction
newResponse() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateAction
newResponse() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.TransportDeleteRiverStateAction
newResponse() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateAction
newResponse() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.TransportGetRiverStateAction
newResponse() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateAction
newResponse() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.TransportPostRiverStateAction
newResponse() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateAction
newResponse() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.TransportPutRiverStateAction
newRiverContext() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverFlow: Create a new river context for a river run
newRiverContext() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverFlow
newRiverContext() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
newRiverFlow(String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.RiverServiceLoader: A river flow encapsulates the thread that moves the data from source to mouth
newRiverMouth(String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.RiverServiceLoader: A river mouth is the Elasticsearch side of the river, where the bulk processor lives
newRiverSource(String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.RiverServiceLoader: A river source is the origin, the data producing side
next() - Method in class org.xbib.elasticsearch.plugin.jdbc.RiverPipeline
nextElement() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceEnumeration
nextRow(ResultSet, KeyValueStreamListener) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Executed when next row is fetched from result set
nextRow(SQLCommand, ResultSet, KeyValueStreamListener) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Action for the next row of the result set to be processed
nextRow(ResultSet, KeyValueStreamListener) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
nextRow(SQLCommand, ResultSet, KeyValueStreamListener) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Get next row and prepare the values for processing.
NO_SPEC - Static variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
NO_SPEC_INT - Static variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
nodeOperation(TransportRunRiverAction.NodeRiverExecuteRequest) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction
nthdayOfWeek - Variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression

O

onModule(RiversModule) - Method in class org.xbib.elasticsearch.plugin.jdbc.river.JDBCRiverPlugin
onModule(ActionModule) - Method in class org.xbib.elasticsearch.plugin.jdbc.river.JDBCRiverPlugin
onModule(RestModule) - Method in class org.xbib.elasticsearch.plugin.jdbc.river.JDBCRiverPlugin
openConnection(URL) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlStreamHandler
optype(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.util.IndexableObject: Set the operation type, either "index", "create", or "delete"
optype() - Method in interface org.xbib.elasticsearch.plugin.jdbc.util.IndexableObject: Get the operation type
optype(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
optype() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
org.xbib.elasticsearch.action.plugin.jdbc.run - package org.xbib.elasticsearch.action.plugin.jdbc.run
org.xbib.elasticsearch.action.plugin.jdbc.state.delete - package org.xbib.elasticsearch.action.plugin.jdbc.state.delete
org.xbib.elasticsearch.action.plugin.jdbc.state.get - package org.xbib.elasticsearch.action.plugin.jdbc.state.get
org.xbib.elasticsearch.action.plugin.jdbc.state.post - package org.xbib.elasticsearch.action.plugin.jdbc.state.post
org.xbib.elasticsearch.action.plugin.jdbc.state.put - package org.xbib.elasticsearch.action.plugin.jdbc.state.put
org.xbib.elasticsearch.plugin.jdbc - package org.xbib.elasticsearch.plugin.jdbc
org.xbib.elasticsearch.plugin.jdbc.classloader - package org.xbib.elasticsearch.plugin.jdbc.classloader
org.xbib.elasticsearch.plugin.jdbc.classloader.directory - package org.xbib.elasticsearch.plugin.jdbc.classloader.directory
org.xbib.elasticsearch.plugin.jdbc.classloader.jar - package org.xbib.elasticsearch.plugin.jdbc.classloader.jar
org.xbib.elasticsearch.plugin.jdbc.classloader.uri - package org.xbib.elasticsearch.plugin.jdbc.classloader.uri
org.xbib.elasticsearch.plugin.jdbc.client - package org.xbib.elasticsearch.plugin.jdbc.client
org.xbib.elasticsearch.plugin.jdbc.client.node - package org.xbib.elasticsearch.plugin.jdbc.client.node
org.xbib.elasticsearch.plugin.jdbc.client.transport - package org.xbib.elasticsearch.plugin.jdbc.client.transport
org.xbib.elasticsearch.plugin.jdbc.cron - package org.xbib.elasticsearch.plugin.jdbc.cron
org.xbib.elasticsearch.plugin.jdbc.execute - package org.xbib.elasticsearch.plugin.jdbc.execute
org.xbib.elasticsearch.plugin.jdbc.feeder - package org.xbib.elasticsearch.plugin.jdbc.feeder
org.xbib.elasticsearch.plugin.jdbc.keyvalue - package org.xbib.elasticsearch.plugin.jdbc.keyvalue
org.xbib.elasticsearch.plugin.jdbc.pipeline - package org.xbib.elasticsearch.plugin.jdbc.pipeline
org.xbib.elasticsearch.plugin.jdbc.pipeline.element - package org.xbib.elasticsearch.plugin.jdbc.pipeline.element
org.xbib.elasticsearch.plugin.jdbc.pipeline.executor - package org.xbib.elasticsearch.plugin.jdbc.pipeline.executor
org.xbib.elasticsearch.plugin.jdbc.river - package org.xbib.elasticsearch.plugin.jdbc.river
org.xbib.elasticsearch.plugin.jdbc.state - package org.xbib.elasticsearch.plugin.jdbc.state
org.xbib.elasticsearch.plugin.jdbc.util - package org.xbib.elasticsearch.plugin.jdbc.util
org.xbib.elasticsearch.rest.action.river.jdbc - package org.xbib.elasticsearch.rest.action.river.jdbc
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.simple - package org.xbib.elasticsearch.river.jdbc.strategy.simple
output(RiverMouth) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.RiverMouthKeyValueStreamListener

P

parse(Map<String, Object>) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.SQLCommand
parseType(ResultSet, Integer, int, Locale) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Parse a value in a row column
parseType(ResultSet, Integer, int, Locale) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Parse of value of result set
password - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
Pipeline<T,R extends PipelineRequest> - Interface in org.xbib.elasticsearch.plugin.jdbc.pipeline: A pipeline.
PipelineElement<E> - Interface in org.xbib.elasticsearch.plugin.jdbc.pipeline.element
PipelineException - Exception in org.xbib.elasticsearch.plugin.jdbc.pipeline
PipelineException(String) - Constructor for exception org.xbib.elasticsearch.plugin.jdbc.pipeline.PipelineException
PipelineException(Throwable) - Constructor for exception org.xbib.elasticsearch.plugin.jdbc.pipeline.PipelineException
PipelineException(String, Throwable) - Constructor for exception org.xbib.elasticsearch.plugin.jdbc.pipeline.PipelineException
PipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>> - Interface in org.xbib.elasticsearch.plugin.jdbc.pipeline: The Pipeline Executor can execute provided pipelines.
PipelineProvider<P extends Pipeline> - Interface in org.xbib.elasticsearch.plugin.jdbc.pipeline
PipelineRequest - Interface in org.xbib.elasticsearch.plugin.jdbc.pipeline
PlainIndexableObject - Class in org.xbib.elasticsearch.plugin.jdbc.util: A plain indexable object.
PlainIndexableObject() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
PlainKeyValueStreamListener<K,V> - Class in org.xbib.elasticsearch.plugin.jdbc.util
PlainKeyValueStreamListener() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.util.PlainKeyValueStreamListener
postRiverState(RiverStateService.RiverStateRequest, ActionListener<ClusterStateUpdateResponse>) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService: Post a new river for river state management
PostRiverStateAction - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.post
PostRiverStateRequest - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.post
PostRiverStateRequest() - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequest
PostRiverStateRequestBuilder - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.post
PostRiverStateRequestBuilder(ClusterAdminClient) - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequestBuilder
PostRiverStateResponse - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.post
PostRiverStateResponse() - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateResponse
PostRiverStateResponse(boolean) - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateResponse
prepare() - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.MetricSimplePipelineExecutor
prepare() - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.SimplePipelineExecutor
prepare() - Method in interface org.xbib.elasticsearch.plugin.jdbc.pipeline.PipelineExecutor: Prepare the pipeline execution.
prepareQuery(String) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Prepare query statement
prepareQuery(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Prepare a query statement
prepareUpdate(String) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Prepare insert/update statement
prepareUpdate(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Prepare an update statement
printStream - Variable in class org.xbib.elasticsearch.plugin.jdbc.feeder.JDBCFeeder
putMapping(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseIngestTransportClient
putMapping(Client, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.ConfigHelper
putMapping(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
putMapping(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
putRiverState(RiverStateService.RiverStateRequest, ActionListener<ClusterStateUpdateResponse>) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService: Put a new river into river state management
PutRiverStateAction - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.put
PutRiverStateRequest - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.put
PutRiverStateRequest() - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateRequest
PutRiverStateRequestBuilder - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.put
PutRiverStateRequestBuilder(ClusterAdminClient) - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateRequestBuilder
PutRiverStateResponse - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.put
PutRiverStateResponse() - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateResponse
PutRiverStateResponse(boolean) - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateResponse

R

readConnection - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
reader - Variable in class org.xbib.elasticsearch.plugin.jdbc.feeder.JDBCFeeder
readFrom(StreamInput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverRequest
readFrom(StreamInput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverResponse
readFrom(StreamInput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateRequest
readFrom(StreamInput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateResponse
readFrom(StreamInput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateRequest
readFrom(StreamInput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateResponse
readFrom(StreamInput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequest
readFrom(StreamInput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateResponse
readFrom(StreamInput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateRequest
readFrom(StreamInput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateResponse
readFrom(Reader) - Method in interface org.xbib.elasticsearch.plugin.jdbc.feeder.CommandLineInterpreter
readFrom(Reader) - Method in class org.xbib.elasticsearch.plugin.jdbc.feeder.JDBCFeeder
readFrom(StreamInput) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
readFrom(StreamInput) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStatesMetaData.Factory
refresh(Client, String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.client.ClientHelper
refresh(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Refresh the index.
refresh(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
refresh(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
register(CallableStatement, Map<String, Object>) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Register output variables for callable statement
register(CallableStatement, Map<String, Object>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource: Register variables in callable statement
release() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Release all resources
release() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
remove() - Method in class org.xbib.elasticsearch.plugin.jdbc.RiverPipeline: Removing pipeline requests is not supported.
repeat(char, int) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.Strings: Gives a string consisting of the given character repeated the given number of times.
replace(String, String, String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.Strings: Replaces all occurrences of a String within another String.
replace(String, String, String, int) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.Strings: Replaces a String with another String inside a larger String, for the first max values of the search String.
replaceOnce(String, String, String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.Strings: Replaces a String with another String inside a larger String, once.
replica(int) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseIngestTransportClient
replica(int) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: The number of replica for index creation
replica(int) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
replica(int) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
reset() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.ConfigHelper
resetSettings() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
ResourceEnumeration - Class in org.xbib.elasticsearch.plugin.jdbc.classloader
ResourceEnumeration(Collection, String) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.classloader.ResourceEnumeration
ResourceFinder - Interface in org.xbib.elasticsearch.plugin.jdbc.classloader: Abstraction of resource searching policy.
ResourceHandle - Interface in org.xbib.elasticsearch.plugin.jdbc.classloader: This is a handle (a connection) to some resource, which may be a class, native library, text file, image, etc.
ResourceLocation - Interface in org.xbib.elasticsearch.plugin.jdbc.classloader: This is a location which is searched by
RestRiverStateAction - Class in org.xbib.elasticsearch.rest.action.river.jdbc
RestRiverStateAction(Settings, Client, RestController) - Constructor for class org.xbib.elasticsearch.rest.action.river.jdbc.RestRiverStateAction
RestRunRiverAction - Class in org.xbib.elasticsearch.rest.action.river.jdbc
RestRunRiverAction(Settings, RestController, Client) - Constructor for class org.xbib.elasticsearch.rest.action.river.jdbc.RestRunRiverAction
resume() - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
resume() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
resume() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
resume() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Resume river mouth after suspend.
resume() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Resume river source
resume() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
resume() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
RiverContext - Interface in org.xbib.elasticsearch.river.jdbc: The River Context is a collection of objects that are relevant to parameterization of a river run.
RiverFlow<RC extends RiverContext> - Interface in org.xbib.elasticsearch.river.jdbc: A RiverFlow is the controlling component for creatin RiverContexts which can be processed independently from each other.
RiverMouth<RC extends RiverContext> - Interface in org.xbib.elasticsearch.river.jdbc: The river mouth is the abstraction of the destination where all the data is flowing from the river source.
RiverMouthKeyValueStreamListener<K,V> - Class in org.xbib.elasticsearch.plugin.jdbc.util: This class consumes pairs from a key/value stream and transports them to the river mouth.
RiverMouthKeyValueStreamListener() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.util.RiverMouthKeyValueStreamListener
RiverPipeline - Class in org.xbib.elasticsearch.plugin.jdbc: A river pipeline is a collection of threads that can be executed in parallel during a river run
RiverPipeline(RiverFlow) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.RiverPipeline
rivers(RiversService) - Static method in class org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction
RiverServiceLoader - Class in org.xbib.elasticsearch.plugin.jdbc.util: The river service loader
RiverServiceLoader() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.util.RiverServiceLoader
RiverSource<RC extends RiverContext> - Interface in org.xbib.elasticsearch.river.jdbc: The river source models the data producing side
RiverState - Class in org.xbib.elasticsearch.plugin.jdbc.state: A river state represents a point in time when a river has a defined behavior with a set of parameters
RiverState() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
RiverStateModule - Class in org.xbib.elasticsearch.plugin.jdbc.state
RiverStateModule() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.state.RiverStateModule
RiverStateService - Class in org.xbib.elasticsearch.plugin.jdbc.state: The RiverStateService manages reading and writing of river states in the cluster state
RiverStateService(Settings, ClusterService) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService
RiverStateService.DeleteRiverStateRequest - Class in org.xbib.elasticsearch.plugin.jdbc.state
RiverStateService.DeleteRiverStateRequest(String, String, String) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService.DeleteRiverStateRequest: Creates a new delete river state request
RiverStateService.RiverStateRequest - Class in org.xbib.elasticsearch.plugin.jdbc.state
RiverStateService.RiverStateRequest(String, RiverState) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.state.RiverStateService.RiverStateRequest: Constructs new register river request
RiverStatesMetaData - Class in org.xbib.elasticsearch.plugin.jdbc.state: Contains metadata about registered rivers
RiverStatesMetaData(RiverState...) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.state.RiverStatesMetaData: Constructs new river state metadata
RiverStatesMetaData.Factory - Class in org.xbib.elasticsearch.plugin.jdbc.state: River state metadata factory
RiverStatesMetaData.Factory() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.state.RiverStatesMetaData.Factory
RiverThread<T,R extends PipelineRequest,P extends Pipeline<T,R>> - Class in org.xbib.elasticsearch.plugin.jdbc: A thread that spawns a single step of river operation.
RiverThread(RiverFlow, List<Map<String, Object>>) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.RiverThread
run() - Method in class org.xbib.elasticsearch.plugin.jdbc.river.JDBCRiver: Execute river once from execute API, no matter if schedule/interval is defined.
run() - Method in class org.xbib.elasticsearch.plugin.jdbc.RiverThread
RunnableRiver - Interface in org.xbib.elasticsearch.plugin.jdbc.execute
Runner - Class in org.xbib.elasticsearch.plugin.jdbc.feeder: Stub for loading a Java class and execute it.
Runner() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.feeder.Runner
RunRiverAction - Class in org.xbib.elasticsearch.action.plugin.jdbc.run
RunRiverRequest - Class in org.xbib.elasticsearch.action.plugin.jdbc.run
RunRiverRequest() - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverRequest
RunRiverRequestBuilder - Class in org.xbib.elasticsearch.action.plugin.jdbc.run
RunRiverRequestBuilder(ClusterAdminClient) - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverRequestBuilder
RunRiverResponse - Class in org.xbib.elasticsearch.action.plugin.jdbc.run
RunRiverResponse() - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverResponse

S

schedule(Runnable, CronExpression) - Method in interface org.xbib.elasticsearch.plugin.jdbc.cron.CronExecutorService: Schedules the specified task to execute according to the specified cron expression.
schedule(Runnable, CronExpression) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronThreadPoolExecutor
SECOND - Static variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
seconds - Variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
set(RiverContext) - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.element.ContextPipelineElement
set(E) - Method in interface org.xbib.elasticsearch.plugin.jdbc.pipeline.element.PipelineElement
setAbort() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequest
setAbort() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequestBuilder
setAutoCommit(boolean) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set auto commit
setAutoCommit(boolean) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setCalendarHour(Calendar, int) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression: Advance the calendar to the particular hour paying particular attention to daylight saving problems.
setCallable(boolean) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.SQLCommand
setClient(Client) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverFlow
setClient(Client) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
setColumnNameMap(Map<String, Object>) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set column name map.
setColumnNameMap(Map<String, Object>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setConcurrency(int) - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.MetricSimplePipelineExecutor
setConcurrency(int) - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.SimplePipelineExecutor
setConcurrency(int) - Method in interface org.xbib.elasticsearch.plugin.jdbc.pipeline.PipelineExecutor: Set the concurrency of this pipeline setExecutor
setConnectionProperties(Map<String, Object>) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Optional JDBC connection properties
setConnectionProperties(Map<String, Object>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setCounter(Integer) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
setCustom(Map<String, Object>) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
setDefinition(Map<String, Object>) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set river instance definition
setDefinition(Map<String, Object>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setExecuted(boolean[]) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverResponse
setExpectedUrl(URL) - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlStreamHandler
setFetchSize(int) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set fetch size
setFetchSize(int) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setId(String) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Set document identifier for next document to be indexed
setId(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
setIndex(String) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Set default index name for this river mouth
setIndex(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
setIndexSettings(Settings) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Set index settings
setIndexSettings(Settings) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
setIngestFactory(IngestFactory) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverFlow: Set ingest factory
setIngestFactory(IngestFactory) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Set ingest factory
setIngestFactory(IngestFactory) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
setIngestFactory(IngestFactory) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
setInterrupted(boolean) - Method in class org.xbib.elasticsearch.plugin.jdbc.RiverPipeline
setLastActive(DateTime, DateTime) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState: Set the last river activity.
setLastDatabaseMetadata(Map<String, Object>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setLastEndDate(long) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setLastExecutionEndDate(long) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setLastExecutionStartDate(long) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setLastResultSetMetadata(Map<String, Object>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setLastRow(Map<String, Object>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setLastRowCount(long) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setLastRunTimeStampOverlap(TimeValue) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverContext
setLastStartDate(long) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setLocale(Locale) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Set the locale for JDBC
setLocale(Locale) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
setMap(Map<String, Object>) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
setMaxRetryWait(TimeValue) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set maximum count of retries
setMaxRetryWait(TimeValue) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setMaxRows(int) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set max rows
setMaxRows(int) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setMetric(MeterMetric) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set metric
setMetric(MeterMetric) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverFlow: Set metric
setMetric(MeterMetric) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setMetric(MeterMetric) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
setName(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
setParameters(List<Object>) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.SQLCommand
setPassword(String) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Set the password authentication
setPassword(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
setPipelineProvider(PipelineProvider<P>) - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.MetricSimplePipelineExecutor
setPipelineProvider(PipelineProvider<P>) - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.SimplePipelineExecutor
setPipelineProvider(PipelineProvider<P>) - Method in interface org.xbib.elasticsearch.plugin.jdbc.pipeline.PipelineExecutor: Set the provider of this pipeline setExecutor
setQueryTimeout(int) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set result set query timeout
setQueryTimeout(int) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setQueue(Queue<RiverContext>) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverFlow: Set queue for processing RiverContext requests
setQueue(Queue<RiverContext>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
setRegister(Map<String, Object>) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.SQLCommand: A register is for parameters of a callable statement.
setResultSetConcurrency(String) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set result set concurrency
setResultSetConcurrency(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setResultSetType(String) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set result set type
setResultSetType(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setResume() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequest
setResume() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequestBuilder
setRetries(int) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set retries
setRetries(int) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setRiverContext(RC) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Set the river context
setRiverContext(RC) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Set the river context
setRiverContext(SimpleRiverContext) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
setRiverContext(RC) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
setRiverMouth(RiverMouth) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set river mouth
setRiverMouth(RiverMouth) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setRiverName(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverRequest
setRiverName(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverRequestBuilder
setRiverName(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateRequest
setRiverName(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateRequestBuilder
setRiverName(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateRequest
setRiverName(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateRequestBuilder
setRiverName(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequest
setRiverName(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequestBuilder
setRiverName(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateRequest
setRiverName(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateRequestBuilder
setRiverName(RiverName) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverFlow: Sets the river name
setRiverName(RiverName) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
setRiverSource(RiverSource) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set river source
setRiverSource(RiverSource) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setRiverState(RiverState) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequest
setRiverState(RiverState) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequestBuilder
setRiverState(RiverState) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateRequest
setRiverState(RiverState) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateRequestBuilder
setRiverState(RiverState) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set river state
setRiverState(RiverState) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setRiverType(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverRequest
setRiverType(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverRequestBuilder
setRiverType(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateRequest
setRiverType(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateRequest
setRiverType(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateRequestBuilder
setRiverType(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequest
setRiverType(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequestBuilder
setRiverType(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateRequest
setRiverType(String) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateRequestBuilder
setRounding(String) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set rounding of big decimal values.
setRounding(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setScale(int) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set scale of big decimal values.
setScale(int) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setSettings(Settings) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
setSettings(Settings) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
setSettings(Settings) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
setSettings(Settings) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverFlow: Set the settings
setSettings(Settings) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
setSQL(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.SQLCommand
setStarted(DateTime) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
setStatements(List<SQLCommand>) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Set the list of SQL statements
setStatements(List<SQLCommand>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setSuspend() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequest
setSuspend() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequestBuilder
setTimestampDiffSupported(boolean) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
setTimeZone(TimeZone) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression: Sets the time zone for which this CronExpression will be resolved.
setTimeZone(TimeZone) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Set the timezone for JDBC setTimestamp() calls with calendar object.
setTimeZone(TimeZone) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
setting(InputStream) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
setting(String, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.ConfigHelper
setting(String, Boolean) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.ConfigHelper
setting(String, Integer) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.ConfigHelper
setting(InputStream) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.ConfigHelper
setting(InputStream) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Create settings
setting(InputStream) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
settings(Settings) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.ConfigHelper
settings() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.ConfigHelper
settingsBuilder() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.ConfigHelper
setType(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
setType(String) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Set default index type name for this river mouth
setType(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
setTypeMapping(Map<String, String>) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Set index type mappings
setTypeMapping(Map<String, String>) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
setUrl(String) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Set JDBC connection URL
setUrl(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
setUser(String) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Set the user authentication
setUser(String) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
shards(int) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseIngestTransportClient
shards(int) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: The number of shards for index creation
shards(int) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
shards(int) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
shouldIgnoreNull(boolean) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainKeyValueStreamListener
shouldIgnoreNull(boolean) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.RiverMouthKeyValueStreamListener
shouldIgnoreNull(boolean) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Should null values in columns be ignored for indexing
shouldIgnoreNull(boolean) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
shouldIgnoreNull() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
shouldPrepareDatabaseMetadata(boolean) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Should database metadata be used in parameter variables
shouldPrepareDatabaseMetadata(boolean) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
shouldPrepareDatabaseMetadata() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
shouldPrepareResultSetMetadata(boolean) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Should result set metadata be used in parameter variables
shouldPrepareResultSetMetadata(boolean) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
shouldPrepareResultSetMetadata() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
shouldTreatBinaryAsString(boolean) - Method in interface org.xbib.elasticsearch.river.jdbc.RiverContext: Should binary types (byte arrays) be treated as JSON strings
shouldTreatBinaryAsString(boolean) - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
shouldTreatBinaryAsString() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
shutdown() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseTransportClient
shutdown() - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Shutdown the ingesting
shutdown() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
shutdown() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
shutdown() - Method in interface org.xbib.elasticsearch.plugin.jdbc.feeder.CommandLineInterpreter
shutdown() - Method in class org.xbib.elasticsearch.plugin.jdbc.feeder.JDBCFeeder
shutdown() - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.SimplePipelineExecutor
shutdown() - Method in interface org.xbib.elasticsearch.plugin.jdbc.pipeline.PipelineExecutor: Shut down this pipeline executor.
shutdown() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Shutdown river mouth and release all resources, e.g.
shutdown() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Shutdown source
shutdown() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
shutdown() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
shutdownHook() - Method in interface org.xbib.elasticsearch.plugin.jdbc.feeder.CommandLineInterpreter
shutdownHook() - Method in class org.xbib.elasticsearch.plugin.jdbc.feeder.JDBCFeeder: Shut down feeder instance by Ctrl-C
SimplePipelineExecutor<T,R extends PipelineRequest,P extends Pipeline<T,R>> - Class in org.xbib.elasticsearch.plugin.jdbc.pipeline.executor: A simple pipeline executor.
SimplePipelineExecutor() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.SimplePipelineExecutor
SimpleRiverContext - Class in org.xbib.elasticsearch.river.jdbc.strategy.simple: The river context consists of the parameters that span source and mouth settings.
SimpleRiverContext() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
SimpleRiverFlow<RC extends RiverContext> - Class in org.xbib.elasticsearch.river.jdbc.strategy.simple: Simple river flow implementation
SimpleRiverFlow() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
SimpleRiverMouth - Class in org.xbib.elasticsearch.river.jdbc.strategy.simple: Simple river mouth implementation.
SimpleRiverMouth() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
SimpleRiverSource<RC extends SimpleRiverContext> - Class in org.xbib.elasticsearch.river.jdbc.strategy.simple: Simple river source implementation.
SimpleRiverSource() - Constructor for class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
skipWhiteSpace(int, String) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
source(Map<String, Object>) - Method in interface org.xbib.elasticsearch.plugin.jdbc.util.IndexableObject
source() - Method in interface org.xbib.elasticsearch.plugin.jdbc.util.IndexableObject
source(Map<String, Object>) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
source() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
SQLCommand - Class in org.xbib.elasticsearch.plugin.jdbc.util: The SQL command
SQLCommand() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.util.SQLCommand
start() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.Metric
start() - Method in interface org.xbib.elasticsearch.plugin.jdbc.feeder.CommandLineInterpreter
start() - Method in class org.xbib.elasticsearch.plugin.jdbc.feeder.JDBCFeeder
start() - Method in class org.xbib.elasticsearch.plugin.jdbc.river.JDBCRiver: Called from Elasticsearch after recovery of indices when a node has initialized.
startBulk(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Start bulk mode
startBulk(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.Metric
startBulk(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
startBulk(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
StatefulRiver - Interface in org.xbib.elasticsearch.plugin.jdbc.state: A stateful river is an extension of a river with a river state
stopBulk(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Stops bulk mode.
stopBulk(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.Metric
stopBulk(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
stopBulk(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
storeExpressionVals(int, String, int) - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
strategy() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverFlow: The name of the strategy the river flow belongs to
strategy() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: The river strategy
strategy() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: The strategy this river source supports.
strategy() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverFlow
strategy() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverMouth
strategy() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.column.ColumnRiverSource
strategy() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverFlow
strategy() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
strategy() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
Strings - Class in org.xbib.elasticsearch.plugin.jdbc.util
suspend() - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest
suspend() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
suspend() - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
suspend() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverMouth: Suspend river mouth.
suspend() - Method in interface org.xbib.elasticsearch.river.jdbc.RiverSource: Suspend river source
suspend() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
suspend() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
suspended - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth
suspended - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource

T

timezone - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
toLocale(String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.util.LocaleUtil
toString() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateResponse
toString() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateResponse
toString() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateResponse
toString() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateResponse
toString() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.AbstractResourceHandle
toString() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.AbstractURLResourceLocation
toString() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.jar.JarFileUrlConnection
toString() - Method in class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIClassLoader
toString() - Method in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression: Returns the string representation of the CronExpression
toString() - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.element.ContextPipelineElement
toString() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
toString() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
toString() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.SQLCommand
toString() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.Values
toString() - Method in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverContext
toXContent(XContentBuilder, ToXContent.Params) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverResponse
toXContent(XContentBuilder, ToXContent.Params) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateResponse
toXContent(XContentBuilder, ToXContent.Params) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateResponse
toXContent(XContentBuilder, ToXContent.Params) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateResponse
toXContent(XContentBuilder, ToXContent.Params) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateResponse
toXContent(XContentBuilder, ToXContent.Params) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
toXContent(RiverStatesMetaData, XContentBuilder, ToXContent.Params) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStatesMetaData.Factory
toXContent(XContentBuilder, ToXContent.Params) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
toXContent(XContentBuilder, ToXContent.Params, Map<String, Object>) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject: Recursive method to build XContent from a key/value map of Values
toXContent(XContentBuilder, ToXContent.Params, List) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
toXContent(XContentBuilder, ToXContent.Params) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.Values
TransportDeleteRiverStateAction - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.delete
TransportDeleteRiverStateAction(Settings, ThreadPool, ClusterService, TransportService, Injector) - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.TransportDeleteRiverStateAction
TransportGetRiverStateAction - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.get
TransportGetRiverStateAction(Settings, ThreadPool, ClusterService, TransportService) - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.get.TransportGetRiverStateAction
TransportPostRiverStateAction - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.post
TransportPostRiverStateAction(Settings, ThreadPool, ClusterService, TransportService, Injector) - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.post.TransportPostRiverStateAction
TransportPutRiverStateAction - Class in org.xbib.elasticsearch.action.plugin.jdbc.state.put
TransportPutRiverStateAction(Settings, ThreadPool, ClusterService, TransportService, Injector) - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.state.put.TransportPutRiverStateAction
TransportRunRiverAction - Class in org.xbib.elasticsearch.action.plugin.jdbc.run
TransportRunRiverAction(Settings, ClusterName, ThreadPool, ClusterService, TransportService, Injector) - Constructor for class org.xbib.elasticsearch.action.plugin.jdbc.run.TransportRunRiverAction
type() - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStatesMetaData.Factory
TYPE - Static variable in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStatesMetaData
type(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.util.IndexableObject: Set the type
type() - Method in interface org.xbib.elasticsearch.plugin.jdbc.util.IndexableObject: Get the type
type(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
type() - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainIndexableObject
type - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverMouth

U

updateIndexSetting(Client, String, String, Object) - Static method in class org.xbib.elasticsearch.plugin.jdbc.client.ClientHelper
updateReplicaLevel(Client, String, int) - Static method in class org.xbib.elasticsearch.plugin.jdbc.client.ClientHelper
updateReplicaLevel(String, int) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Add replica level.
updateReplicaLevel(String, int) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
updateReplicaLevel(String, int) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
URIClassLoader - Class in org.xbib.elasticsearch.plugin.jdbc.classloader.uri: Equivalent of java.net.URLClassloader but without bugs related to ill-formed URLs and with customizable JAR caching policy.
URIClassLoader() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIClassLoader: Creates URIClassLoader
URIClassLoader(ClassLoader) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIClassLoader: Creates URIClassLoader with the specified parent class loader.
URIResourceFinder - Class in org.xbib.elasticsearch.plugin.jdbc.classloader.uri
URIResourceFinder() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.classloader.uri.URIResourceFinder
url - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
user - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource

V

validate() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateRequest
validate() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateRequest
validate() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequest
validate() - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateRequest
valueOf(String) - Static method in enum org.xbib.elasticsearch.plugin.jdbc.util.ControlKeys: Returns the enum constant of this type with the specified name.
values(List<V>) - Method in interface org.xbib.elasticsearch.plugin.jdbc.keyvalue.KeyValueStreamListener: Receive values for the declared keys
values() - Static method in enum org.xbib.elasticsearch.plugin.jdbc.util.ControlKeys: Returns an array containing the constants of this enum type, in the order they are declared.
values(List<V>) - Method in class org.xbib.elasticsearch.plugin.jdbc.util.PlainKeyValueStreamListener: Receive values.
Values<O> - Class in org.xbib.elasticsearch.plugin.jdbc.util: This class represents one or many values.
Values(Object, O, boolean) - Constructor for class org.xbib.elasticsearch.plugin.jdbc.util.Values: Create new Values from an existing values by appending a value.
VolumeFormatUtil - Class in org.xbib.elasticsearch.plugin.jdbc.util
VolumeFormatUtil() - Constructor for class org.xbib.elasticsearch.plugin.jdbc.util.VolumeFormatUtil

W

waitFor(BulkProcessor, TimeValue) - Static method in class org.xbib.elasticsearch.plugin.jdbc.client.BulkProcessorHelper
waitFor() - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.MetricSimplePipelineExecutor
waitFor() - Method in class org.xbib.elasticsearch.plugin.jdbc.pipeline.executor.SimplePipelineExecutor: Wait for all results of the executions.
waitFor() - Method in interface org.xbib.elasticsearch.plugin.jdbc.pipeline.PipelineExecutor: Execute the pipelines.
waitForCluster(ClusterHealthStatus, TimeValue) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.BaseIngestTransportClient
waitForCluster(Client, ClusterHealthStatus, TimeValue) - Static method in class org.xbib.elasticsearch.plugin.jdbc.client.ClientHelper
waitForCluster(ClusterHealthStatus, TimeValue) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Wait for cluster being healthy.
waitForCluster(ClusterHealthStatus, TimeValue) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
waitForCluster(ClusterHealthStatus, TimeValue) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
waitForRecovery(Client, String) - Static method in class org.xbib.elasticsearch.plugin.jdbc.client.ClientHelper
waitForRecovery(String) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Wait for index recovery (after replica change)
waitForRecovery(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
waitForRecovery(String) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
waitForResponses(TimeValue) - Method in interface org.xbib.elasticsearch.plugin.jdbc.client.Ingest: Wait for all outstanding responses
waitForResponses(TimeValue) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.node.BulkNodeClient
waitForResponses(TimeValue) - Method in class org.xbib.elasticsearch.plugin.jdbc.client.transport.BulkTransportClient
wasActiveAt(DateTime) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState: Was the river active at a certain time? Only the last activity can be checked.
wasInactiveAt(DateTime) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
writeConnection - Variable in class org.xbib.elasticsearch.river.jdbc.strategy.simple.SimpleRiverSource
writer - Variable in class org.xbib.elasticsearch.plugin.jdbc.feeder.JDBCFeeder
writeTo(StreamOutput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverRequest
writeTo(StreamOutput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.run.RunRiverResponse
writeTo(StreamOutput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateRequest
writeTo(StreamOutput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.delete.DeleteRiverStateResponse
writeTo(StreamOutput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateRequest
writeTo(StreamOutput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.get.GetRiverStateResponse
writeTo(StreamOutput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateRequest
writeTo(StreamOutput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.post.PostRiverStateResponse
writeTo(StreamOutput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateRequest
writeTo(StreamOutput) - Method in class org.xbib.elasticsearch.action.plugin.jdbc.state.put.PutRiverStateResponse
writeTo(Writer) - Method in interface org.xbib.elasticsearch.plugin.jdbc.feeder.CommandLineInterpreter
writeTo(Writer) - Method in class org.xbib.elasticsearch.plugin.jdbc.feeder.JDBCFeeder
writeTo(StreamOutput) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverState
writeTo(RiverStatesMetaData, StreamOutput) - Method in class org.xbib.elasticsearch.plugin.jdbc.state.RiverStatesMetaData.Factory

Y

YEAR - Static variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression
years - Variable in class org.xbib.elasticsearch.plugin.jdbc.cron.CronExpression

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