org.apache.tez.runtime.library.common.shuffle

Class HttpConnection

java.lang.Object

org.apache.tez.runtime.library.common.shuffle.HttpConnection

public class HttpConnection
extends Object

HttpConnection which can be used for Unordered / Ordered shuffle.

Nested Class Summary

Nested Classes

Modifier and Type	Class and Description
static class	HttpConnection.HttpConnectionParams
static class	HttpConnection.HttpConnectionParamsBuilder

Field Summary

Fields

Modifier and Type	Field and Description
protected HttpURLConnection	connection

Constructor Summary

Constructors

Constructor and Description
HttpConnection(URL url, HttpConnection.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.
boolean	connect() Connect to source
boolean	connect(int connectionTimeout) Connect to source with specific timeout
DataInputStream	getInputStream() Get the inputstream from the connection
void	validate()

Methods inherited from class java.lang.Object

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

Field Detail

connection

protected HttpURLConnection connection

Constructor Detail

HttpConnection

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

HttpConnection

Parameters:

url -

connParams -

logIdentifier -

jobTokenSecretManager -

Throws:

IOException

Method Detail

connect

public boolean connect()
                throws IOException

Connect to source

Returns:

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

Throws:

IOException - upon connection failure

connect

public boolean connect(int connectionTimeout)
                throws IOException

Connect to source with specific timeout

Parameters:

connectionTimeout -

Returns:

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

Throws:

IOException - upon connection failure

validate

public void validate()
              throws IOException

Throws:

IOException

getInputStream

public DataInputStream getInputStream()
                               throws IOException

Get the inputstream from the connection

Returns:

DataInputStream

Throws:

IOException

cleanup

public void cleanup(boolean disconnect)
             throws IOException

Cleanup the connection.

Parameters:

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

Throws:

IOException