Package com.illumon.iris.db.tables.dataimport.logtailer

Interface LogtailerDestinationManager.FinishedFileConsumer

All Known Implementing Classes:

LogtailerFileCleaner

Enclosing class:

LogtailerDestinationManager

public static interface LogtailerDestinationManager.FinishedFileConsumer

Method Summary

Modifier and Type	Method	Description
void	handleFile(File finishedFile, TableLocationIdentifier tableLocationIdentifier, String endpointName)	LogtailerDestinationManager instances post old files that are no longer gathering data to this interface, along with the identifier for its target table and a description of the endpoint to which the data is sent.
void	handleFileForce(File finishedFile, TableLocationIdentifier tableLocationIdentifier)	Works as handleFile(File, TableLocationIdentifier, String) but assumes all endpoints have processed the file.

Method Details

handleFile

void handleFile(@NotNull
 File finishedFile,
 @NotNull
 TableLocationIdentifier tableLocationIdentifier,
 @NotNull
 String endpointName)

LogtailerDestinationManager instances post old files that are no longer gathering data to this interface, along with the identifier for its target table and a description of the endpoint to which the data is sent. It is possible for one file to be sent to multiple endpoints, and files must not be deleted until all endpoints have processed the file.

Parameters:

finishedFile - File which has been fully processed that can be deleted.

tableLocationIdentifier - Identifier for the table to which this file's data is sent.

endpointName - Unique identifier of the endpoint to which the file was sent.

handleFileForce

void handleFileForce(@NotNull
 File finishedFile,
 @NotNull
 TableLocationIdentifier tableLocationIdentifier)

Works as handleFile(File, TableLocationIdentifier, String) but assumes all endpoints have processed the file.

Parameters:

finishedFile - File which has been fully processed that can be deleted.

tableLocationIdentifier - Identifier for the table to which this file's data is sent.