org.apache.hadoop.hive.ql.tools

Class LineageInfo

java.lang.Object

org.apache.hadoop.hive.ql.tools.LineageInfo

All Implemented Interfaces:

NodeProcessor

public class LineageInfo
extends java.lang.Object
implements NodeProcessor

This class prints out the lineage info. It takes sql as input and prints lineage info. Currently this prints only input and output tables for a given sql. Later we can expand to add join tables etc.

Constructor Summary

Constructors

Constructor and Description
LineageInfo()

Method Summary

Modifier and Type	Method and Description
java.util.TreeSet<java.lang.String>	getInputTableList()
void	getLineageInfo(java.lang.String query) parses given query and gets the lineage info.
java.util.TreeSet<java.lang.String>	getOutputTableList()
static void	main(java.lang.String[] args)
java.lang.Object	process(Node nd, java.util.Stack<Node> stack, NodeProcessorCtx procCtx, java.lang.Object... nodeOutputs) Implements the process method for the NodeProcessor interface.

Methods inherited from class java.lang.Object

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

Constructor Detail

LineageInfo

public LineageInfo()

Method Detail

getInputTableList

public java.util.TreeSet<java.lang.String> getInputTableList()

Returns:

java.util.TreeSet

getOutputTableList

public java.util.TreeSet<java.lang.String> getOutputTableList()

Returns:

java.util.TreeSet

process

public java.lang.Object process(Node nd,
                                java.util.Stack<Node> stack,
                                NodeProcessorCtx procCtx,
                                java.lang.Object... nodeOutputs)
                         throws SemanticException

Implements the process method for the NodeProcessor interface.

Specified by:

process in interface NodeProcessor

Parameters:

nd - operator to process

procCtx - operator processor context

nodeOutputs - A variable argument list of outputs from other nodes in the walk

Returns:

Object to be returned by the process call

Throws:

SemanticException

getLineageInfo

public void getLineageInfo(java.lang.String query)
                    throws ParseException,
                           SemanticException

parses given query and gets the lineage info.

Parameters:

query -

Throws:

ParseException

SemanticException

main

public static void main(java.lang.String[] args)
                 throws java.io.IOException,
                        ParseException,
                        SemanticException

Throws:

java.io.IOException

ParseException

SemanticException