public class MoveWork
extends java.lang.Object
implements java.io.Serializable
Modifier and Type | Field and Description |
---|---|
protected java.util.HashSet<ReadEntity> |
inputs
ReadEntitites that are passed to the hooks.
|
protected java.util.List<Partition> |
movedParts
List of inserted partitions
|
protected java.util.HashSet<WriteEntity> |
outputs
List of WriteEntities that are passed to the hooks.
|
Constructor and Description |
---|
MoveWork() |
MoveWork(java.util.HashSet<ReadEntity> inputs,
java.util.HashSet<WriteEntity> outputs) |
MoveWork(java.util.HashSet<ReadEntity> inputs,
java.util.HashSet<WriteEntity> outputs,
LoadTableDesc loadTableWork,
LoadFileDesc loadFileWork,
boolean checkFileFormat) |
Modifier and Type | Method and Description |
---|---|
boolean |
getCheckFileFormat() |
java.util.ArrayList<java.lang.String> |
getDPSpecPaths() |
java.util.HashSet<ReadEntity> |
getInputs() |
LoadFileDesc |
getLoadFileWork() |
LoadMultiFilesDesc |
getLoadMultiFilesWork() |
LoadTableDesc |
getLoadTableWork() |
java.util.HashSet<WriteEntity> |
getOutputs() |
void |
setCheckFileFormat(boolean checkFileFormat) |
void |
setDPSpecPaths(java.util.ArrayList<java.lang.String> dpsp) |
void |
setInputs(java.util.HashSet<ReadEntity> inputs) |
void |
setLoadFileWork(LoadFileDesc loadFileWork) |
void |
setLoadTableWork(LoadTableDesc loadTableWork) |
void |
setMultiFilesDesc(LoadMultiFilesDesc lmfd) |
void |
setOutputs(java.util.HashSet<WriteEntity> outputs) |
protected java.util.HashSet<ReadEntity> inputs
protected java.util.HashSet<WriteEntity> outputs
protected java.util.List<Partition> movedParts
public MoveWork()
public MoveWork(java.util.HashSet<ReadEntity> inputs, java.util.HashSet<WriteEntity> outputs)
public MoveWork(java.util.HashSet<ReadEntity> inputs, java.util.HashSet<WriteEntity> outputs, LoadTableDesc loadTableWork, LoadFileDesc loadFileWork, boolean checkFileFormat)
public void setDPSpecPaths(java.util.ArrayList<java.lang.String> dpsp)
public java.util.ArrayList<java.lang.String> getDPSpecPaths()
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 java.util.HashSet<ReadEntity> getInputs()
public java.util.HashSet<WriteEntity> getOutputs()
public void setInputs(java.util.HashSet<ReadEntity> inputs)
public void setOutputs(java.util.HashSet<WriteEntity> outputs)
Copyright © 2012 The Apache Software Foundation