phoenix
phoenix copied to clipboard
Phoenix-7632 Adding ReplicationLogProcessor Component
JIRA - PHOENIX-7632
Adding the ReplicationLogProcessor component, that accepts a single replication log file, process mutations in configurable batch size and apply them to HBase table via async client. The Replication Log Discovery (to be added as part of PHOENIX-7568) would list the log files and use ReplicationLogProcessor to read and apply the mutations to respective HBase table.
The Discovery and Tracking (Marking file in-progrss / deletion after successful processing) will be done as part of PHOENIX-7568.