Package org.apache.storm.hdfs.trident.sync

Interface SyncPolicy

All Superinterfaces:
Serializable
All Known Implementing Classes:
CountSyncPolicy
public interface SyncPolicy extends Serializable
Interface for controlling when the HdfsBolt syncs and flushes the filesystem.

  • Method Summary

    Modifier and Type
    Method
    Description
    boolean
    mark(TridentTuple tuple, long offset)
    Called for every tuple the HdfsBolt executes.
    void
    reset()
    Called after the HdfsBolt performs a sync.

  • Method Details

    • mark

      boolean mark(TridentTuple tuple, long offset)
      Called for every tuple the HdfsBolt executes.
      Parameters:
      tuple - The tuple executed.
      offset - current offset for the file being written
      Returns:
      true if a sync should be performed

    • reset

      void reset()
      Called after the HdfsBolt performs a sync.