dbcp / Exports / elasticsearch
- openElasticSearch
- openElasticSearchInput
- openElasticSearchOutput
- streamFromElasticSearch
- streamToElasticSearch
• Const batch2: any
Defined in: elasticsearch.ts:6
▸ openElasticSearch(args: { elasticSearch?: Client ; name?: string ; password?: string ; user?: string }): Promise<Client>
| Name | Type |
|---|---|
args |
object |
args.elasticSearch? |
Client |
args.name? |
string |
args.password? |
string |
args.user? |
string |
Returns: Promise<Client>
Defined in: elasticsearch.ts:36
▸ openElasticSearchInput(args: { inputElasticSearch?: Client ; inputName?: string ; inputPassword?: string ; inputUser?: string }): Promise<Client>
| Name | Type |
|---|---|
args |
object |
args.inputElasticSearch? |
Client |
args.inputName? |
string |
args.inputPassword? |
string |
args.inputUser? |
string |
Returns: Promise<Client>
Defined in: elasticsearch.ts:8
▸ openElasticSearchOutput(args: { outputElasticSearch?: Client ; outputName?: string ; outputPassword?: string ; outputUser?: string }): Promise<Client>
| Name | Type |
|---|---|
args |
object |
args.outputElasticSearch? |
Client |
args.outputName? |
string |
args.outputPassword? |
string |
args.outputUser? |
string |
Returns: Promise<Client>
Defined in: elasticsearch.ts:22
▸ streamFromElasticSearch(client: Client, options: { batchSize?: number ; index: string ; orderBy?: string[] }): Promise<ReadableStreamTree>
| Name | Type |
|---|---|
client |
Client |
options |
object |
options.batchSize? |
number |
options.index |
string |
options.orderBy? |
string[] |
Returns: Promise<ReadableStreamTree>
Defined in: elasticsearch.ts:54
▸ streamToElasticSearch(client: Client, options: { batchSize?: number ; bulkOptions?: any ; extra?: Record<string, any> ; extraOutput?: boolean ; index: string }): WritableStreamTree
| Name | Type |
|---|---|
client |
Client |
options |
object |
options.batchSize? |
number |
options.bulkOptions? |
any |
options.extra? |
Record<string, any> |
options.extraOutput? |
boolean |
options.index |
string |
Returns: WritableStreamTree
Defined in: elasticsearch.ts:128