org.apache.hadoop.hive.llap.daemon.impl

Class QueryFragmentInfo

java.lang.Object

org.apache.hadoop.hive.llap.daemon.impl.QueryFragmentInfo

public class QueryFragmentInfo
extends Object

Constructor Summary

Constructors

Constructor and Description
QueryFragmentInfo(QueryInfo queryInfo, String vertexName, int fragmentNumber, int attemptNumber, org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SignableVertexSpec vertexSpec, String fragmentIdString)

Method Summary

Modifier and Type	Method and Description
static boolean	canFinish(QueryFragmentInfo fragment) Check whether a task can run to completion or may end up blocking on it's sources.
boolean	canFinishForPriority() Unlike canFinish, this CANNOT be derived dynamically; a change without a reinsert will cause the queue order to become incorrect.
boolean	equals(Object o)
int	getAttemptNumber()
String	getFragmentIdentifierString()
int	getFragmentNumber()
String[]	getLocalDirs() Get, and create if required, local-dirs for a fragment
String	getVertexName()
org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SignableVertexSpec	getVertexSpec()
int	hashCode()
boolean	registerForFinishableStateUpdates(FinishableStateUpdateHandler handler, boolean lastFinishableState)
void	setCanFinishForPriority(boolean value) This MUST be called when the fragment is NOT in wait queue.
void	unregisterForFinishableStateUpdates(FinishableStateUpdateHandler handler)

Methods inherited from class java.lang.Object

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

Constructor Detail

QueryFragmentInfo

public QueryFragmentInfo(QueryInfo queryInfo,
                         String vertexName,
                         int fragmentNumber,
                         int attemptNumber,
                         org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SignableVertexSpec vertexSpec,
                         String fragmentIdString)

Method Detail

getVertexSpec

public org.apache.hadoop.hive.llap.daemon.rpc.LlapDaemonProtocolProtos.SignableVertexSpec getVertexSpec()

getVertexName

public String getVertexName()

getFragmentNumber

public int getFragmentNumber()

getAttemptNumber

public int getAttemptNumber()

getFragmentIdentifierString

public String getFragmentIdentifierString()

canFinishForPriority

public boolean canFinishForPriority()

Unlike canFinish, this CANNOT be derived dynamically; a change without a reinsert will cause the queue order to become incorrect.

setCanFinishForPriority

public void setCanFinishForPriority(boolean value)

This MUST be called when the fragment is NOT in wait queue.

canFinish

public static boolean canFinish(QueryFragmentInfo fragment)

Check whether a task can run to completion or may end up blocking on it's sources. This currently happens via looking up source state. TODO: Eventually, this should lookup the Hive Processor to figure out whether it's reached a state where it can finish - especially in cases of failures after data has been fetched.

Returns:

true if the task can finish, false otherwise

getLocalDirs

public String[] getLocalDirs()
                      throws IOException

Get, and create if required, local-dirs for a fragment

Returns:

Throws:

IOException

registerForFinishableStateUpdates

public boolean registerForFinishableStateUpdates(FinishableStateUpdateHandler handler,
                                                 boolean lastFinishableState)

Parameters:

handler -

lastFinishableState -

Returns:

true if the current state is the same as the lastFinishableState. false if the state has already changed.

unregisterForFinishableStateUpdates

public void unregisterForFinishableStateUpdates(FinishableStateUpdateHandler handler)

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object