com.github.jcustenborder.kafka.connect.utils.data

Interface SourceRecordDeque

All Superinterfaces:

Collection<org.apache.kafka.connect.source.SourceRecord>, Deque<org.apache.kafka.connect.source.SourceRecord>, Iterable<org.apache.kafka.connect.source.SourceRecord>, Queue<org.apache.kafka.connect.source.SourceRecord>

public interface SourceRecordDeque
extends Deque<org.apache.kafka.connect.source.SourceRecord>

Method Summary

Modifier and Type	Method and Description
List<org.apache.kafka.connect.source.SourceRecord>	drain() Deprecated.
boolean	drain(List<org.apache.kafka.connect.source.SourceRecord> records) Deprecated.
boolean	drain(List<org.apache.kafka.connect.source.SourceRecord> records, int emptyWaitMs) Deprecated.
List<org.apache.kafka.connect.source.SourceRecord>	getBatch() Method will create a new list based on the batch size and drain records to it.
List<org.apache.kafka.connect.source.SourceRecord>	getBatch(int emptyWaitMs) Method will create a new list based on the batch size and drain records to it.
List<org.apache.kafka.connect.source.SourceRecord>	newList() Method returns a new list that has an initial capacity of the batch size the deque is configured for.

Methods inherited from interface java.util.Deque

add, addFirst, addLast, contains, descendingIterator, element, getFirst, getLast, iterator, offer, offerFirst, offerLast, peek, peekFirst, peekLast, poll, pollFirst, pollLast, pop, push, remove, remove, removeFirst, removeFirstOccurrence, removeLast, removeLastOccurrence, size

Methods inherited from interface java.util.Collection

addAll, clear, containsAll, equals, hashCode, isEmpty, parallelStream, removeAll, removeIf, retainAll, spliterator, stream, toArray, toArray

Methods inherited from interface java.lang.Iterable

forEach

Method Detail

newList

List<org.apache.kafka.connect.source.SourceRecord> newList()

Method returns a new list that has an initial capacity of the batch size the deque is configured for.

Returns:

New list with an initial capacity at the batch size.

drain

@Deprecated
List<org.apache.kafka.connect.source.SourceRecord> drain()

Deprecated.

Method will create a new list based on the batch size and drain records to it.

Returns:

getBatch

List<org.apache.kafka.connect.source.SourceRecord> getBatch(int emptyWaitMs)

Method will create a new list based on the batch size and drain records to it.

Returns:

getBatch

List<org.apache.kafka.connect.source.SourceRecord> getBatch()

Method will create a new list based on the batch size and drain records to it.

Returns:

drain

@Deprecated
boolean drain(List<org.apache.kafka.connect.source.SourceRecord> records)

Deprecated.

Method is used drain the records from the queue to the supplied list. newList() should be called to create a list that has the same initial capacity of the batch size.

Parameters:

records - List to append the records to.

Returns:

true if records were drained. false if not.

drain

@Deprecated
boolean drain(List<org.apache.kafka.connect.source.SourceRecord> records,
                          int emptyWaitMs)

Deprecated.

Method is used drain the records from the queue to the supplied list. newList() should be called to create a list that has the same initial capacity of the batch size.

Parameters:

records - List to append the records to.

emptyWaitMs - Time in milliseconds to wait if no records were drained.

Returns:

true if records were drained. false if not.