org.apache.hive.hcatalog.data.transfer.impl

Class HCatOutputFormatWriter

java.lang.Object

org.apache.hive.hcatalog.data.transfer.HCatWriter

org.apache.hive.hcatalog.data.transfer.impl.HCatOutputFormatWriter

public class HCatOutputFormatWriter
extends HCatWriter

This writer writes via HCatOutputFormat

Field Summary

Fields inherited from class org.apache.hive.hcatalog.data.transfer.HCatWriter

conf, info, sp, we

Constructor Summary

Constructors

Constructor and Description
HCatOutputFormatWriter(WriteEntity we, Map<String,String> config)
HCatOutputFormatWriter(WriterContext cntxt, StateProvider sp)

Method Summary

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(Iterator<HCatRecord> recordItr) This method should be used at slave needs to perform writes.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

HCatOutputFormatWriter

public HCatOutputFormatWriter(WriteEntity we,
                              Map<String,String> config)

HCatOutputFormatWriter

public HCatOutputFormatWriter(WriterContext cntxt,
                              StateProvider sp)

Method Detail

prepareWrite

public WriterContext prepareWrite()
                           throws HCatException

Description copied from class: HCatWriter

External system should invoke this method exactly once from a master node.

Specified by:

prepareWrite in class HCatWriter

Returns:

WriterContext This should be serialized and sent to slave nodes to construct HCatWriter there.

Throws:

HCatException

write

public void write(Iterator<HCatRecord> recordItr)
           throws HCatException

Description copied from class: HCatWriter

This method should be used at slave needs to perform writes.

Specified by:

write in class HCatWriter

Parameters:

recordItr - Iterator records to be written into HCatalog.

Throws:

HCatException

commit

public void commit(WriterContext context)
            throws HCatException

Description copied from class: HCatWriter

This method should be called at master node. Primary purpose of this is to do metadata commit.

Specified by:

commit in class HCatWriter

Throws:

HCatException

abort

public void abort(WriterContext context)
           throws HCatException

Description copied from class: HCatWriter

This method should be called at master node. Primary purpose of this is to do cleanups in case of failures.

Specified by:

abort in class HCatWriter

Throws:

HCatException