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.server;
 
 
 
 
 import static io.airlift.concurrent.Threads.daemonThreadsNamed;
 import static java.util.concurrent.Executors.newCachedThreadPool;
 
 public class HttpRemoteTaskFactory
         implements RemoteTaskFactory
 {
     private final HttpClient httpClient;
     private final LocationFactory locationFactory;
     private final JsonCodec<TaskInfotaskInfoCodec;
     private final int maxConsecutiveErrorCount;
     private final Duration minErrorDuration;
     private final ExecutorService executor;
     private final ThreadPoolExecutorMBean executorMBean;
 
     @Inject
     public HttpRemoteTaskFactory(QueryManagerConfig config,
             @ForScheduler HttpClient httpClient,
             LocationFactory locationFactory,
             JsonCodec<TaskInfotaskInfoCodec,
             JsonCodec<TaskUpdateRequesttaskUpdateRequestCodec)
     {
         this. = httpClient;
         this. = locationFactory;
         this. = taskInfoCodec;
         this. = taskUpdateRequestCodec;
         this. = config.getRemoteTaskMinErrorDuration();
         ExecutorService coreExecutor = newCachedThreadPool(daemonThreadsNamed("remote-task-callback-%d"));
         this. = ExecutorServiceAdapter.from(new BoundedExecutor(coreExecutorconfig.getRemoteTaskMaxCallbackThreads()));
         this. = new ThreadPoolExecutorMBean((ThreadPoolExecutorcoreExecutor);
     }
 
     @Managed
     @Nested
     {
         return ;
     }
 
     @Override
     public RemoteTask createRemoteTask(Session session,
             TaskId taskId,
             Node node,
             PlanFragment fragment,
             Multimap<PlanNodeIdSplitinitialSplits,
             OutputBuffers outputBuffers)
     {
         return new HttpRemoteTask(session,
                 taskId,
                 node.getNodeIdentifier(),
                 .createTaskLocation(nodetaskId),
                 fragment,
                 initialSplits,
                 outputBuffers,
                 ,
                ,
                ,
                ,
                ,
                
        );
    }
New to GrepCode? Check out our FAQ X