Proprietà di configurazione perPresto (Java )- coordinatore e nodi di lavoro

È possibile personalizzare le proprietà di configurazione del coordinatore e del lavoratore tramite un'API perPresto (Java ).

Proprietà di configurazione per Presto (Java)- nodi coordinatori e nodi lavoratori
Nome proprietà Immettere Aggiunta convalida
experimental.optimized-repartitioning Booleano True o False
experimental.reserved-pool-enabled Booleano True o False
fragment-result-cache.enabled Booleano True o False
fragment-result-cache.max-cached-entries Numero intero 1000000
fragment-result-cache.base-directory Stringa file:///mnt/tmpfs/fragment
fragment-result-cache.cache-ttl Stringa 24h
heap_dump_on_exceeded_memory_limit.enabled Booleano True o False
heap_dump_on_exceeded_memory_limit.file_directory Stringa Qualsiasi stringa
heap_dump_on_exceeded_memory_limit.max.number Numero intero Limite{1, 1000}
heap_dump_on_exceeded_memory_limit.max.size Numero intero Limite{1, 1000}
memory.heap-headroom-per-node Stringa Limite{1, 1e9} ; i valori supportati sono numeri con o senza unità TB, MB, GB, B, KB
node-scheduler.include-coordinator Booleano True o False
query.execution-policy Stringa Qualsiasi stringa
query.low-memory-killer.policy Stringa Qualsiasi stringa
query.max-memory Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità TB, MB, GB, B, KB
query.max-memory-per-node Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità TB, MB, GB, B, KB
query.max-stage-count Numero intero Limite{1, 1000}
query.max-total-memory-per-node Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità TB, MB, GB, B, KB
query.min-expire-age Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità m, s, ms, h
query.stage-count-warning-threshold Numero intero Limite{1, 1000}
task.concurrency Numero intero Limite{1, 1000}
task.max-drivers-per-task Numero intero Limite{1, 100}
join-distribution-type Stringa Il valore deve essere automatico, trasmesso o partizionato
exchange.client-threads Numero intero Limite{1, 1000}
exchange.http-client.max-connections Numero intero Limite{1, 10000}
exchange.http-client.max-connections-per-server Numero intero Limite{1, 100000}
http-server.log.max-size Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità TB, MB, GB, B, KB
http-server.log.max-history Numero intero Limite{1, 100}
http-server.threads.max Numero intero Limite{1, 1000}
join-max-broadcast-table-size Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità TB, MB, GB, B, KB
log.max-history Numero intero Limite{1, 100}
log.max-size Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità TB, MB, GB, B, KB
node-scheduler.max-pending-splits-per-task Numero intero Limite{1, 3000}
node-scheduler.max-splits-per-node Numero intero Limite{1, 3000}
optimize-nulls-in-join Booleano True o False
optimizer.default-filter-factor-enabled Booleano True o False
optimizer.exploit-constraints Booleano True o False
optimizer.prefer-partial-aggregation Booleano True o False
query.client.timeout Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità m, s, ms, h
query.max-execution-time Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità m, s, ms, h
query.max-history Numero intero Limite{1, 100}
query.max-total-memory Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità TB, MB, GB
query.min-schedule-split-batch-size Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità TB, MB, GB, B, KB
query.max-length Numero intero Limite{1, 1000000}
scale-writers Booleano True o False
shutdown.grace-period Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità m, s, ms, h
sink.max-buffer-size Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità TB, MB, GB, B, KB
experimental.max-revocable-memory-per-node Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità TB, MB, GB, B, KB
experimental.max-spill-per-node Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità TB, MB, GB, B, KB
experimental.pushdown-dereference-enabled Booleano True o False
experimental.pushdown-subfields-enabled Booleano True o False
experimental.query-max-spill-per-node Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità TB, MB, GB, B, KB
experimental.spiller-max-used-space-threshold Float Galleggiante 64
experimental.spiller-spill-path Stringa Qualsiasi stringa
http-server.max-request-header-size Stringa Limite {1, 1e13} ; i valori supportati sono numeri con o senza unità TB, MB, GB, B, kB
http-server.max-response-header-size Stringa Limite {1, 1e13} ; i valori supportati sono numeri con o senza unità TB, MB, GB, B, kB
experimental.internal-communication.max-task-update-size Stringa Limite{1, 1e13} ; i valori supportati sono numeri con o senza unità TB, MB, GB, B, KB
offset-clause-enabled Booleano True o False

Per abilitare la cache dei frammenti, è necessario impostare un ambiente abilitato alla cache. Per la configurazione, inserire le seguenti proprietà in /opt/presto/etc/config.properties.

fragment-result-cache.enabled: true
fragment-result-cache.base-directory: file:///mnt/tmpfs/fragment
fragment-result-cache.max-cached-entries: 1000000
fragment-result-cache.cache-ttl: 24h

Il percorso di montaggio /mnt/tmpfs/fragment è disponibile per impostazione predefinita in un ambiente abilitato alla cache con il volume del sistema montato su di esso.