Packages

class TableWriterSettingsBuilder[K, V] extends WithClientConfig

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

Instance Constructors

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

Value Members

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