HCatWriter
insteadpublic abstract class HCatWriter
extends java.lang.Object
DataTransferFactory
Modifier and Type | Field and Description |
---|---|
protected Configuration |
conf
Deprecated.
|
protected WriterContext |
info
Deprecated.
|
protected StateProvider |
sp
Deprecated.
|
protected WriteEntity |
we
Deprecated.
|
Modifier | Constructor and Description |
---|---|
protected |
HCatWriter(Configuration config,
StateProvider sp)
Deprecated.
This constructor will be used at slave nodes.
|
protected |
HCatWriter(WriteEntity we,
java.util.Map<java.lang.String,java.lang.String> config)
Deprecated.
This constructor will be used at master node
|
Modifier and Type | Method and Description |
---|---|
abstract void |
abort(WriterContext context)
Deprecated.
This method should be called at master node.
|
abstract void |
commit(WriterContext context)
Deprecated.
This method should be called at master node.
|
abstract WriterContext |
prepareWrite()
Deprecated.
External system should invoke this method exactly once from a master node.
|
abstract void |
write(java.util.Iterator<HCatRecord> recordItr)
Deprecated.
This method should be used at slave needs to perform writes.
|
protected Configuration conf
protected WriteEntity we
protected WriterContext info
protected StateProvider sp
protected HCatWriter(WriteEntity we, java.util.Map<java.lang.String,java.lang.String> config)
we
- WriteEntity defines where in storage records should be written to.config
- Any configuration which external system wants to communicate to
HCatalog for performing writes.protected HCatWriter(Configuration config, StateProvider sp)
config
- public abstract WriterContext prepareWrite() throws HCatException
WriterContext
This should be serialized and sent to slave
nodes to construct HCatWriter there.HCatException
public abstract void write(java.util.Iterator<HCatRecord> recordItr) throws HCatException
recordItr
- Iterator
records to be written into HCatalog.{@link
- HCatException}HCatException
public abstract void commit(WriterContext context) throws HCatException
{@link
- HCatException}HCatException
public abstract void abort(WriterContext context) throws HCatException
{@link
- HCatException} *HCatException
Copyright © 2012 The Apache Software Foundation