public static class PerformanceEvaluation.PeInputSplit
extends InputSplit
Constructor and Description |
---|
PeInputSplit() |
PeInputSplit(TableName tableName,
int startRow,
int rows,
int totalRows,
int clients,
boolean flushCommits,
boolean writeToWAL,
boolean useTags,
int noOfTags) |
Modifier and Type | Method and Description |
---|---|
int |
getClients() |
long |
getLength() |
String[] |
getLocations() |
int |
getNoOfTags() |
int |
getRows() |
int |
getStartRow() |
TableName |
getTableName() |
int |
getTotalRows() |
boolean |
isFlushCommits() |
boolean |
isUseTags() |
boolean |
isWriteToWAL() |
void |
readFields(DataInput in) |
void |
write(DataOutput out) |
public PeInputSplit()
public PeInputSplit(TableName tableName, int startRow, int rows, int totalRows, int clients, boolean flushCommits, boolean writeToWAL, boolean useTags, int noOfTags)
public void readFields(DataInput in) throws IOException
IOException
public void write(DataOutput out) throws IOException
IOException
public long getLength() throws IOException, InterruptedException
IOException
InterruptedException
public String[] getLocations() throws IOException, InterruptedException
IOException
InterruptedException
public int getStartRow()
public TableName getTableName()
public int getRows()
public int getTotalRows()
public int getClients()
public boolean isFlushCommits()
public boolean isWriteToWAL()
public boolean isUseTags()
public int getNoOfTags()