Package 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	Description
DataLakeConnection()

Method Summary

Modifier and Type	Method	Description
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(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

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 Details

DataLakeConnection

public DataLakeConnection()

Method Details

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 String getAccount()

The Azure account to use to access the Data Lake.

setAccount

public void setAccount(String account)

The Azure account to use to access the Data Lake.