@ThreadSafe public final class TransformJobInfo extends Object
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 . |
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() |
public TransformJobInfo(@NotNull String db, @NotNull String table, @NotNull String definition, long jobId, @NotNull Map<String,Layout> transformedLayouts)
Status.RUNNING
.db
- the database nametable
- the table namedefinition
- the transformation definitionjobId
- the job IDtransformedLayouts
- the mapping from a partition spec to its transformed layoutpublic String getDb()
public String getTable()
public String getDefinition()
public Map<String,Layout> getTransformedLayouts()
public long getJobId()
public Status getJobStatus()
public void setJobStatus(@NotNull Status status)
status
- the job statuspublic String getJobErrorMessage()
public void setJobErrorMessage(@NotNull String error)
error
- the errorpublic TransformJobInfo toProto()
Copyright © 2023. All Rights Reserved.