com.adaptris.interlok.azure

Class DataLakeConnection

java.lang.Object

com.adaptris.core.AdaptrisConnectionImp

com.adaptris.interlok.azure.AzureConnection<com.azure.storage.file.datalake.DataLakeServiceClient>

com.adaptris.interlok.azure.DataLakeConnection

All Implemented Interfaces:

AdaptrisComponent, AdaptrisConnection, ComponentLifecycle, ComponentLifecycleExtension, StateManagedComponent

@ComponentProfile(summary="Connect to an Azure tenant and access the Data Lake",
                  tag="connections,azure,data lake,data,lake")
public class DataLakeConnection
extends AzureConnection<com.azure.storage.file.datalake.DataLakeServiceClient>

Field Summary

Fields inherited from class com.adaptris.interlok.azure.AzureConnection

applicationId, clientSecret, tenantId

Fields inherited from class com.adaptris.core.AdaptrisConnectionImp

log

Constructor Summary

Constructors

Constructor and Description
DataLakeConnection()

Method Summary

Modifier and Type	Method and Description
java.lang.String	getAccount() The Azure account to use to access the Data Lake.
com.azure.storage.file.datalake.DataLakeServiceClient	getClientConnection()
protected void	initConnection() Initialise the underlying connection.
void	setAccount(java.lang.String account) The Azure account to use to access the Data Lake.
protected void	startConnection() Start the underlying connection.

Methods inherited from class com.adaptris.interlok.azure.AzureConnection

clientSecret, closeConnection, getApplicationId, getClientSecret, getTenantId, prepareConnection, setApplicationId, setClientSecret, setTenantId, stopConnection, tenant

Methods inherited from class com.adaptris.core.AdaptrisConnectionImp

addExceptionListener, addMessageConsumer, addMessageProducer, changeState, cloneForTesting, close, connectionErrorHandler, getConnectionErrorHandler, getUniqueId, getWorkersFirstOnShutdown, init, prepare, requestClose, requestInit, requestStart, requestStop, retrieveComponentState, retrieveConnection, retrieveExceptionListeners, retrieveMessageConsumers, retrieveMessageProducers, setConnectionErrorHandler, setUniqueId, setWorkersFirstOnShutdown, start, stop, workersFirstOnShutdown

Methods inherited from class java.lang.Object

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

Constructor Detail

DataLakeConnection

public DataLakeConnection()

Method Detail

initConnection

protected void initConnection()
                       throws CoreException

Initialise the underlying connection.

Specified by:

initConnection in class AdaptrisConnectionImp

Throws:

CoreException - wrapping any exception.

startConnection

protected void startConnection()

Start the underlying connection.

Specified by:

startConnection in class AdaptrisConnectionImp

Throws:

CoreException - wrapping any exception.

getClientConnection

public com.azure.storage.file.datalake.DataLakeServiceClient getClientConnection()

Specified by:

getClientConnection in class AzureConnection<com.azure.storage.file.datalake.DataLakeServiceClient>

getAccount

public java.lang.String getAccount()

The Azure account to use to access the Data Lake.

setAccount

public void setAccount(java.lang.String account)

The Azure account to use to access the Data Lake.