Index (azure-source-connector 3.5.0-SNAPSHOT API)

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