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.operator;
import static com.google.common.base.Preconditions.checkArgument;
import static com.google.common.base.Preconditions.checkNotNull;
        implements Supplier<ExchangeClient>
    private final BlockEncodingSerde blockEncodingSerde;
    private final DataSize maxBufferedBytes;
    private final int concurrentRequestMultiplier;
    private final Duration minErrorDuration;
    private final HttpClient httpClient;
    private final DataSize maxResponseSize;
    private final ScheduledExecutorService executor;
    @Inject
    public ExchangeClientFactory(BlockEncodingSerde blockEncodingSerde,
            ExchangeClientConfig config,
            @ForExchange HttpClient httpClient,
            @ForExchange ScheduledExecutorService executor)
    {
        this(blockEncodingSerde,
                config.getMaxBufferSize(),
                config.getMaxResponseSize(),
                config.getConcurrentRequestMultiplier(),
                config.getMinErrorDuration(),
                httpClient,
                executor);
    }
    public ExchangeClientFactory(
            BlockEncodingSerde blockEncodingSerde,
            DataSize maxBufferedBytes,
            DataSize maxResponseSize,
            int concurrentRequestMultiplier,
            Duration minErrorDuration,
            HttpClient httpClient,
            ScheduledExecutorService executor)
    {
        this. = blockEncodingSerde;
        this. = checkNotNull(maxBufferedBytes"maxBufferedBytes is null");
        this. = concurrentRequestMultiplier;
        this. = checkNotNull(minErrorDuration"minErrorDuration is null");
        this. = checkNotNull(httpClient"httpClient is null");
        this. = checkNotNull(maxResponseSize"maxResponseSize is null");
        this. = checkNotNull(executor"executor is null");
        checkArgument(maxBufferedBytes.toBytes() > 0, "maxBufferSize must be at least 1 byte: %s"maxBufferedBytes);
        checkArgument(maxResponseSize.toBytes() > 0, "maxResponseSize must be at least 1 byte: %s"maxResponseSize);
        checkArgument(concurrentRequestMultiplier > 0, "concurrentRequestMultiplier must be at least 1: %s"concurrentRequestMultiplier);
    }
    @Override
    public ExchangeClient get()
    {
        return new ExchangeClient(
                ,
                ,
                ,
                ,
                ,
                ,
                );
    }
New to GrepCode? Check out our FAQ X