final class ElasticsearchSourceSettings extends SourceSettingsBase[ApiVersion, ElasticsearchSourceSettings]

Configure Elastiscsearch sources.

Source
ElasticsearchSourceSettings.scala
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ElasticsearchSourceSettings
  2. SourceSettingsBase
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. val apiVersion: ApiVersion
    Definition Classes
    SourceSettingsBase
  2. val bufferSize: Int
    Definition Classes
    SourceSettingsBase
  3. val connection: ElasticsearchConnectionSettings
    Definition Classes
    SourceSettingsBase
  4. val includeDocumentVersion: Boolean
    Definition Classes
    SourceSettingsBase
  5. def scroll: String
    Definition Classes
    SourceSettingsBase
  6. val scrollDuration: FiniteDuration
    Definition Classes
    SourceSettingsBase
  7. def toString(): String
    Definition Classes
    ElasticsearchSourceSettings → AnyRef → Any
  8. def withApiVersion(value: ApiVersion): ElasticsearchSourceSettings
    Definition Classes
    SourceSettingsBase
  9. def withBufferSize(value: Int): ElasticsearchSourceSettings
    Definition Classes
    SourceSettingsBase
  10. def withConnection(value: ElasticsearchConnectionSettings): ElasticsearchSourceSettings
    Definition Classes
    SourceSettingsBase
  11. def withIncludeDocumentVersion(value: Boolean): ElasticsearchSourceSettings

    If includeDocumentVersion is true, '_version' is returned with the search-results * https://www.elastic.co/guide/en/elasticsearch/reference/6.8/search-request-version.html * https://www.elastic.co/guide/en/elasticsearch/guide/current/optimistic-concurrency-control.html

    If includeDocumentVersion is true, '_version' is returned with the search-results * https://www.elastic.co/guide/en/elasticsearch/reference/6.8/search-request-version.html * https://www.elastic.co/guide/en/elasticsearch/guide/current/optimistic-concurrency-control.html

    Definition Classes
    SourceSettingsBase
  12. def withScrollDuration(value: Duration): ElasticsearchSourceSettings
    Definition Classes
    SourceSettingsBase
  13. def withScrollDuration(value: FiniteDuration): ElasticsearchSourceSettings
    Definition Classes
    SourceSettingsBase