Send feedback
Interface ChangeStreamRecordAdapter<ChangeStreamRecordT> (2.23.0)
Stay organized with collections
Save and categorize content based on your preferences.
Version 2.23.0 keyboard_arrow_down
public interface ChangeStreamRecordAdapter<ChangeStreamRecordT>
An extension point that allows end users to plug in a custom implementation of logical change
stream records. This is useful in cases where the user would like to apply advanced client side
filtering(for example, only keep DeleteFamily in the mutations). This adapter acts like a factory
for a SAX style change stream record builder.
Type Parameter Name Description ChangeStreamRecordT
Methods
createChangeStreamRecordBuilder()
public abstract ChangeStreamRecordAdapter.ChangeStreamRecordBuilder<ChangeStreamRecordT> createChangeStreamRecordBuilder()
getTokenFromChangeStreamMutation(ChangeStreamRecordT record)
public abstract String getTokenFromChangeStreamMutation(ChangeStreamRecordT record)
Get the token from the given ChangeStreamMutation record. If the given record is not a
ChangeStreamMutation, it will throw an Exception.
Parameter Name Description recordChangeStreamRecordT
getTokenFromHeartbeat(ChangeStreamRecordT heartbeatRecord)
public abstract String getTokenFromHeartbeat(ChangeStreamRecordT heartbeatRecord)
Get the token from the given Heartbeat record. If the given record is not a Heartbeat, it will
throw an Exception.
Parameter Name Description heartbeatRecordChangeStreamRecordT
isChangeStreamMutation(ChangeStreamRecordT record)
public abstract boolean isChangeStreamMutation(ChangeStreamRecordT record)
Checks if the given change stream record is a ChangeStreamMutation.
Parameter Name Description recordChangeStreamRecordT
isHeartbeat(ChangeStreamRecordT record)
public abstract boolean isHeartbeat(ChangeStreamRecordT record)
Checks if the given change stream record is a Heartbeat.
Parameter Name Description recordChangeStreamRecordT
Send feedback
Except as otherwise noted, the content of this page is licensed under the Creative Commons Attribution 4.0 License , and code samples are licensed under the Apache 2.0 License . For details, see the Google Developers Site Policies . Java is a registered trademark of Oracle and/or its affiliates.
Last updated 2024-04-02 UTC.
[{
"type": "thumb-down",
"id": "hardToUnderstand",
"label":"Hard to understand"
},{
"type": "thumb-down",
"id": "incorrectInformationOrSampleCode",
"label":"Incorrect information or sample code"
},{
"type": "thumb-down",
"id": "missingTheInformationSamplesINeed",
"label":"Missing the information/samples I need"
},{
"type": "thumb-down",
"id": "otherDown",
"label":"Other"
}]
[{
"type": "thumb-up",
"id": "easyToUnderstand",
"label":"Easy to understand"
},{
"type": "thumb-up",
"id": "solvedMyProblem",
"label":"Solved my problem"
},{
"type": "thumb-up",
"id": "otherUp",
"label":"Other"
}]
Need to tell us more?
