@InterfaceAudience.Public public class WALInputFormat extends <any>
InputFormat for WAL files.| Modifier and Type | Field and Description |
|---|---|
static String |
END_TIME_KEY |
static String |
START_TIME_KEY |
| Constructor and Description |
|---|
WALInputFormat() |
| Modifier and Type | Method and Description |
|---|---|
<any> |
createRecordReader(InputSplit split,
TaskAttemptContext context) |
List<InputSplit> |
getSplits(JobContext context) |
public static final String START_TIME_KEY
public static final String END_TIME_KEY
public List<InputSplit> getSplits(JobContext context) throws IOException, InterruptedException
IOExceptionInterruptedExceptionpublic <any> createRecordReader(InputSplit split,
TaskAttemptContext context)
throws IOException,
InterruptedException
IOExceptionInterruptedException