Skip to content

Instantly share code, notes, and snippets.

import org.elasticsearch.common.logging.ESLogger
import org.elasticsearch.action.admin.indices.exists.IndicesExistsRequest
import org.elasticsearch.cluster.ClusterState
import org.elasticsearch.cluster.metadata.IndexMetaData
import org.elasticsearch.common.xcontent.XContentFactory._
import org.elasticsearch.action.bulk.{BulkResponse, BulkRequestBuilder}
import org.elasticsearch.action.ActionListener
import java.util.concurrent.atomic.AtomicInteger
import org.elasticsearch.plugins.AbstractPlugin
import org.elasticsearch.common.inject.{Inject, AbstractModule, Module}
import org.elasticsearch.river._
import org.elasticsearch.client.Client
class JdbcRiverPlugin extends AbstractPlugin {
def name: String = {
"jdbc-river"
}