Package io.debezium.pipeline.source.snapshot.incremental

Class AbstractIncrementalSnapshotContext.SnapshotDataCollection<T>

java.lang.Object

java.util.AbstractCollection<DataCollection<T>>

java.util.AbstractQueue<DataCollection<T>>

java.util.concurrent.LinkedBlockingQueue<DataCollection<T>>

io.debezium.pipeline.source.snapshot.incremental.AbstractIncrementalSnapshotContext.SnapshotDataCollection<T>

All Implemented Interfaces:

Serializable, Iterable<DataCollection<T>>, Collection<DataCollection<T>>, BlockingQueue<DataCollection<T>>, Queue<DataCollection<T>>

Enclosing class:

AbstractIncrementalSnapshotContext<T>

private static class AbstractIncrementalSnapshotContext.SnapshotDataCollection<T>
extends LinkedBlockingQueue<DataCollection<T>>

Field Summary

Fields

Modifier and Type	Field	Description
private final AbstractIncrementalSnapshotContext<T>	context
static final String	DATA_COLLECTIONS_TO_SNAPSHOT_KEY
static final String	DATA_COLLECTIONS_TO_SNAPSHOT_KEY_ADDITIONAL_CONDITION
static final String	DATA_COLLECTIONS_TO_SNAPSHOT_KEY_ID
static final String	DATA_COLLECTIONS_TO_SNAPSHOT_KEY_SURROGATE_KEY
private final Queue<DataCollection<T>>	dataCollectionsToSnapshot
private String	dataCollectionsToSnapshotJson
private final com.fasterxml.jackson.databind.ObjectMapper	mapper
private final com.fasterxml.jackson.core.type.TypeReference<List<LinkedHashMap<String,String>>>	mapperTypeRef

Constructor Summary

Constructors

Constructor	Description
SnapshotDataCollection(AbstractIncrementalSnapshotContext<T> context)

Method Summary

Modifier and Type	Method	Description
(package private) void	add(List<DataCollection<T>> dataCollectionIds)
void	clear()
private String	computeJsonString()
String	dataCollectionsAsJsonString()
Queue<DataCollection<T>>	getDataCollectionsToSnapshot()
(package private) DataCollection<T>	getNext()
boolean	isEmpty()
DataCollection<T>	peek()
boolean	remove(List<DataCollection<T>> toRemove)
int	size()
private List<DataCollection<T>>	stringToDataCollections(String dataCollectionsStr)

Methods inherited from class java.util.concurrent.LinkedBlockingQueue

contains, drainTo, drainTo, forEach, iterator, offer, offer, poll, poll, put, remainingCapacity, remove, removeAll, removeIf, retainAll, spliterator, take, toArray, toArray, toString

Methods inherited from class java.util.AbstractQueue

add, addAll, element, remove

Methods inherited from class java.util.AbstractCollection

containsAll

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.concurrent.BlockingQueue

add

Methods inherited from interface java.util.Collection

addAll, containsAll, equals, hashCode, parallelStream, stream, toArray

Methods inherited from interface java.util.Queue

element, remove

Field Details

DATA_COLLECTIONS_TO_SNAPSHOT_KEY

public static final String DATA_COLLECTIONS_TO_SNAPSHOT_KEY

See Also:

• Constant Field Values

DATA_COLLECTIONS_TO_SNAPSHOT_KEY_ID

public static final String DATA_COLLECTIONS_TO_SNAPSHOT_KEY_ID

See Also:

• Constant Field Values

DATA_COLLECTIONS_TO_SNAPSHOT_KEY_ADDITIONAL_CONDITION

public static final String DATA_COLLECTIONS_TO_SNAPSHOT_KEY_ADDITIONAL_CONDITION

See Also:

• Constant Field Values

DATA_COLLECTIONS_TO_SNAPSHOT_KEY_SURROGATE_KEY

public static final String DATA_COLLECTIONS_TO_SNAPSHOT_KEY_SURROGATE_KEY

See Also:

• Constant Field Values

mapper

private final com.fasterxml.jackson.databind.ObjectMapper mapper

mapperTypeRef

private final com.fasterxml.jackson.core.type.TypeReference<List<LinkedHashMap<String,String>>> mapperTypeRef

dataCollectionsToSnapshot

private final Queue<DataCollection<T>> dataCollectionsToSnapshot

context

private final AbstractIncrementalSnapshotContext<T> context

dataCollectionsToSnapshotJson

private String dataCollectionsToSnapshotJson

Constructor Details

SnapshotDataCollection

SnapshotDataCollection(AbstractIncrementalSnapshotContext<T> context)

Method Details

add

void add(List<DataCollection<T>> dataCollectionIds)

getNext

DataCollection<T> getNext()

peek

public DataCollection<T> peek()

Specified by:

peek in interface Queue<T>

Overrides:

peek in class LinkedBlockingQueue<DataCollection<T>>

size

public int size()

Specified by:

size in interface Collection<T>

Overrides:

size in class LinkedBlockingQueue<DataCollection<T>>

clear

public void clear()

Specified by:

clear in interface Collection<T>

Overrides:

clear in class LinkedBlockingQueue<DataCollection<T>>

isEmpty

public boolean isEmpty()

Specified by:

isEmpty in interface Collection<T>

Overrides:

isEmpty in class AbstractCollection<DataCollection<T>>

remove

public boolean remove(List<DataCollection<T>> toRemove)

dataCollectionsAsJsonString

public String dataCollectionsAsJsonString()

getDataCollectionsToSnapshot

public Queue<DataCollection<T>> getDataCollectionsToSnapshot()

computeJsonString

private String computeJsonString()

stringToDataCollections

private List<DataCollection<T>> stringToDataCollections(String dataCollectionsStr)