Interface InfluxDBv3EnterpriseParameters.Builder

All Superinterfaces:
Buildable, CopyableBuilder<InfluxDBv3EnterpriseParameters.Builder,InfluxDBv3EnterpriseParameters>, SdkBuilder<InfluxDBv3EnterpriseParameters.Builder,InfluxDBv3EnterpriseParameters>, SdkPojo
Enclosing class:
InfluxDBv3EnterpriseParameters
@Mutable @NotThreadSafe public static interface InfluxDBv3EnterpriseParameters.Builder extends SdkPojo, CopyableBuilder<InfluxDBv3EnterpriseParameters.Builder,InfluxDBv3EnterpriseParameters>

  • Method Details

    • queryFileLimit

      InfluxDBv3EnterpriseParameters.Builder queryFileLimit(Integer queryFileLimit)

      Limits the number of Parquet files a query can access. If a query attempts to read more than this limit, InfluxDB 3 returns an error.

      Default: 432

      Parameters:
      queryFileLimit - Limits the number of Parquet files a query can access. If a query attempts to read more than this limit, InfluxDB 3 returns an error.

      Default: 432

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • queryLogSize

      InfluxDBv3EnterpriseParameters.Builder queryLogSize(Integer queryLogSize)

      Defines the size of the query log. Up to this many queries remain in the log before older queries are evicted to make room for new ones.

      Default: 1000

      Parameters:
      queryLogSize - Defines the size of the query log. Up to this many queries remain in the log before older queries are evicted to make room for new ones.

      Default: 1000

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • logFilter

      InfluxDBv3EnterpriseParameters.Builder logFilter(String logFilter)

      Sets the filter directive for logs.

      Parameters:
      logFilter - Sets the filter directive for logs.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • logFormat

      InfluxDBv3EnterpriseParameters.Builder logFormat(String logFormat)

      Defines the message format for logs.

      Default: full

      Parameters:
      logFormat - Defines the message format for logs.

      Default: full

      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • logFormat

      InfluxDBv3EnterpriseParameters.Builder logFormat(LogFormats logFormat)

      Defines the message format for logs.

      Default: full

      Parameters:
      logFormat - Defines the message format for logs.

      Default: full

      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • dataFusionNumThreads

      InfluxDBv3EnterpriseParameters.Builder dataFusionNumThreads(Integer dataFusionNumThreads)

      Sets the maximum number of DataFusion runtime threads to use.

      Parameters:
      dataFusionNumThreads - Sets the maximum number of DataFusion runtime threads to use.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • dataFusionRuntimeType

      InfluxDBv3EnterpriseParameters.Builder dataFusionRuntimeType(String dataFusionRuntimeType)

      Specifies the DataFusion tokio runtime type.

      Default: multi-thread

      Parameters:
      dataFusionRuntimeType - Specifies the DataFusion tokio runtime type.

      Default: multi-thread

      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • dataFusionRuntimeType

      InfluxDBv3EnterpriseParameters.Builder dataFusionRuntimeType(DataFusionRuntimeType dataFusionRuntimeType)

      Specifies the DataFusion tokio runtime type.

      Default: multi-thread

      Parameters:
      dataFusionRuntimeType - Specifies the DataFusion tokio runtime type.

      Default: multi-thread

      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • dataFusionRuntimeDisableLifoSlot

      InfluxDBv3EnterpriseParameters.Builder dataFusionRuntimeDisableLifoSlot(Boolean dataFusionRuntimeDisableLifoSlot)

      Disables the LIFO slot of the DataFusion runtime.

      Parameters:
      dataFusionRuntimeDisableLifoSlot - Disables the LIFO slot of the DataFusion runtime.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • dataFusionRuntimeEventInterval

      InfluxDBv3EnterpriseParameters.Builder dataFusionRuntimeEventInterval(Integer dataFusionRuntimeEventInterval)

      Sets the number of scheduler ticks after which the scheduler of the DataFusion tokio runtime polls for external events–for example: timers, I/O.

      Parameters:
      dataFusionRuntimeEventInterval - Sets the number of scheduler ticks after which the scheduler of the DataFusion tokio runtime polls for external events–for example: timers, I/O.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • dataFusionRuntimeGlobalQueueInterval

      InfluxDBv3EnterpriseParameters.Builder dataFusionRuntimeGlobalQueueInterval(Integer dataFusionRuntimeGlobalQueueInterval)

      Sets the number of scheduler ticks after which the scheduler of the DataFusion runtime polls the global task queue.

      Parameters:
      dataFusionRuntimeGlobalQueueInterval - Sets the number of scheduler ticks after which the scheduler of the DataFusion runtime polls the global task queue.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • dataFusionRuntimeMaxBlockingThreads

      InfluxDBv3EnterpriseParameters.Builder dataFusionRuntimeMaxBlockingThreads(Integer dataFusionRuntimeMaxBlockingThreads)

      Specifies the limit for additional threads spawned by the DataFusion runtime.

      Parameters:
      dataFusionRuntimeMaxBlockingThreads - Specifies the limit for additional threads spawned by the DataFusion runtime.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • dataFusionRuntimeMaxIoEventsPerTick

      InfluxDBv3EnterpriseParameters.Builder dataFusionRuntimeMaxIoEventsPerTick(Integer dataFusionRuntimeMaxIoEventsPerTick)

      Configures the maximum number of events processed per tick by the tokio DataFusion runtime.

      Parameters:
      dataFusionRuntimeMaxIoEventsPerTick - Configures the maximum number of events processed per tick by the tokio DataFusion runtime.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • dataFusionRuntimeThreadKeepAlive

      InfluxDBv3EnterpriseParameters.Builder dataFusionRuntimeThreadKeepAlive(Duration dataFusionRuntimeThreadKeepAlive)

      Sets a custom timeout for a thread in the blocking pool of the tokio DataFusion runtime.

      Parameters:
      dataFusionRuntimeThreadKeepAlive - Sets a custom timeout for a thread in the blocking pool of the tokio DataFusion runtime.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • dataFusionRuntimeThreadKeepAlive

      default InfluxDBv3EnterpriseParameters.Builder dataFusionRuntimeThreadKeepAlive(Consumer<Duration.Builder> dataFusionRuntimeThreadKeepAlive)

      Sets a custom timeout for a thread in the blocking pool of the tokio DataFusion runtime.

      This is a convenience method that creates an instance of the Duration.Builder avoiding the need to create one manually via Duration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to dataFusionRuntimeThreadKeepAlive(Duration).

      Parameters:
      dataFusionRuntimeThreadKeepAlive - a consumer that will call methods on Duration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • dataFusionRuntimeThreadPriority

      InfluxDBv3EnterpriseParameters.Builder dataFusionRuntimeThreadPriority(Integer dataFusionRuntimeThreadPriority)

      Sets the thread priority for tokio DataFusion runtime workers.

      Default: 10

      Parameters:
      dataFusionRuntimeThreadPriority - Sets the thread priority for tokio DataFusion runtime workers.

      Default: 10

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • dataFusionMaxParquetFanout

      InfluxDBv3EnterpriseParameters.Builder dataFusionMaxParquetFanout(Integer dataFusionMaxParquetFanout)

      When multiple parquet files are required in a sorted way (deduplication for example), specifies the maximum fanout.

      Default: 1000

      Parameters:
      dataFusionMaxParquetFanout - When multiple parquet files are required in a sorted way (deduplication for example), specifies the maximum fanout.

      Default: 1000

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • dataFusionUseCachedParquetLoader

      InfluxDBv3EnterpriseParameters.Builder dataFusionUseCachedParquetLoader(Boolean dataFusionUseCachedParquetLoader)

      Uses a cached parquet loader when reading parquet files from the object store.

      Parameters:
      dataFusionUseCachedParquetLoader - Uses a cached parquet loader when reading parquet files from the object store.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • dataFusionConfig

      InfluxDBv3EnterpriseParameters.Builder dataFusionConfig(String dataFusionConfig)

      Provides custom configuration to DataFusion as a comma-separated list of key:value pairs.

      Parameters:
      dataFusionConfig - Provides custom configuration to DataFusion as a comma-separated list of key:value pairs.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • maxHttpRequestSize

      InfluxDBv3EnterpriseParameters.Builder maxHttpRequestSize(Long maxHttpRequestSize)

      Specifies the maximum size of HTTP requests.

      Default: 10485760

      Parameters:
      maxHttpRequestSize - Specifies the maximum size of HTTP requests.

      Default: 10485760

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • forceSnapshotMemThreshold

      InfluxDBv3EnterpriseParameters.Builder forceSnapshotMemThreshold(PercentOrAbsoluteLong forceSnapshotMemThreshold)

      Specifies the threshold for the internal memory buffer. Supports either a percentage (portion of available memory) or absolute value in MB–for example: 70% or 100

      Default: 70%

      Parameters:
      forceSnapshotMemThreshold - Specifies the threshold for the internal memory buffer. Supports either a percentage (portion of available memory) or absolute value in MB–for example: 70% or 100

      Default: 70%

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • forceSnapshotMemThreshold

      default InfluxDBv3EnterpriseParameters.Builder forceSnapshotMemThreshold(Consumer<PercentOrAbsoluteLong.Builder> forceSnapshotMemThreshold)

      Specifies the threshold for the internal memory buffer. Supports either a percentage (portion of available memory) or absolute value in MB–for example: 70% or 100

      Default: 70%

      This is a convenience method that creates an instance of the PercentOrAbsoluteLong.Builder avoiding the need to create one manually via PercentOrAbsoluteLong.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to forceSnapshotMemThreshold(PercentOrAbsoluteLong).

      Parameters:
      forceSnapshotMemThreshold - a consumer that will call methods on PercentOrAbsoluteLong.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • walSnapshotSize

      InfluxDBv3EnterpriseParameters.Builder walSnapshotSize(Integer walSnapshotSize)

      Defines the number of WAL files to attempt to remove in a snapshot. This, multiplied by the interval, determines how often snapshots are taken.

      Default: 600

      Parameters:
      walSnapshotSize - Defines the number of WAL files to attempt to remove in a snapshot. This, multiplied by the interval, determines how often snapshots are taken.

      Default: 600

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • walMaxWriteBufferSize

      InfluxDBv3EnterpriseParameters.Builder walMaxWriteBufferSize(Integer walMaxWriteBufferSize)

      Specifies the maximum number of write requests that can be buffered before a flush must be executed and succeed.

      Default: 100000

      Parameters:
      walMaxWriteBufferSize - Specifies the maximum number of write requests that can be buffered before a flush must be executed and succeed.

      Default: 100000

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • snapshottedWalFilesToKeep

      InfluxDBv3EnterpriseParameters.Builder snapshottedWalFilesToKeep(Integer snapshottedWalFilesToKeep)

      Specifies the number of snapshotted WAL files to retain in the object store. Flushing the WAL files does not clear the WAL files immediately; they are deleted when the number of snapshotted WAL files exceeds this number.

      Default: 300

      Parameters:
      snapshottedWalFilesToKeep - Specifies the number of snapshotted WAL files to retain in the object store. Flushing the WAL files does not clear the WAL files immediately; they are deleted when the number of snapshotted WAL files exceeds this number.

      Default: 300

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • preemptiveCacheAge

      InfluxDBv3EnterpriseParameters.Builder preemptiveCacheAge(Duration preemptiveCacheAge)

      Specifies the interval to prefetch into the Parquet cache during compaction.

      Default: 3d

      Parameters:
      preemptiveCacheAge - Specifies the interval to prefetch into the Parquet cache during compaction.

      Default: 3d

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • preemptiveCacheAge

      default InfluxDBv3EnterpriseParameters.Builder preemptiveCacheAge(Consumer<Duration.Builder> preemptiveCacheAge)

      Specifies the interval to prefetch into the Parquet cache during compaction.

      Default: 3d

      This is a convenience method that creates an instance of the Duration.Builder avoiding the need to create one manually via Duration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to preemptiveCacheAge(Duration).

      Parameters:
      preemptiveCacheAge - a consumer that will call methods on Duration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • parquetMemCachePrunePercentage

      InfluxDBv3EnterpriseParameters.Builder parquetMemCachePrunePercentage(Float parquetMemCachePrunePercentage)

      Specifies the percentage of entries to prune during a prune operation on the in-memory Parquet cache.

      Default: 0.1

      Parameters:
      parquetMemCachePrunePercentage - Specifies the percentage of entries to prune during a prune operation on the in-memory Parquet cache.

      Default: 0.1

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • parquetMemCachePruneInterval

      InfluxDBv3EnterpriseParameters.Builder parquetMemCachePruneInterval(Duration parquetMemCachePruneInterval)

      Sets the interval to check if the in-memory Parquet cache needs to be pruned.

      Default: 1s

      Parameters:
      parquetMemCachePruneInterval - Sets the interval to check if the in-memory Parquet cache needs to be pruned.

      Default: 1s

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • parquetMemCachePruneInterval

      default InfluxDBv3EnterpriseParameters.Builder parquetMemCachePruneInterval(Consumer<Duration.Builder> parquetMemCachePruneInterval)

      Sets the interval to check if the in-memory Parquet cache needs to be pruned.

      Default: 1s

      This is a convenience method that creates an instance of the Duration.Builder avoiding the need to create one manually via Duration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to parquetMemCachePruneInterval(Duration).

      Parameters:
      parquetMemCachePruneInterval - a consumer that will call methods on Duration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • disableParquetMemCache

      InfluxDBv3EnterpriseParameters.Builder disableParquetMemCache(Boolean disableParquetMemCache)

      Disables the in-memory Parquet cache. By default, the cache is enabled.

      Parameters:
      disableParquetMemCache - Disables the in-memory Parquet cache. By default, the cache is enabled.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • parquetMemCacheQueryPathDuration

      InfluxDBv3EnterpriseParameters.Builder parquetMemCacheQueryPathDuration(Duration parquetMemCacheQueryPathDuration)

      Specifies the time window for caching recent Parquet files in memory.

      Default: 5h

      Parameters:
      parquetMemCacheQueryPathDuration - Specifies the time window for caching recent Parquet files in memory.

      Default: 5h

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • parquetMemCacheQueryPathDuration

      default InfluxDBv3EnterpriseParameters.Builder parquetMemCacheQueryPathDuration(Consumer<Duration.Builder> parquetMemCacheQueryPathDuration)

      Specifies the time window for caching recent Parquet files in memory.

      Default: 5h

      This is a convenience method that creates an instance of the Duration.Builder avoiding the need to create one manually via Duration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to parquetMemCacheQueryPathDuration(Duration).

      Parameters:
      parquetMemCacheQueryPathDuration - a consumer that will call methods on Duration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • lastCacheEvictionInterval

      InfluxDBv3EnterpriseParameters.Builder lastCacheEvictionInterval(Duration lastCacheEvictionInterval)

      Specifies the interval to evict expired entries from the Last-N-Value cache, expressed as a human-readable duration–for example: 20s, 1m, 1h.

      Default: 10s

      Parameters:
      lastCacheEvictionInterval - Specifies the interval to evict expired entries from the Last-N-Value cache, expressed as a human-readable duration–for example: 20s, 1m, 1h.

      Default: 10s

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • lastCacheEvictionInterval

      default InfluxDBv3EnterpriseParameters.Builder lastCacheEvictionInterval(Consumer<Duration.Builder> lastCacheEvictionInterval)

      Specifies the interval to evict expired entries from the Last-N-Value cache, expressed as a human-readable duration–for example: 20s, 1m, 1h.

      Default: 10s

      This is a convenience method that creates an instance of the Duration.Builder avoiding the need to create one manually via Duration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to lastCacheEvictionInterval(Duration).

      Parameters:
      lastCacheEvictionInterval - a consumer that will call methods on Duration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • distinctCacheEvictionInterval

      InfluxDBv3EnterpriseParameters.Builder distinctCacheEvictionInterval(Duration distinctCacheEvictionInterval)

      Specifies the interval to evict expired entries from the distinct value cache, expressed as a human-readable duration–for example: 20s, 1m, 1h.

      Default: 10s

      Parameters:
      distinctCacheEvictionInterval - Specifies the interval to evict expired entries from the distinct value cache, expressed as a human-readable duration–for example: 20s, 1m, 1h.

      Default: 10s

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • distinctCacheEvictionInterval

      default InfluxDBv3EnterpriseParameters.Builder distinctCacheEvictionInterval(Consumer<Duration.Builder> distinctCacheEvictionInterval)

      Specifies the interval to evict expired entries from the distinct value cache, expressed as a human-readable duration–for example: 20s, 1m, 1h.

      Default: 10s

      This is a convenience method that creates an instance of the Duration.Builder avoiding the need to create one manually via Duration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to distinctCacheEvictionInterval(Duration).

      Parameters:
      distinctCacheEvictionInterval - a consumer that will call methods on Duration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • gen1Duration

      InfluxDBv3EnterpriseParameters.Builder gen1Duration(Duration gen1Duration)

      Specifies the duration that Parquet files are arranged into. Data timestamps land each row into a file of this duration. Supported durations are 1m, 5m, and 10m. These files are known as “generation 1” files, which the compactor can merge into larger generations.

      Default: 10m

      Parameters:
      gen1Duration - Specifies the duration that Parquet files are arranged into. Data timestamps land each row into a file of this duration. Supported durations are 1m, 5m, and 10m. These files are known as “generation 1” files, which the compactor can merge into larger generations.

      Default: 10m

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • gen1Duration

      default InfluxDBv3EnterpriseParameters.Builder gen1Duration(Consumer<Duration.Builder> gen1Duration)

      Specifies the duration that Parquet files are arranged into. Data timestamps land each row into a file of this duration. Supported durations are 1m, 5m, and 10m. These files are known as “generation 1” files, which the compactor can merge into larger generations.

      Default: 10m

      This is a convenience method that creates an instance of the Duration.Builder avoiding the need to create one manually via Duration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to gen1Duration(Duration).

      Parameters:
      gen1Duration - a consumer that will call methods on Duration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • execMemPoolBytes

      InfluxDBv3EnterpriseParameters.Builder execMemPoolBytes(PercentOrAbsoluteLong execMemPoolBytes)

      Specifies the size of memory pool used during query execution. Can be given as absolute value in bytes or as a percentage of the total available memory–for example: 8000000000 or 10%.

      Default: 20%

      Parameters:
      execMemPoolBytes - Specifies the size of memory pool used during query execution. Can be given as absolute value in bytes or as a percentage of the total available memory–for example: 8000000000 or 10%.

      Default: 20%

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • execMemPoolBytes

      default InfluxDBv3EnterpriseParameters.Builder execMemPoolBytes(Consumer<PercentOrAbsoluteLong.Builder> execMemPoolBytes)

      Specifies the size of memory pool used during query execution. Can be given as absolute value in bytes or as a percentage of the total available memory–for example: 8000000000 or 10%.

      Default: 20%

      This is a convenience method that creates an instance of the PercentOrAbsoluteLong.Builder avoiding the need to create one manually via PercentOrAbsoluteLong.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to execMemPoolBytes(PercentOrAbsoluteLong).

      Parameters:
      execMemPoolBytes - a consumer that will call methods on PercentOrAbsoluteLong.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • parquetMemCacheSize

      InfluxDBv3EnterpriseParameters.Builder parquetMemCacheSize(PercentOrAbsoluteLong parquetMemCacheSize)

      Specifies the size of the in-memory Parquet cache in megabytes or percentage of total available memory.

      Default: 20%

      Parameters:
      parquetMemCacheSize - Specifies the size of the in-memory Parquet cache in megabytes or percentage of total available memory.

      Default: 20%

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • parquetMemCacheSize

      default InfluxDBv3EnterpriseParameters.Builder parquetMemCacheSize(Consumer<PercentOrAbsoluteLong.Builder> parquetMemCacheSize)

      Specifies the size of the in-memory Parquet cache in megabytes or percentage of total available memory.

      Default: 20%

      This is a convenience method that creates an instance of the PercentOrAbsoluteLong.Builder avoiding the need to create one manually via PercentOrAbsoluteLong.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to parquetMemCacheSize(PercentOrAbsoluteLong).

      Parameters:
      parquetMemCacheSize - a consumer that will call methods on PercentOrAbsoluteLong.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • walReplayFailOnError

      InfluxDBv3EnterpriseParameters.Builder walReplayFailOnError(Boolean walReplayFailOnError)

      Determines whether WAL replay should fail when encountering errors.

      Default: false

      Parameters:
      walReplayFailOnError - Determines whether WAL replay should fail when encountering errors.

      Default: false

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • walReplayConcurrencyLimit

      InfluxDBv3EnterpriseParameters.Builder walReplayConcurrencyLimit(Integer walReplayConcurrencyLimit)

      Concurrency limit during WAL replay. Setting this number too high can lead to OOM. The default is dynamically determined.

      Default: max(num_cpus, 10)

      Parameters:
      walReplayConcurrencyLimit - Concurrency limit during WAL replay. Setting this number too high can lead to OOM. The default is dynamically determined.

      Default: max(num_cpus, 10)

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • tableIndexCacheMaxEntries

      InfluxDBv3EnterpriseParameters.Builder tableIndexCacheMaxEntries(Integer tableIndexCacheMaxEntries)

      Specifies the maximum number of entries in the table index cache.

      Default: 1000

      Parameters:
      tableIndexCacheMaxEntries - Specifies the maximum number of entries in the table index cache.

      Default: 1000

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • tableIndexCacheConcurrencyLimit

      InfluxDBv3EnterpriseParameters.Builder tableIndexCacheConcurrencyLimit(Integer tableIndexCacheConcurrencyLimit)

      Limits the concurrency level for table index cache operations.

      Default: 8

      Parameters:
      tableIndexCacheConcurrencyLimit - Limits the concurrency level for table index cache operations.

      Default: 8

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • gen1LookbackDuration

      InfluxDBv3EnterpriseParameters.Builder gen1LookbackDuration(Duration gen1LookbackDuration)

      Specifies how far back to look when creating generation 1 Parquet files.

      Default: 24h

      Parameters:
      gen1LookbackDuration - Specifies how far back to look when creating generation 1 Parquet files.

      Default: 24h

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • gen1LookbackDuration

      default InfluxDBv3EnterpriseParameters.Builder gen1LookbackDuration(Consumer<Duration.Builder> gen1LookbackDuration)

      Specifies how far back to look when creating generation 1 Parquet files.

      Default: 24h

      This is a convenience method that creates an instance of the Duration.Builder avoiding the need to create one manually via Duration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to gen1LookbackDuration(Duration).

      Parameters:
      gen1LookbackDuration - a consumer that will call methods on Duration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • retentionCheckInterval

      InfluxDBv3EnterpriseParameters.Builder retentionCheckInterval(Duration retentionCheckInterval)

      The interval at which retention policies are checked and enforced. Enter as a human-readable time–for example: 30m or 1h.

      Default: 30m

      Parameters:
      retentionCheckInterval - The interval at which retention policies are checked and enforced. Enter as a human-readable time–for example: 30m or 1h.

      Default: 30m

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • retentionCheckInterval

      default InfluxDBv3EnterpriseParameters.Builder retentionCheckInterval(Consumer<Duration.Builder> retentionCheckInterval)

      The interval at which retention policies are checked and enforced. Enter as a human-readable time–for example: 30m or 1h.

      Default: 30m

      This is a convenience method that creates an instance of the Duration.Builder avoiding the need to create one manually via Duration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to retentionCheckInterval(Duration).

      Parameters:
      retentionCheckInterval - a consumer that will call methods on Duration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • deleteGracePeriod

      InfluxDBv3EnterpriseParameters.Builder deleteGracePeriod(Duration deleteGracePeriod)

      Specifies the grace period before permanently deleting data.

      Default: 24h

      Parameters:
      deleteGracePeriod - Specifies the grace period before permanently deleting data.

      Default: 24h

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • deleteGracePeriod

      default InfluxDBv3EnterpriseParameters.Builder deleteGracePeriod(Consumer<Duration.Builder> deleteGracePeriod)

      Specifies the grace period before permanently deleting data.

      Default: 24h

      This is a convenience method that creates an instance of the Duration.Builder avoiding the need to create one manually via Duration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to deleteGracePeriod(Duration).

      Parameters:
      deleteGracePeriod - a consumer that will call methods on Duration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • hardDeleteDefaultDuration

      InfluxDBv3EnterpriseParameters.Builder hardDeleteDefaultDuration(Duration hardDeleteDefaultDuration)

      Sets the default duration for hard deletion of data.

      Default: 90d

      Parameters:
      hardDeleteDefaultDuration - Sets the default duration for hard deletion of data.

      Default: 90d

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • hardDeleteDefaultDuration

      default InfluxDBv3EnterpriseParameters.Builder hardDeleteDefaultDuration(Consumer<Duration.Builder> hardDeleteDefaultDuration)

      Sets the default duration for hard deletion of data.

      Default: 90d

      This is a convenience method that creates an instance of the Duration.Builder avoiding the need to create one manually via Duration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to hardDeleteDefaultDuration(Duration).

      Parameters:
      hardDeleteDefaultDuration - a consumer that will call methods on Duration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • ingestQueryInstances

      InfluxDBv3EnterpriseParameters.Builder ingestQueryInstances(Integer ingestQueryInstances)

      Specifies number of instances in the DbCluster which can both ingest and query.

      Parameters:
      ingestQueryInstances - Specifies number of instances in the DbCluster which can both ingest and query.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • queryOnlyInstances

      InfluxDBv3EnterpriseParameters.Builder queryOnlyInstances(Integer queryOnlyInstances)

      Specifies number of instances in the DbCluster which can only query.

      Parameters:
      queryOnlyInstances - Specifies number of instances in the DbCluster which can only query.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • dedicatedCompactor

      InfluxDBv3EnterpriseParameters.Builder dedicatedCompactor(Boolean dedicatedCompactor)

      Specifies if the compactor instance should be a standalone instance or not.

      Parameters:
      dedicatedCompactor - Specifies if the compactor instance should be a standalone instance or not.
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • compactionRowLimit

      InfluxDBv3EnterpriseParameters.Builder compactionRowLimit(Integer compactionRowLimit)

      Specifies the soft limit for the number of rows per file that the compactor writes. The compactor may write more rows than this limit.

      Default: 1000000

      Parameters:
      compactionRowLimit - Specifies the soft limit for the number of rows per file that the compactor writes. The compactor may write more rows than this limit.

      Default: 1000000

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • compactionMaxNumFilesPerPlan

      InfluxDBv3EnterpriseParameters.Builder compactionMaxNumFilesPerPlan(Integer compactionMaxNumFilesPerPlan)

      Sets the maximum number of files included in any compaction plan.

      Default: 500

      Parameters:
      compactionMaxNumFilesPerPlan - Sets the maximum number of files included in any compaction plan.

      Default: 500

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • compactionGen2Duration

      InfluxDBv3EnterpriseParameters.Builder compactionGen2Duration(Duration compactionGen2Duration)

      Specifies the duration of the first level of compaction (gen2). Later levels of compaction are multiples of this duration. This value should be equal to or greater than the gen1 duration.

      Default: 20m

      Parameters:
      compactionGen2Duration - Specifies the duration of the first level of compaction (gen2). Later levels of compaction are multiples of this duration. This value should be equal to or greater than the gen1 duration.

      Default: 20m

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • compactionGen2Duration

      default InfluxDBv3EnterpriseParameters.Builder compactionGen2Duration(Consumer<Duration.Builder> compactionGen2Duration)

      Specifies the duration of the first level of compaction (gen2). Later levels of compaction are multiples of this duration. This value should be equal to or greater than the gen1 duration.

      Default: 20m

      This is a convenience method that creates an instance of the Duration.Builder avoiding the need to create one manually via Duration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to compactionGen2Duration(Duration).

      Parameters:
      compactionGen2Duration - a consumer that will call methods on Duration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • compactionMultipliers

      InfluxDBv3EnterpriseParameters.Builder compactionMultipliers(String compactionMultipliers)

      Specifies a comma-separated list of multiples defining the duration of each level of compaction. The number of elements in the list determines the number of compaction levels. The first element specifies the duration of the first level (gen3); subsequent levels are multiples of the previous level.

      Default: 3,4,6,5

      Parameters:
      compactionMultipliers - Specifies a comma-separated list of multiples defining the duration of each level of compaction. The number of elements in the list determines the number of compaction levels. The first element specifies the duration of the first level (gen3); subsequent levels are multiples of the previous level.

      Default: 3,4,6,5

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • compactionCleanupWait

      InfluxDBv3EnterpriseParameters.Builder compactionCleanupWait(Duration compactionCleanupWait)

      Specifies the amount of time that the compactor waits after finishing a compaction run to delete files marked as needing deletion during that compaction run.

      Default: 10m

      Parameters:
      compactionCleanupWait - Specifies the amount of time that the compactor waits after finishing a compaction run to delete files marked as needing deletion during that compaction run.

      Default: 10m

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • compactionCleanupWait

      default InfluxDBv3EnterpriseParameters.Builder compactionCleanupWait(Consumer<Duration.Builder> compactionCleanupWait)

      Specifies the amount of time that the compactor waits after finishing a compaction run to delete files marked as needing deletion during that compaction run.

      Default: 10m

      This is a convenience method that creates an instance of the Duration.Builder avoiding the need to create one manually via Duration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to compactionCleanupWait(Duration).

      Parameters:
      compactionCleanupWait - a consumer that will call methods on Duration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • compactionCheckInterval

      InfluxDBv3EnterpriseParameters.Builder compactionCheckInterval(Duration compactionCheckInterval)

      Specifies how often the compactor checks for new compaction work to perform.

      Default: 10s

      Parameters:
      compactionCheckInterval - Specifies how often the compactor checks for new compaction work to perform.

      Default: 10s

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • compactionCheckInterval

      default InfluxDBv3EnterpriseParameters.Builder compactionCheckInterval(Consumer<Duration.Builder> compactionCheckInterval)

      Specifies how often the compactor checks for new compaction work to perform.

      Default: 10s

      This is a convenience method that creates an instance of the Duration.Builder avoiding the need to create one manually via Duration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to compactionCheckInterval(Duration).

      Parameters:
      compactionCheckInterval - a consumer that will call methods on Duration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • lastValueCacheDisableFromHistory

      InfluxDBv3EnterpriseParameters.Builder lastValueCacheDisableFromHistory(Boolean lastValueCacheDisableFromHistory)

      Disables populating the last-N-value cache from historical data. If disabled, the cache is still populated with data from the write-ahead log (WAL).

      Parameters:
      lastValueCacheDisableFromHistory - Disables populating the last-N-value cache from historical data. If disabled, the cache is still populated with data from the write-ahead log (WAL).
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • distinctValueCacheDisableFromHistory

      InfluxDBv3EnterpriseParameters.Builder distinctValueCacheDisableFromHistory(Boolean distinctValueCacheDisableFromHistory)

      Disables populating the distinct value cache from historical data. If disabled, the cache is still populated with data from the write-ahead log (WAL).

      Parameters:
      distinctValueCacheDisableFromHistory - Disables populating the distinct value cache from historical data. If disabled, the cache is still populated with data from the write-ahead log (WAL).
      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • replicationInterval

      InfluxDBv3EnterpriseParameters.Builder replicationInterval(Duration replicationInterval)

      Specifies the interval at which data replication occurs between cluster nodes.

      Default: 250ms

      Parameters:
      replicationInterval - Specifies the interval at which data replication occurs between cluster nodes.

      Default: 250ms

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • replicationInterval

      default InfluxDBv3EnterpriseParameters.Builder replicationInterval(Consumer<Duration.Builder> replicationInterval)

      Specifies the interval at which data replication occurs between cluster nodes.

      Default: 250ms

      This is a convenience method that creates an instance of the Duration.Builder avoiding the need to create one manually via Duration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to replicationInterval(Duration).

      Parameters:
      replicationInterval - a consumer that will call methods on Duration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also:

    • catalogSyncInterval

      InfluxDBv3EnterpriseParameters.Builder catalogSyncInterval(Duration catalogSyncInterval)

      Defines how often the catalog synchronizes across cluster nodes.

      Default: 10s

      Parameters:
      catalogSyncInterval - Defines how often the catalog synchronizes across cluster nodes.

      Default: 10s

      Returns:
      Returns a reference to this object so that method calls can be chained together.

    • catalogSyncInterval

      default InfluxDBv3EnterpriseParameters.Builder catalogSyncInterval(Consumer<Duration.Builder> catalogSyncInterval)

      Defines how often the catalog synchronizes across cluster nodes.

      Default: 10s

      This is a convenience method that creates an instance of the Duration.Builder avoiding the need to create one manually via Duration.builder().

      When the Consumer completes, SdkBuilder.build() is called immediately and its result is passed to catalogSyncInterval(Duration).

      Parameters:
      catalogSyncInterval - a consumer that will call methods on Duration.Builder
      Returns:
      Returns a reference to this object so that method calls can be chained together.
      See Also: