public class HWISessionItem extends java.lang.Object implements java.lang.Runnable, java.lang.Comparable<HWISessionItem>
Modifier and Type | Class and Description |
---|---|
static class |
HWISessionItem.WebSessionItemStatus
Represents the state a session item can be in.
|
Modifier and Type | Field and Description |
---|---|
protected static org.apache.commons.logging.Log |
l4j |
java.lang.Thread |
runnable |
Constructor and Description |
---|
HWISessionItem(HWIAuth auth,
java.lang.String sessionName)
Creates an instance of WebSessionItem, sets status to NEW.
|
Modifier and Type | Method and Description |
---|---|
void |
addQuery(java.lang.String query)
Adds a new query to the execution list.
|
void |
clearQueries() |
void |
clientKill() |
void |
clientRenew()
This method clears the private member variables.
|
void |
clientStart()
HWISessionItem is a Runnable instance.
|
int |
compareTo(HWISessionItem other)
to support sorting/Set.
|
boolean |
equals(java.lang.Object other)
Uses the sessionName property to compare to sessions.
|
HWIAuth |
getAuth() |
java.lang.String |
getErrorFile()
Currently unused.
|
HiveHistoryViewer |
getHistoryViewer() |
java.lang.String |
getHiveConfVar(HiveConf.ConfVars wanted)
Helper function to get configuration variables.
|
java.lang.String |
getHiveConfVar(java.lang.String s) |
java.lang.String |
getJobTrackerURL(java.lang.String jobid) |
java.util.List<java.lang.String> |
getQueries()
Returns an unmodifiable list of queries.
|
java.util.List<java.lang.Integer> |
getQueryRet()
The HWISessionItem stores the result of each query in an array.
|
java.util.ArrayList<java.util.ArrayList<java.lang.String>> |
getResultBucket()
gets the value for resultBucket.
|
int |
getResultBucketMaxSize()
returns the value for resultBucketMaxSize.
|
java.lang.String |
getResultFile() |
java.lang.String |
getSessionName()
The session name is an identifier to recognize the session.
|
boolean |
getSSIsSilent()
This is a chained call to SessionState.getIsSilent().
|
HWISessionItem.WebSessionItemStatus |
getStatus()
Used to represent to the user and other components what state the
HWISessionItem is in.
|
protected void |
killIt()
This is a callback style function used by the HiveSessionManager.
|
void |
removeQuery(int item)
Removes a query from the execution list.
|
void |
run() |
void |
runQuery()
runQuery iterates the list of queries executing each query.
|
protected void |
setAuth(HWIAuth auth) |
void |
setErrorFile(java.lang.String errorFile)
Currently unused.
|
void |
setResultBucketMaxSize(int size)
sets the value for resultBucketMaxSize.
|
void |
setResultFile(java.lang.String resultFile) |
void |
setSSIsSilent(boolean silent)
This is a chained call to SessionState.setIsSilent().
|
protected static final org.apache.commons.logging.Log l4j
public java.lang.Thread runnable
public HWISessionItem(HWIAuth auth, java.lang.String sessionName)
public void clientStart() throws HWIException
HWIException
public void clientKill() throws HWIException
HWIException
public void clientRenew() throws HWIException
HWIException
protected void killIt()
public java.lang.String getHiveConfVar(HiveConf.ConfVars wanted) throws HWIException
wanted
- a ConfVarHWIException
public java.lang.String getHiveConfVar(java.lang.String s) throws HWIException
HWIException
public java.lang.String getJobTrackerURL(java.lang.String jobid) throws HWIException
HWIException
public void run()
run
in interface java.lang.Runnable
public void runQuery()
public void setSSIsSilent(boolean silent) throws HWIException
HWIException
public boolean getSSIsSilent() throws HWIException
HWIException
public int compareTo(HWISessionItem other)
compareTo
in interface java.lang.Comparable<HWISessionItem>
public HiveHistoryViewer getHistoryViewer() throws HWIException
HWIException
public boolean equals(java.lang.Object other)
equals
in class java.lang.Object
public java.lang.String getResultFile()
public void setResultFile(java.lang.String resultFile)
public java.lang.String getSessionName()
public HWISessionItem.WebSessionItemStatus getStatus()
public java.lang.String getErrorFile()
public void setErrorFile(java.lang.String errorFile)
errorFile
- the full path to the file for results.public HWIAuth getAuth()
protected void setAuth(HWIAuth auth)
auth
- the auth to setpublic java.util.List<java.lang.String> getQueries()
public void addQuery(java.lang.String query) throws HWIException
query
- query to be added to the listHWIException
public void removeQuery(int item) throws HWIException
item
- the 0 based index of the item to be removedHWIException
public void clearQueries() throws HWIException
HWIException
public int getResultBucketMaxSize()
public void setResultBucketMaxSize(int size)
size
- the new sizepublic java.util.ArrayList<java.util.ArrayList<java.lang.String>> getResultBucket()
public java.util.List<java.lang.Integer> getQueryRet()
Copyright © 2012 The Apache Software Foundation