Index

A B C D E F G H I R S T U V 
All Classes and Interfaces|All Packages|Constant Field Values

A

asKey(String, String) - Static method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
 
AZURE_FETCH_PAGE_SIZE - Static variable in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
AZURE_PREFIX_CONFIG - Static variable in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
AZURE_RETRY_BACKOFF_INITIAL_DELAY_MS_CONFIG - Static variable in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
AZURE_RETRY_BACKOFF_INITIAL_DELAY_MS_DEFAULT - Static variable in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
AZURE_RETRY_BACKOFF_MAX_ATTEMPTS_CONFIG - Static variable in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
AZURE_RETRY_BACKOFF_MAX_ATTEMPTS_DEFAULT - Static variable in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
AZURE_RETRY_BACKOFF_MAX_DELAY_MS_CONFIG - Static variable in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
AZURE_RETRY_BACKOFF_MAX_DELAY_MS_DEFAULT - Static variable in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
AZURE_STORAGE_CONNECTION_STRING_CONFIG - Static variable in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
AZURE_STORAGE_CONTAINER_NAME_CONFIG - Static variable in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
AZURE_USER_AGENT - Static variable in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
AzureBlobClient - Class in io.aiven.kafka.connect.azure.source.utils
AzureBlobClient is a class that handles communication with the Azure blob source system/ It handles authentication, querying and downloading of data from Azure in an Async manner.
AzureBlobClient(AzureBlobSourceConfig) - Constructor for class io.aiven.kafka.connect.azure.source.utils.AzureBlobClient
 
AzureBlobConfigFragment - Class in io.aiven.kafka.connect.azure.source.config
The configuration fragment that defines the Azure specific characteristics.
AzureBlobConfigFragment(AbstractConfig) - Constructor for class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
Construct the Azure Blob ConfigFragment..
AzureBlobOffsetManagerEntry - Class in io.aiven.kafka.connect.azure.source.utils
 
AzureBlobOffsetManagerEntry(String, String) - Constructor for class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
Construct the AzureOffsetManagerEntry.
AzureBlobSourceConfig - Class in io.aiven.kafka.connect.azure.source.config
 
AzureBlobSourceConfig(Map<?, ?>) - Constructor for class io.aiven.kafka.connect.azure.source.config.AzureBlobSourceConfig
 
AzureBlobSourceConfigDef - Class in io.aiven.kafka.connect.azure.source.config
 
AzureBlobSourceConfigDef() - Constructor for class io.aiven.kafka.connect.azure.source.config.AzureBlobSourceConfigDef
 
AzureBlobSourceConnector - Class in io.aiven.kafka.connect.azure.source
AzureBlobSourceConnector is a Kafka Connect Connector implementation that watches an azure blob container and generates tasks to ingest contents.
AzureBlobSourceConnector() - Constructor for class io.aiven.kafka.connect.azure.source.AzureBlobSourceConnector
 
AzureBlobSourceRecord - Class in io.aiven.kafka.connect.azure.source.utils
 
AzureBlobSourceRecord(BlobItem) - Constructor for class io.aiven.kafka.connect.azure.source.utils.AzureBlobSourceRecord
 
AzureBlobSourceRecordIterator - Class in io.aiven.kafka.connect.azure.source.utils
Iterator that processes Azure Blob files and creates Kafka source records.
AzureBlobSourceRecordIterator(AzureBlobSourceConfig, OffsetManager<AzureBlobOffsetManagerEntry>, Transformer, AzureBlobClient) - Constructor for class io.aiven.kafka.connect.azure.source.utils.AzureBlobSourceRecordIterator
 
AzureBlobSourceTask - Class in io.aiven.kafka.connect.azure.source
 
AzureBlobSourceTask() - Constructor for class io.aiven.kafka.connect.azure.source.AzureBlobSourceTask
Constructor to set the Logger used.
AzureBlobSourceTask(Iterator<AzureBlobSourceRecord>) - Constructor for class io.aiven.kafka.connect.azure.source.AzureBlobSourceTask
For testing access.

B

BLOB_NAME - Static variable in class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
 

C

closeResources() - Method in class io.aiven.kafka.connect.azure.source.AzureBlobSourceTask
 
compareTo(AzureBlobOffsetManagerEntry) - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
 
config() - Method in class io.aiven.kafka.connect.azure.source.AzureBlobSourceConnector
 
configDef() - Static method in class io.aiven.kafka.connect.azure.source.config.AzureBlobSourceConfig
 
configure(Map<String, String>) - Method in class io.aiven.kafka.connect.azure.source.AzureBlobSourceTask
 
CONTAINER - Static variable in class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
 
createOffsetManagerEntry(BlobItem) - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobSourceRecordIterator
 
createSourceRecord(BlobItem) - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobSourceRecordIterator
 

D

duplicate() - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobSourceRecord
 

E

equals(Object) - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
 

F

