I
- Vertex idV
- Vertex valueE
- Edge valueprotected abstract static class HCatalogVertexOutputFormat.HCatalogVertexWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable> extends VertexWriter<I,V,E>
Modifier | Constructor and Description |
---|---|
protected |
HCatalogVertexWriter() |
Modifier and Type | Method and Description |
---|---|
void |
close(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
protected org.apache.hadoop.mapreduce.TaskAttemptContext |
getContext()
Get the context.
|
protected org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable<?>,org.apache.hcatalog.data.HCatRecord> |
getRecordWriter()
Get the record reader.
|
protected void |
initialize(org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable<?>,org.apache.hcatalog.data.HCatRecord> hCatRecordWriter)
Initialize with the HCatRecordWriter
|
void |
initialize(org.apache.hadoop.mapreduce.TaskAttemptContext context) |
getConf, setConf
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
writeVertex
protected void initialize(org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable<?>,org.apache.hcatalog.data.HCatRecord> hCatRecordWriter)
hCatRecordWriter
- Internal writerprotected org.apache.hadoop.mapreduce.RecordWriter<org.apache.hadoop.io.WritableComparable<?>,org.apache.hcatalog.data.HCatRecord> getRecordWriter()
protected org.apache.hadoop.mapreduce.TaskAttemptContext getContext()
public void initialize(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException
initialize
in class VertexWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
IOException
public void close(org.apache.hadoop.mapreduce.TaskAttemptContext context) throws IOException, InterruptedException
close
in class VertexWriter<I extends org.apache.hadoop.io.WritableComparable,V extends org.apache.hadoop.io.Writable,E extends org.apache.hadoop.io.Writable>
IOException
InterruptedException
Copyright © 2011-2019 The Apache Software Foundation. All Rights Reserved.