public class QueryFragmentInfo extends Object
Constructor and Description |
---|
QueryFragmentInfo(QueryInfo queryInfo,
String vertexName,
int fragmentNumber,
int attemptNumber,
LlapDaemonProtocolProtos.SignableVertexSpec vertexSpec,
String fragmentIdString) |
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() |
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) |
public QueryFragmentInfo(QueryInfo queryInfo, String vertexName, int fragmentNumber, int attemptNumber, LlapDaemonProtocolProtos.SignableVertexSpec vertexSpec, String fragmentIdString)
public LlapDaemonProtocolProtos.SignableVertexSpec getVertexSpec()
public String getVertexName()
public int getFragmentNumber()
public int getAttemptNumber()
public String getFragmentIdentifierString()
public boolean canFinishForPriority()
public void setCanFinishForPriority(boolean value)
public static boolean canFinish(QueryFragmentInfo fragment)
public String[] getLocalDirs() throws IOException
IOException
public boolean registerForFinishableStateUpdates(FinishableStateUpdateHandler handler, boolean lastFinishableState)
handler
- lastFinishableState
- public void unregisterForFinishableStateUpdates(FinishableStateUpdateHandler handler)
Copyright © 2021 The Apache Software Foundation. All rights reserved.