public class HCatOutputFormatWriter extends HCatWriter
HCatOutputFormat
conf, info, sp, we
Constructor and Description |
---|
HCatOutputFormatWriter(Configuration config,
StateProvider sp) |
HCatOutputFormatWriter(WriteEntity we,
java.util.Map<java.lang.String,java.lang.String> config) |
Modifier and Type | Method and Description |
---|---|
void |
abort(WriterContext context)
This method should be called at master node.
|
void |
commit(WriterContext context)
This method should be called at master node.
|
WriterContext |
prepareWrite()
External system should invoke this method exactly once from a master node.
|
void |
write(java.util.Iterator<HCatRecord> recordItr)
This method should be used at slave needs to perform writes.
|
public HCatOutputFormatWriter(WriteEntity we, java.util.Map<java.lang.String,java.lang.String> config)
public HCatOutputFormatWriter(Configuration config, StateProvider sp)
public WriterContext prepareWrite() throws HCatException
HCatWriter
prepareWrite
in class HCatWriter
WriterContext
This should be serialized and sent to slave
nodes to construct HCatWriter there.HCatException
public void write(java.util.Iterator<HCatRecord> recordItr) throws HCatException
HCatWriter
write
in class HCatWriter
recordItr
- Iterator
records to be written into HCatalog.HCatException
public void commit(WriterContext context) throws HCatException
HCatWriter
commit
in class HCatWriter
HCatException
public void abort(WriterContext context) throws HCatException
HCatWriter
abort
in class HCatWriter
HCatException
Copyright © 2012 The Apache Software Foundation