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.
  • 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.