static class WALInputFormat.WALSplit extends org.apache.hadoop.mapreduce.InputSplit implements org.apache.hadoop.io.Writable
InputSplit
for WAL
files. Each split represent exactly one log file.Modifier and Type | Field and Description |
---|---|
private long |
endTime |
private long |
fileSize |
private String |
logFileName |
private long |
startTime |
Constructor and Description |
---|
WALSplit()
for serialization
|
WALSplit(String logFileName,
long fileSize,
long startTime,
long endTime)
Represent an WALSplit, i.e.
|
Modifier and Type | Method and Description |
---|---|
long |
getEndTime() |
long |
getLength() |
String[] |
getLocations() |
String |
getLogFileName() |
long |
getStartTime() |
void |
readFields(DataInput in) |
String |
toString() |
void |
write(DataOutput out) |
private String logFileName
private long fileSize
private long startTime
private long endTime
public WALSplit()
public long getLength() throws IOException, InterruptedException
getLength
in class org.apache.hadoop.mapreduce.InputSplit
IOException
InterruptedException
public String[] getLocations() throws IOException, InterruptedException
getLocations
in class org.apache.hadoop.mapreduce.InputSplit
IOException
InterruptedException
public String getLogFileName()
public long getStartTime()
public long getEndTime()
public void readFields(DataInput in) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
IOException
public void write(DataOutput out) throws IOException
write
in interface org.apache.hadoop.io.Writable
IOException
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.