Interface InfluxDBv3CoreParameters.Builder

  • Method Details

    • queryFileLimit

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      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

      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

      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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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 InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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 InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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 InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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 InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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 InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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 InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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 InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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 that the compactor in InfluxDB 3 Enterprise 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 that the compactor in InfluxDB 3 Enterprise can merge into larger generations.

      Default: 10m

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

      default InfluxDBv3CoreParameters.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 that the compactor in InfluxDB 3 Enterprise 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

      InfluxDBv3CoreParameters.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 InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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 InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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 InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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 InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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 InfluxDBv3CoreParameters.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

      InfluxDBv3CoreParameters.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 InfluxDBv3CoreParameters.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: