Modifier and Type | Method and Description |
---|---|
static RiverMouth |
RiverServiceLoader.newRiverMouth(String strategy)
A river mouth is the Elasticsearch side of the river, where the bulk processor lives
|
Modifier and Type | Method and Description |
---|---|
RiverMouthKeyValueStreamListener<K,V> |
RiverMouthKeyValueStreamListener.output(RiverMouth output) |
Modifier and Type | Method and Description |
---|---|
RiverMouth |
RiverContext.getRiverMouth()
Get river mouth
|
RiverMouth<RC> |
RiverMouth.newInstance()
Create a new river mouth instance
|
RiverMouth |
RiverMouth.setId(String id)
Set document identifier for next document to be indexed
|
RiverMouth |
RiverMouth.setIndex(String index)
Set default index name for this river mouth
|
RiverMouth |
RiverMouth.setIndexSettings(org.elasticsearch.common.settings.Settings indexSettings)
Set index settings
|
RiverMouth |
RiverMouth.setIngestFactory(IngestFactory ingestFactory)
Set ingest factory
|
RiverMouth<RC> |
RiverMouth.setRiverContext(RC context)
Set the river context
|
RiverMouth |
RiverMouth.setType(String type)
Set default index type name for this river mouth
|
RiverMouth |
RiverMouth.setTypeMapping(Map<String,String> typeMapping)
Set index type mappings
|
Modifier and Type | Method and Description |
---|---|
RiverContext |
RiverContext.setRiverMouth(RiverMouth riverMouth)
Set river mouth
|
Modifier and Type | Class and Description |
---|---|
class |
ColumnRiverMouth
River mouth implementation for the 'column' strategy
|
Modifier and Type | Method and Description |
---|---|
protected ColumnRiverContext |
ColumnRiverFlow.fillRiverContext(ColumnRiverContext riverContext,
RiverState state,
RiverSource riverSource,
RiverMouth riverMouth) |
Modifier and Type | Class and Description |
---|---|
class |
SimpleRiverMouth
Simple river mouth implementation.
|
Modifier and Type | Method and Description |
---|---|
protected RiverMouth |
SimpleRiverFlow.createRiverMouth(Map<String,Object> params) |
RiverMouth |
SimpleRiverContext.getRiverMouth() |
Modifier and Type | Method and Description |
---|---|
protected RC |
SimpleRiverFlow.fillRiverContext(RC riverContext,
RiverState state,
RiverSource riverSource,
RiverMouth riverMouth) |
SimpleRiverContext |
SimpleRiverContext.setRiverMouth(RiverMouth mouth) |
elasticsearch-river-jdbc