Start line:  
End line:  

Snippet Preview

Snippet HTML Code

Stack Overflow Questions
  /*
   * Licensed under the Apache License, Version 2.0 (the "License");
   * you may not use this file except in compliance with the License.
   * You may obtain a copy of the License at
   *
   *     http://www.apache.org/licenses/LICENSE-2.0
   *
   * Unless required by applicable law or agreed to in writing, software
   * distributed under the License is distributed on an "AS IS" BASIS,
  * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
  * See the License for the specific language governing permissions and
  * limitations under the License.
  */
 package com.facebook.presto.execution;
 
 
 
 
 public class TaskManagerConfig
 {
     private boolean verboseStats;
     private boolean taskCpuTimerEnabled = true;
     private DataSize maxTaskMemoryUsage = new DataSize(256, .);
     private DataSize operatorPreAllocatedMemory = new DataSize(16, .);
     private DataSize maxTaskIndexMemoryUsage = new DataSize(64, .);
     private int maxShardProcessorThreads = Runtime.getRuntime().availableProcessors() * 4;
     private Integer minDrivers;
 
     private DataSize sinkMaxBufferSize = new DataSize(32, .);
 
     private Duration clientTimeout = new Duration(5, .);
     private Duration infoMaxAge = new Duration(15, .);
     private int writerCount = 1;
     private int httpNotificationThreads = 25;
 
     public boolean isVerboseStats()
     {
         return ;
     }
 
     @Config("task.verbose-stats")
     public TaskManagerConfig setVerboseStats(boolean verboseStats)
     {
         this. = verboseStats;
         return this;
     }
 
     public boolean isTaskCpuTimerEnabled()
     {
         return ;
     }
 
     @Config("task.cpu-timer-enabled")
     public TaskManagerConfig setTaskCpuTimerEnabled(boolean taskCpuTimerEnabled)
     {
         this. = taskCpuTimerEnabled;
         return this;
     }
 
     @NotNull
     {
         return ;
     }
 
     @Config("task.max-partial-aggregation-memory")
     public TaskManagerConfig setMaxPartialAggregationMemoryUsage(DataSize maxPartialAggregationMemoryUsage)
     {
         this. = maxPartialAggregationMemoryUsage;
         return this;
     }
 
     {
         if ( == null) {
             return new DataSize(2 * .toBytes(), .);
         }
         return ;
     }
 
     @Config("experimental.big-query-max-task-memory")
     public TaskManagerConfig setBigQueryMaxTaskMemoryUsage(DataSize bigQueryMaxTaskMemoryUsage)
     {
         this. = bigQueryMaxTaskMemoryUsage;
         return this;
     }
 
     @NotNull
    {
        return ;
    }
    @Config("task.max-memory")
    public TaskManagerConfig setMaxTaskMemoryUsage(DataSize maxTaskMemoryUsage)
    {
        this. = maxTaskMemoryUsage;
        return this;
    }
    @NotNull
    {
        return ;
    }
    @Config("task.operator-pre-allocated-memory")
    public TaskManagerConfig setOperatorPreAllocatedMemory(DataSize operatorPreAllocatedMemory)
    {
        this. = operatorPreAllocatedMemory;
        return this;
    }
    @NotNull
    {
        return ;
    }
    @Config("task.max-index-memory")
    public TaskManagerConfig setMaxTaskIndexMemoryUsage(DataSize maxTaskIndexMemoryUsage)
    {
        this. = maxTaskIndexMemoryUsage;
        return this;
    }
    @Min(1)
    public int getMaxShardProcessorThreads()
    {
        return ;
    }
    @Config("task.shard.max-threads")
    public TaskManagerConfig setMaxShardProcessorThreads(int maxShardProcessorThreads)
    {
        this. = maxShardProcessorThreads;
        return this;
    }
    @Min(1)
    public int getMinDrivers()
    {
        if ( == null) {
            return 2 * ;
        }
        return ;
    }
    @Config("task.min-drivers")
    public TaskManagerConfig setMinDrivers(int minDrivers)
    {
        this. = minDrivers;
        return this;
    }
    @NotNull
    {
        return ;
    }
    @Config("sink.max-buffer-size")
    public TaskManagerConfig setSinkMaxBufferSize(DataSize sinkMaxBufferSize)
    {
        this. = sinkMaxBufferSize;
        return this;
    }
    @MinDuration("5s")
    @NotNull
    public Duration getClientTimeout()
    {
        return ;
    }
    @Config("task.client.timeout")
    public TaskManagerConfig setClientTimeout(Duration clientTimeout)
    {
        this. = clientTimeout;
        return this;
    }
    @NotNull
    public Duration getInfoMaxAge()
    {
        return ;
    }
    @Config("task.info.max-age")
    public TaskManagerConfig setInfoMaxAge(Duration infoMaxAge)
    {
        this. = infoMaxAge;
        return this;
    }
    @Min(1)
    public int getWriterCount()
    {
        return ;
    }
    @Config("task.writer-count")
    @ConfigDescription("Number of writers per task")
    public TaskManagerConfig setWriterCount(int writerCount)
    {
        this. = writerCount;
        return this;
    }
    @Min(1)
    public int getHttpNotificationThreads()
    {
        return ;
    }
    @Config("task.http-notification-threads")
    public TaskManagerConfig setHttpNotificationThreads(int httpNotificationThreads)
    {
        this. = httpNotificationThreads;
        return this;
    }
New to GrepCode? Check out our FAQ X