alluxio.master.table.transform

Class TransformJobInfo

java.lang.Object

alluxio.master.table.transform.TransformJobInfo

@ThreadSafe
public final class TransformJobInfo
extends Object

Information kept for a transformation job.

Constructor Summary

Constructors

Constructor and Description
TransformJobInfo(@NotNull String db, @NotNull String table, @NotNull String definition, long jobId, @NotNull Map<String,Layout> transformedLayouts) The default job status on construction is Status.RUNNING.

Method Summary

Modifier and Type	Method and Description
String	getDb()
Pair<String,String>	getDbTable()
String	getDefinition()
String	getJobErrorMessage()
long	getJobId()
Status	getJobStatus()
String	getTable()
Map<String,Layout>	getTransformedLayouts()
void	setJobErrorMessage(@NotNull String error) Sets the job error message.
void	setJobStatus(@NotNull Status status) Sets the job status.
TransformJobInfo	toProto()

Methods inherited from class java.lang.Object

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

Constructor Detail

TransformJobInfo

public TransformJobInfo(@NotNull
                        @NotNull String db,
                        @NotNull
                        @NotNull String table,
                        @NotNull
                        @NotNull String definition,
                        long jobId,
                        @NotNull
                        @NotNull Map<String,Layout> transformedLayouts)

The default job status on construction is Status.RUNNING.

Parameters:

db - the database name

table - the table name

definition - the transformation definition

jobId - the job ID

transformedLayouts - the mapping from a partition spec to its transformed layout

Method Detail

getDb

public String getDb()

Returns:

the database name

getTable

public String getTable()

Returns:

the table name

getDbTable

public Pair<String,String> getDbTable()

Returns:

the (db, table) pair

getDefinition

public String getDefinition()

Returns:

the transformation definition

getTransformedLayouts

public Map<String,Layout> getTransformedLayouts()

Returns:

a read-only mapping from a partition spec to its transformed layout

getJobId

public long getJobId()

Returns:

the job ID

getJobStatus

public Status getJobStatus()

Returns:

the job status

setJobStatus

public void setJobStatus(@NotNull
                         @NotNull Status status)

Sets the job status.

Parameters:

status - the job status

getJobErrorMessage

public String getJobErrorMessage()

Returns:

the job error message or empty if there is no error

setJobErrorMessage

public void setJobErrorMessage(@NotNull
                               @NotNull String error)

Sets the job error message.

Parameters:

error - the error

toProto

public TransformJobInfo toProto()

Returns:

the proto representation