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 QueryManagerConfig
 {
     private int scheduleSplitBatchSize = 1000;
     private int maxConcurrentQueries = 1000;
     private int maxQueuedQueries = 5000;
     private int maxConcurrentBigQueries = 10;
     private int maxQueuedBigQueries = 500;
     private int maxPendingSplitsPerNode = 100;
 
     private int initialHashPartitions = 8;
     private Duration maxQueryAge = new Duration(15, .);
     private int maxQueryHistory = 100;
     private Duration clientTimeout = new Duration(5, .);
 
     private int queryManagerExecutorPoolSize = 5;
 
     private int remoteTaskMaxConsecutiveErrorCount = 10;
     private int remoteTaskMaxCallbackThreads = 1000;
 
     @Min(1)
     public int getScheduleSplitBatchSize()
     {
         return ;
     }
 
     @Config("query.schedule-split-batch-size")
     public QueryManagerConfig setScheduleSplitBatchSize(int scheduleSplitBatchSize)
     {
         this. = scheduleSplitBatchSize;
         return this;
     }
 
     @Min(1)
     public int getMaxConcurrentBigQueries()
     {
         return ;
     }
 
     @Config("experimental.max-concurrent-big-queries")
     public QueryManagerConfig setMaxConcurrentBigQueries(int maxConcurrentBigQueries)
     {
         this. = maxConcurrentBigQueries;
         return this;
     }
 
     @Min(1)
     public int getMaxQueuedBigQueries()
     {
         return ;
     }
 
     @Config("experimental.max-queued-big-queries")
     public QueryManagerConfig setMaxQueuedBigQueries(int maxQueuedBigQueries)
     {
         this. = maxQueuedBigQueries;
         return this;
     }
 
     @Min(1)
     public int getMaxConcurrentQueries()
     {
         return ;
     }
 
     @Config("query.max-concurrent-queries")
     public QueryManagerConfig setMaxConcurrentQueries(int maxConcurrentQueries)
     {
         this. = maxConcurrentQueries;
         return this;
     }
 
     @Min(1)
    public int getMaxQueuedQueries()
    {
        return ;
    }
    @Config("query.max-queued-queries")
    public QueryManagerConfig setMaxQueuedQueries(int maxQueuedQueries)
    {
        this. = maxQueuedQueries;
        return this;
    }
    @Min(1)
    public int getMaxPendingSplitsPerNode()
    {
        return ;
    }
    @Config("query.max-pending-splits-per-node")
    public QueryManagerConfig setMaxPendingSplitsPerNode(int maxPendingSplitsPerNode)
    {
        this. = maxPendingSplitsPerNode;
        return this;
    }
    @Nullable
    @Min(1)
    {
        return ;
    }
    @Config("experimental.big-query-initial-hash-partitions")
    public QueryManagerConfig setBigQueryInitialHashPartitions(Integer bigQueryinitialHashPartitions)
    {
        this. = bigQueryinitialHashPartitions;
        return this;
    }
    @Min(1)
    public int getInitialHashPartitions()
    {
        return ;
    }
    @Config("query.initial-hash-partitions")
    public QueryManagerConfig setInitialHashPartitions(int initialHashPartitions)
    {
        this. = initialHashPartitions;
        return this;
    }
    @NotNull
    public Duration getMaxQueryAge()
    {
        return ;
    }
    @Config("query.max-age")
    public QueryManagerConfig setMaxQueryAge(Duration maxQueryAge)
    {
        this. = maxQueryAge;
        return this;
    }
    @Min(0)
    public int getMaxQueryHistory()
    {
        return ;
    }
    @Config("query.max-history")
    public QueryManagerConfig setMaxQueryHistory(int maxQueryHistory)
    {
        this. = maxQueryHistory;
        return this;
    }
    @MinDuration("5s")
    @NotNull
    public Duration getClientTimeout()
    {
        return ;
    }
    @Config("query.client.timeout")
    public QueryManagerConfig setClientTimeout(Duration clientTimeout)
    {
        this. = clientTimeout;
        return this;
    }
    @Min(1)
    public int getQueryManagerExecutorPoolSize()
    {
        return ;
    }
    @Config("query.manager-executor-pool-size")
    public QueryManagerConfig setQueryManagerExecutorPoolSize(int queryManagerExecutorPoolSize)
    {
        this. = queryManagerExecutorPoolSize;
        return this;
    }
    @Min(0)
    {
        return ;
    }
    @Config("query.remote-task.max-consecutive-error-count")
    public QueryManagerConfig setRemoteTaskMaxConsecutiveErrorCount(int remoteTaskMaxConsecutiveErrorCount)
    {
        this. = remoteTaskMaxConsecutiveErrorCount;
        return this;
    }
    @NotNull
    {
        return ;
    }
    @Config("query.remote-task.min-error-duration")
    public QueryManagerConfig setRemoteTaskMinErrorDuration(Duration remoteTaskMinErrorDuration)
    {
        this. = remoteTaskMinErrorDuration;
        return this;
    }
    @Min(1)
    public int getRemoteTaskMaxCallbackThreads()
    {
        return ;
    }
    @Config("query.remote-task.max-callback-threads")
    public QueryManagerConfig setRemoteTaskMaxCallbackThreads(int remoteTaskMaxCallbackThreads)
    {
        this. = remoteTaskMaxCallbackThreads;
        return this;
    }
New to GrepCode? Check out our FAQ X