Interface InfluxDBv3CoreParameters.Builder
- All Superinterfaces:
Buildable
,CopyableBuilder<InfluxDBv3CoreParameters.Builder,
,InfluxDBv3CoreParameters> SdkBuilder<InfluxDBv3CoreParameters.Builder,
,InfluxDBv3CoreParameters> SdkPojo
- Enclosing class:
InfluxDBv3CoreParameters
-
Method Summary
Modifier and TypeMethodDescriptiondataFusionConfig
(String dataFusionConfig) Provides custom configuration to DataFusion as a comma-separated list of key:value pairs.dataFusionMaxParquetFanout
(Integer dataFusionMaxParquetFanout) When multiple parquet files are required in a sorted way (deduplication for example), specifies the maximum fanout.dataFusionNumThreads
(Integer dataFusionNumThreads) Sets the maximum number of DataFusion runtime threads to use.dataFusionRuntimeDisableLifoSlot
(Boolean dataFusionRuntimeDisableLifoSlot) Disables the LIFO slot of the DataFusion runtime.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.dataFusionRuntimeGlobalQueueInterval
(Integer dataFusionRuntimeGlobalQueueInterval) Sets the number of scheduler ticks after which the scheduler of the DataFusion runtime polls the global task queue.dataFusionRuntimeMaxBlockingThreads
(Integer dataFusionRuntimeMaxBlockingThreads) Specifies the limit for additional threads spawned by the DataFusion runtime.dataFusionRuntimeMaxIoEventsPerTick
(Integer dataFusionRuntimeMaxIoEventsPerTick) Configures the maximum number of events processed per tick by the tokio DataFusion runtime.default InfluxDBv3CoreParameters.Builder
dataFusionRuntimeThreadKeepAlive
(Consumer<Duration.Builder> dataFusionRuntimeThreadKeepAlive) Sets a custom timeout for a thread in the blocking pool of the tokio DataFusion runtime.dataFusionRuntimeThreadKeepAlive
(Duration dataFusionRuntimeThreadKeepAlive) Sets a custom timeout for a thread in the blocking pool of the tokio DataFusion runtime.dataFusionRuntimeThreadPriority
(Integer dataFusionRuntimeThreadPriority) Sets the thread priority for tokio DataFusion runtime workers.dataFusionRuntimeType
(String dataFusionRuntimeType) Specifies the DataFusion tokio runtime type.dataFusionRuntimeType
(DataFusionRuntimeType dataFusionRuntimeType) Specifies the DataFusion tokio runtime type.dataFusionUseCachedParquetLoader
(Boolean dataFusionUseCachedParquetLoader) Uses a cached parquet loader when reading parquet files from the object store.default InfluxDBv3CoreParameters.Builder
deleteGracePeriod
(Consumer<Duration.Builder> deleteGracePeriod) Specifies the grace period before permanently deleting data.deleteGracePeriod
(Duration deleteGracePeriod) Specifies the grace period before permanently deleting data.disableParquetMemCache
(Boolean disableParquetMemCache) Disables the in-memory Parquet cache.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.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 InfluxDBv3CoreParameters.Builder
execMemPoolBytes
(Consumer<PercentOrAbsoluteLong.Builder> execMemPoolBytes) Specifies the size of memory pool used during query execution.execMemPoolBytes
(PercentOrAbsoluteLong execMemPoolBytes) Specifies the size of memory pool used during query execution.default InfluxDBv3CoreParameters.Builder
forceSnapshotMemThreshold
(Consumer<PercentOrAbsoluteLong.Builder> forceSnapshotMemThreshold) Specifies the threshold for the internal memory buffer.forceSnapshotMemThreshold
(PercentOrAbsoluteLong forceSnapshotMemThreshold) Specifies the threshold for the internal memory buffer.default InfluxDBv3CoreParameters.Builder
gen1Duration
(Consumer<Duration.Builder> gen1Duration) Specifies the duration that Parquet files are arranged into.gen1Duration
(Duration gen1Duration) Specifies the duration that Parquet files are arranged into.default InfluxDBv3CoreParameters.Builder
gen1LookbackDuration
(Consumer<Duration.Builder> gen1LookbackDuration) Specifies how far back to look when creating generation 1 Parquet files.gen1LookbackDuration
(Duration gen1LookbackDuration) Specifies how far back to look when creating generation 1 Parquet files.default InfluxDBv3CoreParameters.Builder
hardDeleteDefaultDuration
(Consumer<Duration.Builder> hardDeleteDefaultDuration) Sets the default duration for hard deletion of data.hardDeleteDefaultDuration
(Duration hardDeleteDefaultDuration) Sets the default duration for hard deletion of data.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.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.Sets the filter directive for logs.Defines the message format for logs.logFormat
(LogFormats logFormat) Defines the message format for logs.maxHttpRequestSize
(Long maxHttpRequestSize) Specifies the maximum size of HTTP requests.default InfluxDBv3CoreParameters.Builder
parquetMemCachePruneInterval
(Consumer<Duration.Builder> parquetMemCachePruneInterval) Sets the interval to check if the in-memory Parquet cache needs to be pruned.parquetMemCachePruneInterval
(Duration parquetMemCachePruneInterval) Sets the interval to check if the in-memory Parquet cache needs to be pruned.parquetMemCachePrunePercentage
(Float parquetMemCachePrunePercentage) Specifies the percentage of entries to prune during a prune operation on the in-memory Parquet cache.default InfluxDBv3CoreParameters.Builder
parquetMemCacheQueryPathDuration
(Consumer<Duration.Builder> parquetMemCacheQueryPathDuration) Specifies the time window for caching recent Parquet files in memory.parquetMemCacheQueryPathDuration
(Duration parquetMemCacheQueryPathDuration) Specifies the time window for caching recent Parquet files in memory.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.parquetMemCacheSize
(PercentOrAbsoluteLong parquetMemCacheSize) Specifies the size of the in-memory Parquet cache in megabytes or percentage of total available memory.default InfluxDBv3CoreParameters.Builder
preemptiveCacheAge
(Consumer<Duration.Builder> preemptiveCacheAge) Specifies the interval to prefetch into the Parquet cache during compaction.preemptiveCacheAge
(Duration preemptiveCacheAge) Specifies the interval to prefetch into the Parquet cache during compaction.queryFileLimit
(Integer queryFileLimit) Limits the number of Parquet files a query can access.queryLogSize
(Integer queryLogSize) Defines the size of the query log.default InfluxDBv3CoreParameters.Builder
retentionCheckInterval
(Consumer<Duration.Builder> retentionCheckInterval) The interval at which retention policies are checked and enforced.retentionCheckInterval
(Duration retentionCheckInterval) The interval at which retention policies are checked and enforced.snapshottedWalFilesToKeep
(Integer snapshottedWalFilesToKeep) Specifies the number of snapshotted WAL files to retain in the object store.tableIndexCacheConcurrencyLimit
(Integer tableIndexCacheConcurrencyLimit) Limits the concurrency level for table index cache operations.tableIndexCacheMaxEntries
(Integer tableIndexCacheMaxEntries) Specifies the maximum number of entries in the table index cache.walMaxWriteBufferSize
(Integer walMaxWriteBufferSize) Specifies the maximum number of write requests that can be buffered before a flush must be executed and succeed.walReplayConcurrencyLimit
(Integer walReplayConcurrencyLimit) Concurrency limit during WAL replay.walReplayFailOnError
(Boolean walReplayFailOnError) Determines whether WAL replay should fail when encountering errors.walSnapshotSize
(Integer walSnapshotSize) Defines the number of WAL files to attempt to remove in a snapshot.Methods inherited from interface software.amazon.awssdk.utils.builder.CopyableBuilder
copy
Methods inherited from interface software.amazon.awssdk.utils.builder.SdkBuilder
applyMutation, build
Methods inherited from interface software.amazon.awssdk.core.SdkPojo
equalsBySdkFields, sdkFieldNameToField, sdkFields
-
Method Details
-
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
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
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
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
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 theDuration.Builder
avoiding the need to create one manually viaDuration.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed todataFusionRuntimeThreadKeepAlive(Duration)
.- Parameters:
dataFusionRuntimeThreadKeepAlive
- a consumer that will call methods onDuration.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
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
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
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 100Default: 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 thePercentOrAbsoluteLong.Builder
avoiding the need to create one manually viaPercentOrAbsoluteLong.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed toforceSnapshotMemThreshold(PercentOrAbsoluteLong)
.- Parameters:
forceSnapshotMemThreshold
- a consumer that will call methods onPercentOrAbsoluteLong.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
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
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
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
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 theDuration.Builder
avoiding the need to create one manually viaDuration.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed topreemptiveCacheAge(Duration)
.- Parameters:
preemptiveCacheAge
- a consumer that will call methods onDuration.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 theDuration.Builder
avoiding the need to create one manually viaDuration.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed toparquetMemCachePruneInterval(Duration)
.- Parameters:
parquetMemCachePruneInterval
- a consumer that will call methods onDuration.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
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 theDuration.Builder
avoiding the need to create one manually viaDuration.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed toparquetMemCacheQueryPathDuration(Duration)
.- Parameters:
parquetMemCacheQueryPathDuration
- a consumer that will call methods onDuration.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
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 theDuration.Builder
avoiding the need to create one manually viaDuration.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed tolastCacheEvictionInterval(Duration)
.- Parameters:
lastCacheEvictionInterval
- a consumer that will call methods onDuration.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 theDuration.Builder
avoiding the need to create one manually viaDuration.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed todistinctCacheEvictionInterval(Duration)
.- Parameters:
distinctCacheEvictionInterval
- a consumer that will call methods onDuration.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
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
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 theDuration.Builder
avoiding the need to create one manually viaDuration.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed togen1Duration(Duration)
.- Parameters:
gen1Duration
- a consumer that will call methods onDuration.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
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 thePercentOrAbsoluteLong.Builder
avoiding the need to create one manually viaPercentOrAbsoluteLong.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed toexecMemPoolBytes(PercentOrAbsoluteLong)
.- Parameters:
execMemPoolBytes
- a consumer that will call methods onPercentOrAbsoluteLong.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
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 thePercentOrAbsoluteLong.Builder
avoiding the need to create one manually viaPercentOrAbsoluteLong.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed toparquetMemCacheSize(PercentOrAbsoluteLong)
.- Parameters:
parquetMemCacheSize
- a consumer that will call methods onPercentOrAbsoluteLong.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
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
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
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
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 theDuration.Builder
avoiding the need to create one manually viaDuration.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed togen1LookbackDuration(Duration)
.- Parameters:
gen1LookbackDuration
- a consumer that will call methods onDuration.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
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 theDuration.Builder
avoiding the need to create one manually viaDuration.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed toretentionCheckInterval(Duration)
.- Parameters:
retentionCheckInterval
- a consumer that will call methods onDuration.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
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 theDuration.Builder
avoiding the need to create one manually viaDuration.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed todeleteGracePeriod(Duration)
.- Parameters:
deleteGracePeriod
- a consumer that will call methods onDuration.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-
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 theDuration.Builder
avoiding the need to create one manually viaDuration.builder()
.When the
Consumer
completes,SdkBuilder.build()
is called immediately and its result is passed tohardDeleteDefaultDuration(Duration)
.- Parameters:
hardDeleteDefaultDuration
- a consumer that will call methods onDuration.Builder
- Returns:
- Returns a reference to this object so that method calls can be chained together.
- See Also:
-