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 |
---|---|
boolean |
canFinish()
Check whether a task can run to completion or may end up blocking on it's sources.
|
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 |
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 canFinish()
public String[] getLocalDirs() throws IOException
IOException
public boolean registerForFinishableStateUpdates(FinishableStateUpdateHandler handler, boolean lastFinishableState)
handler
- lastFinishableState
- public void unregisterForFinishableStateUpdates(FinishableStateUpdateHandler handler)
Copyright © 2016 The Apache Software Foundation. All rights reserved.