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 com.facebook.presto.util.Threads.daemonThreadsNamed;
 import static java.util.concurrent.Executors.newCachedThreadPool;
 
 public class HttpRemoteTaskFactory
         implements RemoteTaskFactory
 {
     private final AsyncHttpClient httpClient;
     private final LocationFactory locationFactory;
     private final JsonCodec<TaskInfotaskInfoCodec;
     private final int maxConsecutiveErrorCount;
     private final Duration minErrorDuration;
     private final ExecutorService executor = newCachedThreadPool(daemonThreadsNamed("remote-task-callback-%d"));
 
     @Inject
     public HttpRemoteTaskFactory(QueryManagerConfig config,
             @ForScheduler AsyncHttpClient httpClient,
             LocationFactory locationFactory,
             JsonCodec<TaskInfotaskInfoCodec,
             JsonCodec<TaskUpdateRequesttaskUpdateRequestCodec)
     {
         this. = httpClient;
         this. = locationFactory;
         this. = taskInfoCodec;
         this. = taskUpdateRequestCodec;
         this. = config.getRemoteTaskMinErrorDuration();
     }
 
     @Managed
     @Nested
     {
         return ;
     }
 
     @Override
     public RemoteTask createRemoteTask(Session session,
             TaskId taskId,
             com.facebook.presto.spi.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