Package | Description |
---|---|
org.apache.hadoop.hive.llap | |
org.apache.hadoop.hive.llap.daemon.impl | |
org.apache.hadoop.hive.llap.tez | |
org.apache.hadoop.hive.llap.tezplugins |
Modifier and Type | Method and Description |
---|---|
static LlapNodeId |
LlapNodeId.getInstance(String hostname,
int port) |
Modifier and Type | Method and Description |
---|---|
LlapNodeId |
QueryInfo.getAmNodeId() |
Constructor and Description |
---|
QueryInfo(QueryIdentifier queryIdentifier,
String appIdString,
String dagIdString,
String dagName,
String hiveQueryIdString,
int dagIdentifier,
String user,
ConcurrentMap<String,LlapDaemonProtocolProtos.SourceStateProto> sourceStateMap,
String[] localDirsBase,
org.apache.hadoop.fs.FileSystem localFs,
String tokenUserName,
String tokenAppId,
LlapNodeId amNodeId) |
Modifier and Type | Method and Description |
---|---|
void |
LlapProtocolClientProxy.sendSourceStateUpdate(LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request,
LlapNodeId nodeId,
LlapProtocolClientProxy.ExecuteRequestCallback<LlapDaemonProtocolProtos.SourceStateUpdatedResponseProto> callback) |
Modifier and Type | Method and Description |
---|---|
void |
LlapTaskCommunicator.registerKnownNode(LlapNodeId nodeId) |
void |
LlapTaskCommunicator.registerPingingNode(LlapNodeId nodeId) |
void |
LlapTaskCommunicator.sendStateUpdate(LlapNodeId nodeId,
LlapDaemonProtocolProtos.SourceStateUpdatedRequestProto request) |
Copyright © 2021 The Apache Software Foundation. All rights reserved.