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() |
java.lang.String[] |
getLocations() |
int |
getNoOfTags() |
int |
getRows() |
int |
getStartRow() |
TableName |
getTableName() |
int |
getTotalRows() |
boolean |
isFlushCommits() |
boolean |
isUseTags() |
boolean |
isWriteToWAL() |
void |
readFields(java.io.DataInput in) |
void |
write(java.io.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(java.io.DataInput in) throws java.io.IOException
java.io.IOException
public void write(java.io.DataOutput out) throws java.io.IOException
java.io.IOException
public long getLength() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
public java.lang.String[] getLocations() throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.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()