fromProperties(Map<String, Object>) - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
Creates an AzureOffsetManagerEntry.

G

getAzureBlobStream(String) - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobClient
returns a stream of BlobItems listing each object in lexical order.
getAzureContainerName() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobSourceConfig
 
getAzureFetchPageSize() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
getAzureFetchPageSize() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobSourceConfig
 
getAzurePrefix() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
getAzurePrefix() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobSourceConfig
 
getAzureRetryBackoffInitialDelay() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
getAzureRetryBackoffMaxAttempts() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
getAzureRetryBackoffMaxDelay() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
getAzureRetryOptions() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
getAzureServiceAsyncClient() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
Creates an async Service Client which can be used to create async container and blob clients, which can list and download blobs respectively.
getAzureServiceAsyncClient() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobSourceConfig
 
getBlob(String) - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobClient
 
getConnectionString() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
getContainer() - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
Gets the Azure container for the current object.
getContainerName() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
getFetchBufferSize() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
getFetchBufferSize() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobSourceConfig
 
getInputStream(AzureBlobSourceRecord) - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobSourceRecordIterator
 
getIterator(AbstractSourceTask.BackoffConfig) - Method in class io.aiven.kafka.connect.azure.source.AzureBlobSourceTask
 
getKey() - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
Gets the blob name for the current object.
getLogger() - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobSourceRecordIterator
 
getManagerKey() - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
Returns the OffsetManagerKey for this Entry.
getNativeItemStream(String) - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobSourceRecordIterator
 
getNativeKey(BlobItem) - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobSourceRecordIterator
 
getOffsetManagerKey(String) - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobSourceRecordIterator
 
getProperties() - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
Creates a new offset map.
getProperty(String) - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
 
getRecordCount() - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
Gets the umber of records extracted from data returned from Azure Blob.
getSpecTitle() - Method in class io.aiven.kafka.connect.azure.source.utils.VersionInfo
Gets the specification title of the package.
getSpecVendor() - Method in class io.aiven.kafka.connect.azure.source.utils.VersionInfo
Gets the specification vendor of the package.
getSpecVersion() - Method in class io.aiven.kafka.connect.azure.source.utils.VersionInfo
Gets the specification version of the package.
getTitle() - Method in class io.aiven.kafka.connect.azure.source.utils.VersionInfo
Gets the implementation title of the package.
getUserAgent() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
getVendor() - Method in class io.aiven.kafka.connect.azure.source.utils.VersionInfo
Gets the implementation vendor of the package.
getVersion() - Method in class io.aiven.kafka.connect.azure.source.utils.VersionInfo
Gets the implementation version of the package.

H

hashCode() - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
 

I

incrementRecordCount() - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
 
io.aiven.kafka.connect.azure.source - package io.aiven.kafka.connect.azure.source
 
io.aiven.kafka.connect.azure.source.config - package io.aiven.kafka.connect.azure.source.config
 
io.aiven.kafka.connect.azure.source.utils - package io.aiven.kafka.connect.azure.source.utils
 

R

RECORD_COUNT - Static variable in class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
 

S

setProperty(String, Object) - Method in class io.aiven.kafka.connect.azure.source.utils.AzureBlobOffsetManagerEntry
 
start(Map<String, String>) - Method in class io.aiven.kafka.connect.azure.source.AzureBlobSourceConnector
 
stop() - Method in class io.aiven.kafka.connect.azure.source.AzureBlobSourceConnector
 

T

taskClass() - Method in class io.aiven.kafka.connect.azure.source.AzureBlobSourceConnector
 
taskConfigs(int) - Method in class io.aiven.kafka.connect.azure.source.AzureBlobSourceConnector
 
toString() - Method in class io.aiven.kafka.connect.azure.source.utils.VersionInfo
Default string representation of the implementation information from the package.

U

update(ConfigDef) - Static method in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
Adds the configuration options for the azure client to the configuration definition.
USER_AGENT_HEADER_VALUE - Static variable in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 

V

validate() - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobConfigFragment
 
validate(Map<String, String>) - Method in class io.aiven.kafka.connect.azure.source.config.AzureBlobSourceConfigDef
 
version() - Method in class io.aiven.kafka.connect.azure.source.AzureBlobSourceConnector
 
version() - Method in class io.aiven.kafka.connect.azure.source.AzureBlobSourceTask
 
VersionInfo - Class in io.aiven.kafka.connect.azure.source.utils
This class was originally developed by the Apache RAT project A formatter for Package information about a class.
VersionInfo() - Constructor for class io.aiven.kafka.connect.azure.source.utils.VersionInfo
Constructor that uses the VersionInfo package for information.
VersionInfo(Class<?>) - Constructor for class io.aiven.kafka.connect.azure.source.utils.VersionInfo
Constructor for a specific class.
A B C D E F G H I R S T U V 
All Classes and Interfaces|All Packages|Constant Field Values