@Deprecated 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 writeId,
org.apache.hadoop.fs.Path partitionPath,
int bucketProperty)
Deprecated.
|
Modifier and Type | Method and Description |
---|---|
void |
close()
Deprecated.
|
protected RecordUpdater |
createRecordUpdater(AcidOutputFormat<?,?> outputFormat)
Deprecated.
|
void |
delete(Object record)
Deprecated.
|
void |
flush()
Deprecated.
This implementation does intentionally nothing at this time.
|
void |
insert(Object record)
Deprecated.
|
String |
toString()
Deprecated.
|
void |
update(Object record)
Deprecated.
|
public MutatorImpl(org.apache.hadoop.conf.Configuration configuration, int recordIdColumn, ObjectInspector objectInspector, AcidOutputFormat<?,?> outputFormat, long writeId, org.apache.hadoop.fs.Path partitionPath, int bucketProperty) throws IOException
bucketProperty
- - from existing RecordIdentifier.getBucketProperty()
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 © 2022 The Apache Software Foundation. All rights reserved.