public final class GraphFilterInputFormat extends <any> implements GraphFilterAware
InputFormat that is useful if the underlying InputFormat is not GraphFilterAware.
If the underlying InputFormat is GraphFilterAware, then GraphFilterInputFormat acts as an identity mapping.
If the underlying InputFormat is not GraphFilterAware, then GraphFilterInputFormat will apply the respective GraphFilter
and prune the loaded source graph data accordingly.| Constructor and Description |
|---|
GraphFilterInputFormat() |
| Modifier and Type | Method and Description |
|---|---|
<any> |
createRecordReader(InputSplit inputSplit,
TaskAttemptContext taskAttemptContext) |
List<InputSplit> |
getSplits(JobContext jobContext) |
void |
setGraphFilter(GraphFilter graphFilter) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitstoreGraphFilterpublic List<InputSplit> getSplits(JobContext jobContext) throws IOException, InterruptedException
IOExceptionInterruptedExceptionpublic <any> createRecordReader(InputSplit inputSplit,
TaskAttemptContext taskAttemptContext)
throws IOException,
InterruptedException
IOExceptionInterruptedExceptionpublic void setGraphFilter(GraphFilter graphFilter)
setGraphFilter in interface GraphFilterAwareCopyright © 2013–2016 Apache Software Foundation. All rights reserved.