Uses of Class
io.aiven.commons.kafka.connector.source.task.Context

Packages that use Context

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
io.aiven.commons.kafka.connector.source.task

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

Methods in io.aiven.commons.kafka.connector.source that return Context

Modifier and Type	Method	Description
abstract Context	AbstractSourceNativeInfo.getContext()	Creates the context for the native info.
Context	EvolvingSourceRecord.getContext()	Gets the Context for this source record.

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

Modifier and Type	Method	Description
protected abstract OffsetManager.OffsetManagerEntry	NativeSourceData.createOffsetManagerEntry(Context context)	Creates an offset manager entry from a context.

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

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

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

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

Modifier and Type	Method	Description
InputStreamExtractor.StreamSpliterator	AvroExtractor.createSpliterator(org.apache.commons.io.function.IOSupplier<InputStream> inputStreamIOSupplier, long streamLength, Context context)
InputStreamExtractor.StreamSpliterator	ByteArrayExtractor.createSpliterator(org.apache.commons.io.function.IOSupplier<InputStream> inputStreamIOSupplier, long streamLength, Context context)
protected abstract InputStreamExtractor.StreamSpliterator	InputStreamExtractor.createSpliterator(org.apache.commons.io.function.IOSupplier<InputStream> inputStreamIOSupplier, long streamLength, Context context)	Creates the stream spliterator for this extractor.
InputStreamExtractor.StreamSpliterator	JsonExtractor.createSpliterator(org.apache.commons.io.function.IOSupplier<InputStream> inputStreamIOSupplier, long streamLength, Context context)
InputStreamExtractor.StreamSpliterator	ParquetExtractor.createSpliterator(org.apache.commons.io.function.IOSupplier<InputStream> inputStreamIOSupplier, long streamLength, Context context)

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

Methods in io.aiven.commons.kafka.connector.source.impl that return Context

Modifier and Type	Method	Description
Context	ExampleSourceNativeInfo.getContext()

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

Modifier and Type	Method	Description
protected OffsetManager.OffsetManagerEntry	ExampleNativeSourceData.createOffsetManagerEntry(Context context)

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

Methods in io.aiven.commons.kafka.connector.source.impl.csv that return Context

Modifier and Type	Method	Description
Context	ExampleCsvSourceNativeInfo.getContext()

Methods in io.aiven.commons.kafka.connector.source.impl.csv with parameters of type Context

Modifier and Type	Method	Description
protected OffsetManager.OffsetManagerEntry	ExampleCsvSourceData.createOffsetManagerEntry(Context context)

Uses of Context in io.aiven.commons.kafka.connector.source.task

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

Modifier and Type	Method	Description
Predicate<Context>	DistributionType.asPredicate(int maxTasks, int taskId)	Creates a context predicate from this distribution type.

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

Modifier	Constructor	Description
protected	Context(Context anotherContext)	Creates a defensive copy of the Context