Uses of Class
io.aiven.commons.kafka.connector.source.AbstractSourceNativeInfo

Packages that use AbstractSourceNativeInfo

Package	Description
io.aiven.commons.kafka.connector.source
io.aiven.commons.kafka.connector.source.extractor
io.aiven.commons.kafka.connector.source.impl	This package contains simple example implementations of the generic objects for EvolvingSourceRecord and EvolvingSourceRecordIterator.
io.aiven.commons.kafka.connector.source.impl.csv

Uses of AbstractSourceNativeInfo in io.aiven.commons.kafka.connector.source

Methods in io.aiven.commons.kafka.connector.source with type parameters of type AbstractSourceNativeInfo

Modifier and Type	Method	Description
<T extends AbstractSourceNativeInfo<?, ?>> T	EvolvingSourceRecord.getSourceNativeInfo()	Gets the AbstractNativeSource info from the constructor.

Methods in io.aiven.commons.kafka.connector.source that return types with arguments of type AbstractSourceNativeInfo

Modifier and Type	Method	Description
protected abstract Iterator<? extends AbstractSourceNativeInfo<K,?>>	NativeSourceData.getNativeItemIterator(K startFrom)	Get an iterator of Native objects from the underlying storage layer.

Methods in io.aiven.commons.kafka.connector.source with parameters of type AbstractSourceNativeInfo

Modifier and Type	Method	Description
int	AbstractSourceNativeInfo.compareTo(AbstractSourceNativeInfo<K,N> other)

Constructors in io.aiven.commons.kafka.connector.source with parameters of type AbstractSourceNativeInfo

Modifier	Constructor	Description
	EvolvingSourceRecord(AbstractSourceNativeInfo<?,?> sourceNativeInfo, OffsetManager.OffsetManagerEntry offsetManagerEntry, Context context)	Construct a source record from a native item.

Uses of AbstractSourceNativeInfo in io.aiven.commons.kafka.connector.source.extractor

Methods in io.aiven.commons.kafka.connector.source.extractor with parameters of type AbstractSourceNativeInfo

Modifier and Type	Method	Description
protected EvolvingSourceRecord	IOExtractorTest.createExampleSourceRecord(AbstractSourceNativeInfo<?,?> nativeItem)	Creates an EvolvingSourceRecord with the Context of OffsetManagerEntry as would be set by the EvolvingSourceRecordIterator processes.

Uses of AbstractSourceNativeInfo in io.aiven.commons.kafka.connector.source.impl

Subclasses of AbstractSourceNativeInfo in io.aiven.commons.kafka.connector.source.impl

Modifier and Type	Class	Description
class	ExampleSourceNativeInfo	This example data object has a String key and a byte buffer as its data object.

Uses of AbstractSourceNativeInfo in io.aiven.commons.kafka.connector.source.impl.csv

Subclasses of AbstractSourceNativeInfo in io.aiven.commons.kafka.connector.source.impl.csv

Modifier and Type	Class	Description
class	ExampleCsvSourceNativeInfo	This example data object has a String key and a byte buffer as its data object.