Package dev.frostlake.metastore.model

Class TaskExecution

java.lang.Object

dev.frostlake.metastore.model.TaskExecution

public class TaskExecution
extends Object

Constructor Summary

Constructors

Constructor	Description
TaskExecution(LocalDateTime scheduledTime, LocalDateTime startTime, LocalDateTime endTime, TaskExecutionState state, String errorMessage, int rowsAffected)
TaskExecution(LocalDateTime scheduledTime, LocalDateTime startTime, LocalDateTime endTime, TaskExecutionState state, String errorMessage, int rowsAffected, TaskTrigger trigger)	The same, recording what started the run.

Method Summary

Modifier and Type	Method	Description
LocalDateTime	getEndTime()
String	getErrorMessage()
int	getRowsAffected()
String	getScheduledFrom()	What started this run, as TASK_HISTORY prints it.
LocalDateTime	getScheduledTime()
LocalDateTime	getStartTime()
String	getState()

Methods inherited from class java.lang.Object

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

Constructor Details

TaskExecution

public TaskExecution(LocalDateTime scheduledTime,
 LocalDateTime startTime,
 LocalDateTime endTime,
 TaskExecutionState state,
 String errorMessage,
 int rowsAffected)

TaskExecution

public TaskExecution(LocalDateTime scheduledTime,
 LocalDateTime startTime,
 LocalDateTime endTime,
 TaskExecutionState state,
 String errorMessage,
 int rowsAffected,
 TaskTrigger trigger)

The same, recording what started the run.

Parameters:

scheduledTime - the time the run was scheduled for

startTime - when it began

endTime - when it ended

state - its outcome

errorMessage - the failure's message, or null

rowsAffected - the rows its body wrote

trigger - what started it

Method Details

getScheduledFrom

public String getScheduledFrom()

What started this run, as TASK_HISTORY prints it.

Returns:

SCHEDULE or EXECUTE TASK

getScheduledTime

public LocalDateTime getScheduledTime()

getStartTime

public LocalDateTime getStartTime()

getEndTime

public LocalDateTime getEndTime()

getState

public String getState()

getErrorMessage

public String getErrorMessage()

getRowsAffected

public int getRowsAffected()