[CASSANDRA-11957] Implement seek() of org.apache.cassandra.db.commitlog.EncryptedFileSegmentInputStream

• Type: Improvement
• Status: Resolved
• Priority: Urgent
• Resolution: Fixed
• Fix Version/s: 3.8
• Component/s: Legacy/Coordination, Legacy/Local Write-Read Paths
• Assignee: Imran Chaudhry
• Reporter: Imran Chaudhry

Authors

Imran Chaudhry

Reviewers

Joshua McKenzie

• Tester: Joshua McKenzie
• Created: 03/Jun/16 22:21
• Updated: 16/Apr/19 09:30
• Resolved: 21/Jun/16 19:50

Description

CDC needs the seek() method of org.apache.cassandra.db.commitlog.EncryptedFileSegmentInputStream implemented (currently throws an exception.)

CommitLogs are read using this stream and the seek() method needs to be implemented so that mutations which are appended to the currently active commitlog can be read out in realtime.

Current implementation is:

public void seek(long position)

{ // implement this when we actually need it throw new UnsupportedOperationException(); }

Issue Links

• relates to: CASSANDRA-8844 Change Data Capture (CDC)