Packages

class TableReaderSettingsBuilder[K, V] extends WithClientConfig

Source
PravegaSettings.scala
Linear Supertypes
WithClientConfig, AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. TableReaderSettingsBuilder
  2. WithClientConfig
  3. AnyRef
  4. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Instance Constructors

  1. new TableReaderSettingsBuilder(config: Config, keySerializer: Serializer[K], valueSerializer: Serializer[V], tableKeyExtractor: Option[(K) => TableKey], clientConfig: Option[ClientConfig] = None, clientConfigModifier: Option[(ClientConfigBuilder) => ClientConfigBuilder] = None, keyValueTableClientConfigurationBuilder: KeyValueTableClientConfigurationBuilder, keyValueTableClientConfigurationBuilderCustomizer: Option[(KeyValueTableClientConfigurationBuilder) => KeyValueTableClientConfigurationBuilder] = None, maximumInflightMessages: Int, maxEntriesAtOnce: Int)

Value Members

  1. def build(): TableReaderSettings[K, V]
  2. def clientConfigBuilder(clientConfigModifier: (ClientConfigBuilder) => ClientConfigBuilder): TableReaderSettingsBuilder[K, V]
  3. def keyValueTableClientConfigurationBuilder(f: (KeyValueTableClientConfigurationBuilder) => KeyValueTableClientConfigurationBuilder): TableReaderSettingsBuilder[K, V]
  4. def withClientConfigModifier(clientConfig: ClientConfig): TableReaderSettingsBuilder[K, V]
  5. def withKeyExtractor(extractor: (K) => TableKey): TableReaderSettingsBuilder[K, V]
  6. def withMaxEntriesAtOnce(i: Int): TableReaderSettingsBuilder[K, V]
  7. def withMaximumInflightMessages(i: Int): TableReaderSettingsBuilder[K, V]

Deprecated Value Members

  1. def withTableKey(extractor: (K) => TableKey): TableReaderSettingsBuilder[K, V]
    Annotations
    @deprecated
    Deprecated

    (Since version Alpakka 4.0.0) Use withKeyExtractor instead