public class OrcRecordUpdater extends Object implements RecordUpdater
row
coming in (as in insert(long, Object)
for example), is a struct like #createEventSchema(ObjectInspector)
)
So there are OIs here to make the translation.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.
|
String |
toString() |
void |
update(long currentWriteId,
Object row)
Update an old record with a new set of values.
|
public void insert(long currentWriteId, Object row) throws IOException
RecordUpdater
insert
in interface RecordUpdater
currentWriteId
- the table write id of the current transaction.row
- the row of data to insertIOException
public void update(long currentWriteId, Object row) throws IOException
RecordUpdater
update
in interface RecordUpdater
currentWriteId
- the current write idrow
- the new values for the rowIOException
public void delete(long currentWriteId, Object row) throws IOException
RecordUpdater
delete
in interface RecordUpdater
currentWriteId
- the current write idIOException
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
public long getBufferedRowCount()
RecordUpdater
getBufferedRowCount
in interface RecordUpdater
Copyright © 2022 The Apache Software Foundation. All rights reserved.