Package | Description |
---|---|
org.apache.hive.hcatalog.streaming.mutate.worker |
Modifier and Type | Class and Description |
---|---|
class |
BucketIdException |
class |
GroupRevisitedException |
class |
PartitionCreationException |
class |
RecordSequenceException |
Modifier and Type | Method and Description |
---|---|
MutatorCoordinator |
MutatorCoordinatorBuilder.build()
Deprecated.
|
void |
MutatorCoordinator.delete(List<String> partitionValues,
Object record)
Deprecated.
We expect records grouped by (partitionValues,bucketId) and ordered by (origWriteId,rowId).
|
void |
MutatorCoordinator.insert(List<String> partitionValues,
Object record)
Deprecated.
We expect records grouped by (partitionValues,bucketId) and ordered by (origWriteId,rowId).
|
void |
MutatorCoordinator.update(List<String> partitionValues,
Object record)
Deprecated.
We expect records grouped by (partitionValues,bucketId) and ordered by (origWriteId,rowId).
|
Copyright © 2022 The Apache Software Foundation. All rights reserved.