C D E G I N P S
All Classes All Packages

C

closeService() - Method in class com.adaptris.interlok.azure.datalake.DataLakeUploadService

Calls LifecycleHelper#close for the Azure connection.

com.adaptris.interlok.azure.datalake - package com.adaptris.interlok.azure.datalake

D

DataLakeConsumer - Class in com.adaptris.interlok.azure.datalake

Implementation of a file consumer that can retrieve files from Microsoft Data Lake.

DataLakeConsumer() - Constructor for class com.adaptris.interlok.azure.datalake.DataLakeConsumer

DataLakeProducer - Class in com.adaptris.interlok.azure.datalake

Implementation of a file producer that can upload files to Microsoft Data Lake.

DataLakeProducer() - Constructor for class com.adaptris.interlok.azure.datalake.DataLakeProducer

DataLakeUploadService - Class in com.adaptris.interlok.azure.datalake

Upload files to Microsoft Data Lake.

DataLakeUploadService() - Constructor for class com.adaptris.interlok.azure.datalake.DataLakeUploadService

doProduce(AdaptrisMessage, String) - Method in class com.adaptris.interlok.azure.datalake.DataLakeProducer

Upload the given Adaptris message to the Data Lake.

doService(AdaptrisMessage) - Method in class com.adaptris.interlok.azure.datalake.DataLakeUploadService

Upload the given message to the Data Lake.

E

endpoint(AdaptrisMessage) - Method in class com.adaptris.interlok.azure.datalake.DataLakeProducer

.

G

getConnection() - Method in class com.adaptris.interlok.azure.datalake.DataLakeUploadService

A connection to an Azure Data Lake.

getFilename() - Method in class com.adaptris.interlok.azure.datalake.DataLakeProducer

The name of the file to put into the Data Lake.

getFilename() - Method in class com.adaptris.interlok.azure.datalake.DataLakeUploadService

The name of the file to put into the Data Lake.

getFileSystem() - Method in class com.adaptris.interlok.azure.datalake.DataLakeConsumer

The Data Lake file system to access.

getFileSystem() - Method in class com.adaptris.interlok.azure.datalake.DataLakeProducer

The Data Lake file system to access.

getFileSystem() - Method in class com.adaptris.interlok.azure.datalake.DataLakeUploadService

The Data Lake file system to access.

getOverwrite() - Method in class com.adaptris.interlok.azure.datalake.DataLakeProducer

Whether to overwrite existing files.

getOverwrite() - Method in class com.adaptris.interlok.azure.datalake.DataLakeUploadService

Whether to overwrite existing files.

getPath() - Method in class com.adaptris.interlok.azure.datalake.DataLakeConsumer

The path to poll for files.

getPath() - Method in class com.adaptris.interlok.azure.datalake.DataLakeProducer

The path to poll for files.

getPath() - Method in class com.adaptris.interlok.azure.datalake.DataLakeUploadService

The path to poll for files.

I

initService() - Method in class com.adaptris.interlok.azure.datalake.DataLakeUploadService

Calls LifecycleHelper#init for the Azure connection.

N

newThreadName() - Method in class com.adaptris.interlok.azure.datalake.DataLakeConsumer

.

P

prepare() - Method in class com.adaptris.interlok.azure.datalake.DataLakeProducer

.

prepare() - Method in class com.adaptris.interlok.azure.datalake.DataLakeUploadService

Calls LifecycleHelper#prepare for the Azure connection.

prepareConsumer() - Method in class com.adaptris.interlok.azure.datalake.DataLakeConsumer

.

processMessages() - Method in class com.adaptris.interlok.azure.datalake.DataLakeConsumer

Process any files found on the Data Lake.

S

setConnection(AdaptrisConnection) - Method in class com.adaptris.interlok.azure.datalake.DataLakeUploadService

A connection to an Azure Data Lake.

setFilename(String) - Method in class com.adaptris.interlok.azure.datalake.DataLakeProducer

The name of the file to put into the Data Lake.

setFilename(String) - Method in class com.adaptris.interlok.azure.datalake.DataLakeUploadService

The name of the file to put into the Data Lake.

setFileSystem(String) - Method in class com.adaptris.interlok.azure.datalake.DataLakeConsumer

The Data Lake file system to access.

setFileSystem(String) - Method in class com.adaptris.interlok.azure.datalake.DataLakeProducer

The Data Lake file system to access.

setFileSystem(String) - Method in class com.adaptris.interlok.azure.datalake.DataLakeUploadService

The Data Lake file system to access.

setOverwrite(Boolean) - Method in class com.adaptris.interlok.azure.datalake.DataLakeProducer

Whether to overwrite existing files.

setOverwrite(Boolean) - Method in class com.adaptris.interlok.azure.datalake.DataLakeUploadService

Whether to overwrite existing files.

setPath(String) - Method in class com.adaptris.interlok.azure.datalake.DataLakeConsumer

The path to poll for files.

setPath(String) - Method in class com.adaptris.interlok.azure.datalake.DataLakeProducer

The path to poll for files.

setPath(String) - Method in class com.adaptris.interlok.azure.datalake.DataLakeUploadService

The path to poll for files.

start() - Method in class com.adaptris.interlok.azure.datalake.DataLakeUploadService

Calls LifecycleHelper#start for the Azure connection.

stop() - Method in class com.adaptris.interlok.azure.datalake.DataLakeUploadService

Calls LifecycleHelper#stop for the Azure connection.

C D E G I N P S
All Classes All Packages