Package co.decodable.sdk.pipeline

Class DecodableDebeziumEnvelope<V>

java.lang.Object

co.decodable.sdk.pipeline.DecodableDebeziumEnvelope<V>

Type Parameters:

V - The value data type in a change stream record

public class DecodableDebeziumEnvelope<V>
extends Object

Base class to represent any custom POJO value type wrapped in a Debezium CDC envelope.

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	DecodableDebeziumEnvelope.CDC_OP_TYPE

Constructor Summary

Constructors

Constructor	Description
DecodableDebeziumEnvelope()
DecodableDebeziumEnvelope(V before, V after, String op, long ts_ms)

Method Summary

Modifier and Type	Method	Description
boolean	equals(Object o)
V	getAfter()
V	getBefore()
String	getOp()
long	getTs_ms()
int	hashCode()
void	setAfter(V after)
void	setBefore(V before)
void	setOp(String op)
void	setTs_ms(long ts_ms)
String	toString()
V	unwrap()

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

DecodableDebeziumEnvelope

public DecodableDebeziumEnvelope()

DecodableDebeziumEnvelope

public DecodableDebeziumEnvelope(V before,
 V after,
 String op,
 long ts_ms)

Method Details

unwrap

public V unwrap()

getBefore

public V getBefore()

setBefore

public void setBefore(V before)

getAfter

public V getAfter()

setAfter

public void setAfter(V after)

getOp

public String getOp()

setOp

public void setOp(String op)

getTs_ms

public long getTs_ms()

setTs_ms

public void setTs_ms(long ts_ms)

toString

public String toString()

Overrides:

toString in class Object

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object