Collects per-node runtime metrics for an ETL pipeline run.

Members

MemberKindDescription
List<NodeRunMetrics> NodesPropertyGets or sets the nodes.
DateTime? StartedAtPropertyGets or sets the started at.
DateTime? CompletedAtPropertyGets or sets the completed at.
bool IsRunningPropertyGets or sets the is running.
TimeSpan TotalElapsedPropertyGets or sets the total elapsed.
void Start()MethodMarks the start of a pipeline run.
void Complete()MethodMarks the end of a pipeline run.
NodeRunMetrics Record(string nodeName, int rowsIn, int rowsOut, TimeSpan elapsed, string status = "Completed")MethodRecords a completed node execution.
int Measure(string nodeName, int rowsIn, Func<int> action)MethodMeasures a node action and records its metrics. Returns the action's row count.
void Reset()MethodClears all metrics and timing.
string Summary()MethodHuman-readable metrics report.

Related