public class MoveWork extends Object implements Serializable
Modifier and Type | Field and Description |
---|---|
protected Set<ReadEntity> |
inputs
ReadEntitites that are passed to the hooks.
|
protected List<Partition> |
movedParts
List of inserted partitions
|
protected Set<WriteEntity> |
outputs
List of WriteEntities that are passed to the hooks.
|
Constructor and Description |
---|
MoveWork() |
MoveWork(boolean isCTAS,
Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
LoadTableDesc loadTableWork,
LoadFileDesc loadFileWork,
boolean checkFileFormat) |
MoveWork(MoveWork o) |
MoveWork(Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
LoadTableDesc loadTableWork,
LoadFileDesc loadFileWork,
boolean checkFileFormat) |
MoveWork(Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
LoadTableDesc loadTableWork,
LoadFileDesc loadFileWork,
boolean checkFileFormat,
boolean srcLocal) |
MoveWork(Set<ReadEntity> inputs,
Set<WriteEntity> outputs,
LoadTableDesc loadTableWork,
LoadFileDesc loadFileWork,
boolean checkFileFormat,
String dumpRoot,
ReplicationMetricCollector metricCollector,
boolean isReplication) |
Modifier and Type | Method and Description |
---|---|
boolean |
getCheckFileFormat() |
String |
getDumpDirectory() |
Set<ReadEntity> |
getInputs() |
boolean |
getIsInReplicationScope() |
LoadFileDesc |
getLoadFileWork() |
LoadMultiFilesDesc |
getLoadMultiFilesWork() |
LoadTableDesc |
getLoadTableWork() |
ReplicationMetricCollector |
getMetricCollector() |
Set<WriteEntity> |
getOutputs() |
boolean |
isCTAS() |
boolean |
isNeedCleanTarget() |
boolean |
isReplication() |
boolean |
isSrcLocal() |
void |
setCheckFileFormat(boolean checkFileFormat) |
void |
setInputs(Set<ReadEntity> inputs) |
void |
setIsInReplicationScope(boolean isInReplicationScope) |
void |
setLoadFileWork(LoadFileDesc loadFileWork) |
void |
setLoadTableWork(LoadTableDesc loadTableWork) |
void |
setMultiFilesDesc(LoadMultiFilesDesc lmfd) |
void |
setNeedCleanTarget(boolean needCleanTarget) |
void |
setOutputs(Set<WriteEntity> outputs) |
void |
setSrcLocal(boolean srcLocal) |
protected Set<ReadEntity> inputs
protected Set<WriteEntity> outputs
public MoveWork()
public MoveWork(Set<ReadEntity> inputs, Set<WriteEntity> outputs, LoadTableDesc loadTableWork, LoadFileDesc loadFileWork, boolean checkFileFormat, boolean srcLocal)
public MoveWork(Set<ReadEntity> inputs, Set<WriteEntity> outputs, LoadTableDesc loadTableWork, LoadFileDesc loadFileWork, boolean checkFileFormat)
public MoveWork(boolean isCTAS, Set<ReadEntity> inputs, Set<WriteEntity> outputs, LoadTableDesc loadTableWork, LoadFileDesc loadFileWork, boolean checkFileFormat)
public MoveWork(Set<ReadEntity> inputs, Set<WriteEntity> outputs, LoadTableDesc loadTableWork, LoadFileDesc loadFileWork, boolean checkFileFormat, String dumpRoot, ReplicationMetricCollector metricCollector, boolean isReplication)
public MoveWork(MoveWork o)
public boolean isCTAS()
public LoadTableDesc getLoadTableWork()
public void setLoadTableWork(LoadTableDesc loadTableWork)
public LoadFileDesc getLoadFileWork()
public LoadMultiFilesDesc getLoadMultiFilesWork()
public void setMultiFilesDesc(LoadMultiFilesDesc lmfd)
public void setLoadFileWork(LoadFileDesc loadFileWork)
public boolean getCheckFileFormat()
public void setCheckFileFormat(boolean checkFileFormat)
public Set<ReadEntity> getInputs()
public Set<WriteEntity> getOutputs()
public void setInputs(Set<ReadEntity> inputs)
public void setOutputs(Set<WriteEntity> outputs)
public boolean isSrcLocal()
public void setSrcLocal(boolean srcLocal)
public boolean isNeedCleanTarget()
public void setNeedCleanTarget(boolean needCleanTarget)
public void setIsInReplicationScope(boolean isInReplicationScope)
public ReplicationMetricCollector getMetricCollector()
public String getDumpDirectory()
public boolean isReplication()
public boolean getIsInReplicationScope()
Copyright © 2022 The Apache Software Foundation. All rights reserved.