Skip to content
Projects
Groups
Snippets
Help
This project
Loading...
Sign in / Register
Toggle navigation
A
atlas
Project
Overview
Details
Activity
Cycle Analytics
Repository
Repository
Files
Commits
Branches
Tags
Contributors
Graph
Compare
Charts
Issues
0
Issues
0
List
Board
Labels
Milestones
Merge Requests
0
Merge Requests
0
CI / CD
CI / CD
Pipelines
Jobs
Schedules
Charts
Wiki
Wiki
Snippets
Snippets
Members
Members
Collapse sidebar
Close sidebar
Activity
Graph
Charts
Create a new issue
Jobs
Commits
Issue Boards
Open sidebar
dataplatform
atlas
Commits
ba14612a
Commit
ba14612a
authored
Jan 06, 2015
by
a760104
Browse files
Options
Browse Files
Download
Email Patches
Plain Diff
Commit hive execution engine type, hive session id, and change log.info
to log.debug
parent
82aa80c0
Show whitespace changes
Inline
Side-by-side
Showing
3 changed files
with
3 additions
and
0 deletions
+3
-0
HiveLineageBean.java
.../main/java/com/aetna/hadoop/dgc/hive/HiveLineageBean.java
+1
-0
HiveLineageInfo.java
.../main/java/com/aetna/hadoop/dgc/hive/HiveLineageInfo.java
+1
-0
Hook.java
hivehook/src/main/java/com/aetna/hadoop/dgc/hive/Hook.java
+1
-0
No files found.
hivehook/src/main/java/com/aetna/hadoop/dgc/hive/HiveLineageBean.java
View file @
ba14612a
...
@@ -10,6 +10,7 @@ public class HiveLineageBean implements Serializable {
...
@@ -10,6 +10,7 @@ public class HiveLineageBean implements Serializable {
*
*
*/
*/
private
static
final
long
serialVersionUID
=
1L
;
private
static
final
long
serialVersionUID
=
1L
;
public
String
queryId
;
public
String
queryId
;
public
String
hiveId
;
public
String
hiveId
;
public
String
user
;
public
String
user
;
...
...
hivehook/src/main/java/com/aetna/hadoop/dgc/hive/HiveLineageInfo.java
View file @
ba14612a
...
@@ -81,6 +81,7 @@ public class HiveLineageInfo implements NodeProcessor {
...
@@ -81,6 +81,7 @@ public class HiveLineageInfo implements NodeProcessor {
public
HiveLineageBean
getHLBean
()
{
public
HiveLineageBean
getHLBean
()
{
return
hlb
;
return
hlb
;
}
}
/**
/**
* Implements the process method for the NodeProcessor interface.
* Implements the process method for the NodeProcessor interface.
*/
*/
...
...
hivehook/src/main/java/com/aetna/hadoop/dgc/hive/Hook.java
View file @
ba14612a
...
@@ -45,6 +45,7 @@ import org.apache.hadoop.util.StringUtils;
...
@@ -45,6 +45,7 @@ import org.apache.hadoop.util.StringUtils;
* DGC Hook sends query + plan info to DGCCollector Service. To enable (hadoop 2.4 and up) set
* DGC Hook sends query + plan info to DGCCollector Service. To enable (hadoop 2.4 and up) set
* hive.exec.pre.hooks/hive.exec.post.hooks/hive.exec.failure.hooks to include this class.
* hive.exec.pre.hooks/hive.exec.post.hooks/hive.exec.failure.hooks to include this class.
*/
*/
public
class
Hook
implements
ExecuteWithHookContext
{
public
class
Hook
implements
ExecuteWithHookContext
{
private
static
final
Log
LOG
=
LogFactory
.
getLog
(
Hook
.
class
.
getName
());
private
static
final
Log
LOG
=
LogFactory
.
getLog
(
Hook
.
class
.
getName
());
...
...
Write
Preview
Markdown
is supported
0%
Try again
or
attach a new file
Attach a file
Cancel
You are about to add
0
people
to the discussion. Proceed with caution.
Finish editing this message first!
Cancel
Please
register
or
sign in
to comment