org.apache.hadoop.hive.ql.io

Interface RecordUpdater

All Known Implementing Classes:

OrcRecordUpdater

public interface RecordUpdater

API for supporting updating records.

Method Summary

Modifier and Type	Method and Description
void	close(boolean abort) Close this updater.
void	delete(long currentWriteId, Object row) 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.
long	getBufferedRowCount() Returns the number of rows in memory before flush().
SerDeStats	getStats() Returns the statistics information
void	insert(long currentWriteId, Object row) Insert a new record into the table.
void	update(long currentWriteId, Object row) Update an old record with a new set of values.

Method Detail

insert

void insert(long currentWriteId,
            Object row)
     throws IOException

Insert a new record into the table.

Parameters:

currentWriteId - the table write id of the current transaction.

row - the row of data to insert

Throws:

IOException

update

void update(long currentWriteId,
            Object row)
     throws IOException

Update an old record with a new set of values.

Parameters:

currentWriteId - the current write id

row - the new values for the row

Throws:

IOException

delete

void delete(long currentWriteId,
            Object row)
     throws IOException

Delete a row from the table.

Parameters:

currentWriteId - the current write id

Throws:

IOException

flush

void flush()
    throws IOException

Flush the current set of rows to the underlying file system, so that they are available to readers. Most implementations will need to write additional state information when this is called, so it should only be called during streaming when a transaction is finished, but the RecordUpdater can't be closed yet.

Throws:

IOException

close

void close(boolean abort)
    throws IOException

Close this updater. No further calls are legal after this.

Parameters:

abort - Can the data since the last flush be discarded?

Throws:

IOException

getStats

SerDeStats getStats()

Returns the statistics information

Returns:

SerDeStats

getBufferedRowCount

long getBufferedRowCount()

Returns the number of rows in memory before flush().

Returns:

- buffered row count