Package io.openlineage.client.job

Class Naming.Spark

java.lang.Object

io.openlineage.client.job.Naming.Spark

All Implemented Interfaces:

Naming.JobName

Enclosing class:

Naming

public static class Naming.Spark
extends Object
implements Naming.JobName

Represents a Spark job name using the format: {appName}.{command}.{table}.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	Naming.Spark.SparkBuilder

Constructor Summary

Constructors

Constructor	Description
Spark(String appName, String command, String table)	Constructs a new Naming.Spark job name.

Method Summary

Modifier and Type	Method	Description
static Naming.Spark.SparkBuilder	builder()
String	getName()	Returns the formatted job name.

Methods inherited from class java.lang.Object

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

Constructor Details

Spark

public Spark(String appName,
 @Nullable
 String command,
 @Nullable
 String table)

Constructs a new Naming.Spark job name.

Parameters:

appName - the Spark application name; must be non-null and non-empty

command - the command or function being run; must be non-null and non-empty

table - the target table; must be non-null and non-empty

Throws:

IllegalArgumentException - if any argument is empty

NullPointerException - if any argument is null

Method Details

getName

public String getName()

Returns the formatted job name.

Specified by:

getName in interface Naming.JobName

Returns:

the job name in the format: {appName}.{command}.{table}

builder

public static Naming.Spark.SparkBuilder builder()