Package | Description |
---|---|
org.apache.tez.http | |
org.apache.tez.http.async.netty | |
org.apache.tez.runtime.library.common.shuffle |
Licensed to the Apache Software Foundation (ASF) under one
or more contributor license agreements.
|
Constructor and Description |
---|
HttpConnection(URL url,
HttpConnectionParams connParams,
String logIdentifier,
org.apache.tez.common.security.JobTokenSecretManager jobTokenSecretManager)
HttpConnection
|
Constructor and Description |
---|
AsyncHttpConnection(URL url,
HttpConnectionParams connParams,
String logIdentifier,
org.apache.tez.common.security.JobTokenSecretManager jobTokenSecretManager) |
Modifier and Type | Method and Description |
---|---|
static HttpConnectionParams |
ShuffleUtils.getHttpConnectionParams(org.apache.hadoop.conf.Configuration conf)
Build
HttpConnectionParams from configuration |
Modifier and Type | Method and Description |
---|---|
static BaseHttpConnection |
ShuffleUtils.getHttpConnection(boolean asyncHttp,
URL url,
HttpConnectionParams params,
String logIdentifier,
org.apache.tez.common.security.JobTokenSecretManager jobTokenSecretManager) |
Fetcher.FetcherBuilder |
Fetcher.FetcherBuilder.setHttpConnectionParameters(HttpConnectionParams httpParams) |
Constructor and Description |
---|
Fetcher.FetcherBuilder(FetcherCallback fetcherCallback,
HttpConnectionParams params,
FetchedInputAllocator inputManager,
org.apache.hadoop.yarn.api.records.ApplicationId appId,
int dagIdentifier,
org.apache.tez.common.security.JobTokenSecretManager jobTokenSecretMgr,
String srcNameTrimmed,
org.apache.hadoop.conf.Configuration conf,
boolean localDiskFetchEnabled,
String localHostname,
int shufflePort,
boolean asyncHttp) |
Fetcher.FetcherBuilder(FetcherCallback fetcherCallback,
HttpConnectionParams params,
FetchedInputAllocator inputManager,
org.apache.hadoop.yarn.api.records.ApplicationId appId,
int dagIdentifier,
org.apache.tez.common.security.JobTokenSecretManager jobTokenSecretMgr,
String srcNameTrimmed,
org.apache.hadoop.conf.Configuration conf,
org.apache.hadoop.fs.RawLocalFileSystem localFs,
org.apache.hadoop.fs.LocalDirAllocator localDirAllocator,
org.apache.hadoop.fs.Path lockPath,
boolean localDiskFetchEnabled,
boolean sharedFetchEnabled,
String localHostname,
int shufflePort,
boolean asyncHttp) |
Copyright © 2016 Apache Software Foundation. All rights reserved.