Send feedback
Interface ChangeStreamRecordAdapter<ChangeStreamRecordT> (2.40.0)
Stay organized with collections
Save and categorize content based on your preferences.
Version 2.40.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 )
Internal Only : This feature is not stable for application use.
Intended for use by the BigtableIO in apache/beam only.
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
Returns
Type Description
String
getTokenFromHeartbeat(ChangeStreamRecordT heartbeatRecord)
public abstract String getTokenFromHeartbeat ( ChangeStreamRecordT heartbeatRecord )
Internal Only : This feature is not stable for application use.
Intended for use by the BigtableIO in apache/beam only.
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
Returns
Type Description
String
isChangeStreamMutation(ChangeStreamRecordT record)
public abstract boolean isChangeStreamMutation ( ChangeStreamRecordT record )
Internal Only : This feature is not stable for application use.
Intended for use by the BigtableIO in apache/beam only.
Checks if the given change stream record is a ChangeStreamMutation.
Parameter
Name Description
recordChangeStreamRecordT
isHeartbeat(ChangeStreamRecordT record)
public abstract boolean isHeartbeat ( ChangeStreamRecordT record )
Internal Only : This feature is not stable for application use.
Intended for use by the BigtableIO in apache/beam only.
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-12-19 UTC.
Need to tell us more?
[[["Easy to understand","easyToUnderstand","thumb-up"],["Solved my problem","solvedMyProblem","thumb-up"],["Other","otherUp","thumb-up"]],[["Hard to understand","hardToUnderstand","thumb-down"],["Incorrect information or sample code","incorrectInformationOrSampleCode","thumb-down"],["Missing the information/samples I need","missingTheInformationSamplesINeed","thumb-down"],["Other","otherDown","thumb-down"]],["Last updated 2024-12-19 UTC."],[],[]]
