|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |
java.lang.Object org.apache.hadoop.hive.ql.io.orc.OrcRecordUpdater
public class OrcRecordUpdater
A RecordUpdater where the files are stored as ORC.
Nested Class Summary | |
---|---|
static class |
OrcRecordUpdater.OrcOptions
An extension to AcidOutputFormat that allows users to add additional options. |
Field Summary | |
---|---|
static String |
ACID_FORMAT
|
static String |
ACID_KEY_INDEX_NAME
|
static String |
ACID_STATS
|
static int |
ORC_ACID_VERSION
|
Method Summary | |
---|---|
void |
close(boolean abort)
Close this updater. |
void |
delete(long currentTransaction,
long originalTransaction,
long rowId)
Delete a row from the table. |
void |
flush()
Flush the current set of rows to the underlying file system, so that they are available to readers. |
SerDeStats |
getStats()
Returns the statistics information |
void |
insert(long currentTransaction,
Object row)
Insert a new record into the table. |
void |
update(long currentTransaction,
long originalTransaction,
long rowId,
Object row)
Update an old record with a new set of values. |
Methods inherited from class java.lang.Object |
---|
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
Field Detail |
---|
public static final String ACID_KEY_INDEX_NAME
public static final String ACID_FORMAT
public static final String ACID_STATS
public static final int ORC_ACID_VERSION
Method Detail |
---|
public void insert(long currentTransaction, Object row) throws IOException
RecordUpdater
insert
in interface RecordUpdater
currentTransaction
- the transaction id of the current transaction.row
- the row of data to insert
IOException
public void update(long currentTransaction, long originalTransaction, long rowId, Object row) throws IOException
RecordUpdater
update
in interface RecordUpdater
currentTransaction
- the current transaction idoriginalTransaction
- the row's original transaction idrowId
- the original row idrow
- the new values for the row
IOException
public void delete(long currentTransaction, long originalTransaction, long rowId) throws IOException
RecordUpdater
delete
in interface RecordUpdater
currentTransaction
- the current transaction idoriginalTransaction
- the rows original transaction idrowId
- the original row id
IOException
public void flush() throws IOException
RecordUpdater
flush
in interface RecordUpdater
IOException
public void close(boolean abort) throws IOException
RecordUpdater
close
in interface RecordUpdater
abort
- Can the data since the last flush be discarded?
IOException
public SerDeStats getStats()
RecordUpdater
getStats
in interface RecordUpdater
|
||||||||||
PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD |