Class AzureBlobSourceTask
java.lang.Object
org.apache.kafka.connect.source.SourceTask
io.aiven.kafka.connect.common.source.AbstractSourceTask
io.aiven.kafka.connect.azure.source.AzureBlobSourceTask
- All Implemented Interfaces:
org.apache.kafka.connect.connector.Task
public class AzureBlobSourceTask
extends io.aiven.kafka.connect.common.source.AbstractSourceTask
-
Nested Class Summary
Nested classes/interfaces inherited from class io.aiven.kafka.connect.common.source.AbstractSourceTask
io.aiven.kafka.connect.common.source.AbstractSourceTask.AbortTrigger, io.aiven.kafka.connect.common.source.AbstractSourceTask.Backoff, io.aiven.kafka.connect.common.source.AbstractSourceTask.BackoffConfig, io.aiven.kafka.connect.common.source.AbstractSourceTask.SupplierOfLong, io.aiven.kafka.connect.common.source.AbstractSourceTask.Timer
-
Field Summary
Fields inherited from class io.aiven.kafka.connect.common.source.AbstractSourceTask
MAX_POLL_TIME, NULL_RESULT
Fields inherited from class org.apache.kafka.connect.source.SourceTask
context
-
Constructor Summary
ConstructorsModifierConstructorDescriptionConstructor to set the Logger used.protected
AzureBlobSourceTask
(Iterator<AzureBlobSourceRecord> iterator) For testing access. -
Method Summary
Modifier and TypeMethodDescriptionprotected void
protected io.aiven.kafka.connect.common.config.SourceCommonConfig
protected Iterator<org.apache.kafka.connect.source.SourceRecord>
getIterator
(io.aiven.kafka.connect.common.source.AbstractSourceTask.BackoffConfig config) version()
Methods inherited from class io.aiven.kafka.connect.common.source.AbstractSourceTask
isRunning, poll, start, stillPolling, stop
Methods inherited from class org.apache.kafka.connect.source.SourceTask
commit, commitRecord, initialize
-
Constructor Details
-
AzureBlobSourceTask
public AzureBlobSourceTask()Constructor to set the Logger used. This constructor is required by Connect. -
AzureBlobSourceTask
For testing access.- Parameters:
iterator
- the iterator to read.
-
-
Method Details
-
getIterator
protected Iterator<org.apache.kafka.connect.source.SourceRecord> getIterator(io.aiven.kafka.connect.common.source.AbstractSourceTask.BackoffConfig config) - Specified by:
getIterator
in classio.aiven.kafka.connect.common.source.AbstractSourceTask
-
configure
protected io.aiven.kafka.connect.common.config.SourceCommonConfig configure(Map<String, String> props) - Specified by:
configure
in classio.aiven.kafka.connect.common.source.AbstractSourceTask
-
closeResources
protected void closeResources()- Specified by:
closeResources
in classio.aiven.kafka.connect.common.source.AbstractSourceTask
-
version
-