Uses of Class
io.aiven.commons.kafka.connector.source.task.Context
Packages that use Context
Package
Description
-
Uses of Context in io.aiven.commons.kafka.connector.source
Methods in io.aiven.commons.kafka.connector.source that return ContextModifier and TypeMethodDescriptionabstract ContextAbstractSourceNativeInfo.getContext()Creates the context for the native info.EvolvingSourceRecord.getContext()Gets the Context for this source record.Methods in io.aiven.commons.kafka.connector.source with parameters of type ContextModifier and TypeMethodDescriptionprotected abstract OffsetManager.OffsetManagerEntryNativeSourceData.createOffsetManagerEntry(Context context) Creates an offset manager entry from a context.Constructors in io.aiven.commons.kafka.connector.source with parameters of type ContextModifierConstructorDescriptionEvolvingSourceRecord(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 ContextModifier and TypeMethodDescriptionAvroExtractor.createSpliterator(org.apache.commons.io.function.IOSupplier<InputStream> inputStreamIOSupplier, long streamLength, Context context) ByteArrayExtractor.createSpliterator(org.apache.commons.io.function.IOSupplier<InputStream> inputStreamIOSupplier, long streamLength, Context context) protected abstract InputStreamExtractor.StreamSpliteratorInputStreamExtractor.createSpliterator(org.apache.commons.io.function.IOSupplier<InputStream> inputStreamIOSupplier, long streamLength, Context context) Creates the stream spliterator for this extractor.JsonExtractor.createSpliterator(org.apache.commons.io.function.IOSupplier<InputStream> inputStreamIOSupplier, long streamLength, Context context) ParquetExtractor.createSpliterator(org.apache.commons.io.function.IOSupplier<InputStream> inputStreamIOSupplier, long streamLength, 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 ContextModifier and TypeMethodDescriptionDistributionType.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