Package io.aiven.kafka.connect.azure.source

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

    Nested classes/interfaces inherited from class org.apache.kafka.connect.source.SourceTask

    org.apache.kafka.connect.source.SourceTask.TransactionBoundary

  • 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, TRANSACTION_BOUNDARY_CONFIG

  • Constructor Summary

    Constructors
    Modifier
    Constructor
    Description
     
    AzureBlobSourceTask()
    Constructor to set the Logger used.
    protected
    AzureBlobSourceTask(Iterator<AzureBlobSourceRecord> iterator)
    For testing access.

  • Method Summary

    Modifier and Type
    Method
    Description
    protected void
    closeResources()
     
    protected io.aiven.kafka.connect.common.config.SourceCommonConfig
    configure(Map<String,String> props)
     
    protected Iterator<org.apache.kafka.connect.source.SourceRecord>
    getIterator(io.aiven.kafka.connect.common.source.AbstractSourceTask.BackoffConfig config)
     
    String
    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, commitRecord, initialize

    Methods inherited from class java.lang.Object

    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

  • Constructor Details

    • AzureBlobSourceTask

      public AzureBlobSourceTask()
      Constructor to set the Logger used. This constructor is required by Connect.

    • AzureBlobSourceTask

      protected AzureBlobSourceTask(Iterator<AzureBlobSourceRecord> iterator)
      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 class io.aiven.kafka.connect.common.source.AbstractSourceTask

    • configure

      protected io.aiven.kafka.connect.common.config.SourceCommonConfig configure(Map<String,String> props)
      Specified by:
      configure in class io.aiven.kafka.connect.common.source.AbstractSourceTask

    • closeResources

      protected void closeResources()
      Specified by:
      closeResources in class io.aiven.kafka.connect.common.source.AbstractSourceTask

    • version

      public String version()