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(String db, String table, String definition, long jobId, 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(String error) Sets the job error message.
void	setJobStatus(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
                        String db,
                        @NotNull
                        String table,
                        @NotNull
                        String definition,
                        long jobId,
                        @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
                         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
                               String error)

Sets the job error message.

Parameters:

error - the error

toProto

public TransformJobInfo toProto()

Returns:

the proto representation