public class LineageLogger extends Object implements ExecuteWithHookContext
Modifier and Type | Class and Description |
---|---|
static class |
LineageLogger.Edge
An edge in lineage.
|
static class |
LineageLogger.Vertex
A vertex in lineage.
|
Constructor and Description |
---|
LineageLogger() |
Modifier and Type | Method and Description |
---|---|
static List<LineageLogger.Edge> |
getEdges(QueryPlan plan,
LineageCtx.Index index)
Based on the final select operator, find out all the target columns.
|
static Set<LineageLogger.Vertex> |
getVertices(List<LineageLogger.Edge> edges)
Get all the vertices of all edges.
|
void |
run(HookContext hookContext) |
public void run(HookContext hookContext)
run
in interface ExecuteWithHookContext
hookContext
- The hook context passed to each hooks.public static List<LineageLogger.Edge> getEdges(QueryPlan plan, LineageCtx.Index index)
public static Set<LineageLogger.Vertex> getVertices(List<LineageLogger.Edge> edges)
Copyright © 2022 The Apache Software Foundation. All rights reserved.