org.apache.tez.http

Class HttpConnection

java.lang.Object

org.apache.tez.http.BaseHttpConnection

org.apache.tez.http.HttpConnection

public class HttpConnection
extends BaseHttpConnection

Field Summary

Fields

Modifier and Type	Field and Description
protected HttpURLConnection	connection

Fields inherited from class org.apache.tez.http.BaseHttpConnection

UNIT_CONNECT_TIMEOUT

Constructor Summary

Constructors

Constructor and Description
HttpConnection(URL url, HttpConnectionParams connParams, String logIdentifier, org.apache.tez.common.security.JobTokenSecretManager jobTokenSecretManager) HttpConnection

Method Summary

Methods

Modifier and Type	Method and Description
void	cleanup(boolean disconnect) Cleanup the connection.
void	computeEncHash()
boolean	connect() Connect to source
DataInputStream	getInputStream() Get the inputstream from the connection
void	validate() Validate established connection

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

connection

protected volatile HttpURLConnection connection

Constructor Detail

HttpConnection

public HttpConnection(URL url,
              HttpConnectionParams connParams,
              String logIdentifier,
              org.apache.tez.common.security.JobTokenSecretManager jobTokenSecretManager)
               throws IOException

HttpConnection

Parameters:

url -

connParams -

logIdentifier -

jobTokenSecretManager -

Throws:

IOException

Method Detail

computeEncHash

public void computeEncHash()
                    throws IOException

Throws:

IOException

connect

public boolean connect()
                throws IOException

Connect to source

Specified by:

connect in class BaseHttpConnection

Returns:

true if connection was successful false if connection was previously cleaned up

Throws:

IOException - upon connection failure

validate

public void validate()
              throws IOException

Description copied from class: BaseHttpConnection

Validate established connection

Specified by:

validate in class BaseHttpConnection

Throws:

IOException

getInputStream

public DataInputStream getInputStream()
                               throws IOException

Get the inputstream from the connection

Specified by:

getInputStream in class BaseHttpConnection

Returns:

DataInputStream

Throws:

IOException

cleanup

public void cleanup(boolean disconnect)
             throws IOException

Cleanup the connection.

Specified by:

cleanup in class BaseHttpConnection

Parameters:

disconnect - Close the connection if this is true; otherwise respect keepalive

Throws:

IOException