Package org.apache.arrow.datafusion
Class ExecutionOptions
java.lang.Object
org.apache.arrow.datafusion.ExecutionOptions
Configures options related to query execution
-
Method Summary
Modifier and TypeMethodDescriptionlongGet the batch sizebooleanGet whether batch coalescing is enabledbooleanGet whether statistics collection is enabledparquet()Get execution options related to reading Parquet datalongGet the target number of partitionswithBatchSize(long batchSize) Set the size of batches to use when creating new data batcheswithCoalesceBatches(boolean enabled) Set whether to enable batch coalescingwithCollectStatistics(boolean enabled) Set whether to enable statistics collectionwithTargetPartitions(long targetPartitions) Set the target number of partitions
-
Method Details
-
parquet
Get execution options related to reading Parquet data- Returns:
ParquetOptionsinstance for this config
-
batchSize
public long batchSize()Get the batch size- Returns:
- batch size
-
withBatchSize
Set the size of batches to use when creating new data batches- Parameters:
batchSize- the batch size to set- Returns:
- the modified
ExecutionOptionsinstance
-
coalesceBatches
public boolean coalesceBatches()Get whether batch coalescing is enabled- Returns:
- whether batch coalescing is enabled
-
withCoalesceBatches
Set whether to enable batch coalescing- Parameters:
enabled- whether to enable batch coalescing- Returns:
- the modified
ExecutionOptionsinstance
-
collectStatistics
public boolean collectStatistics()Get whether statistics collection is enabled- Returns:
- whether statistics collection is enabled
-
withCollectStatistics
Set whether to enable statistics collection- Parameters:
enabled- whether to enable statistics collection- Returns:
- the modified
ExecutionOptionsinstance
-
targetPartitions
public long targetPartitions()Get the target number of partitions- Returns:
- number of partitions
-
withTargetPartitions
Set the target number of partitions- Parameters:
targetPartitions- the number of partitions to set- Returns:
- the modified
ExecutionOptionsinstance
-