public class MutatorImpl extends Object implements Mutator
Mutator
implementation. Creates a suitable RecordUpdater
and delegates mutation events.Constructor and Description |
---|
MutatorImpl(org.apache.hadoop.conf.Configuration configuration,
int recordIdColumn,
ObjectInspector objectInspector,
AcidOutputFormat<?,?> outputFormat,
long transactionId,
org.apache.hadoop.fs.Path partitionPath,
int bucketId) |
Modifier and Type | Method and Description |
---|---|
void |
close() |
protected RecordUpdater |
createRecordUpdater(AcidOutputFormat<?,?> outputFormat) |
void |
delete(Object record) |
void |
flush()
This implementation does intentionally nothing at this time.
|
void |
insert(Object record) |
String |
toString() |
void |
update(Object record) |
public MutatorImpl(org.apache.hadoop.conf.Configuration configuration, int recordIdColumn, ObjectInspector objectInspector, AcidOutputFormat<?,?> outputFormat, long transactionId, org.apache.hadoop.fs.Path partitionPath, int bucketId) throws IOException
IOException
public void insert(Object record) throws IOException
insert
in interface Mutator
IOException
public void update(Object record) throws IOException
update
in interface Mutator
IOException
public void delete(Object record) throws IOException
delete
in interface Mutator
IOException
public void flush() throws IOException
OrcRecordUpdater.flush()
will purposefully throw and exception in this instance. We keep this here in the
event that we support multiple transactions and to make it clear that the omission of an invocation of
OrcRecordUpdater.flush()
was not a mistake.flush
in interface Flushable
flush
in interface Mutator
IOException
public void close() throws IOException
close
in interface Closeable
close
in interface AutoCloseable
IOException
protected RecordUpdater createRecordUpdater(AcidOutputFormat<?,?> outputFormat) throws IOException
IOException
Copyright © 2016 The Apache Software Foundation. All rights reserved.