org.apache.storm.hdfs.bolt.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
 boolean mark(Tuple tuple, long offset)
          Called for every tuple the HdfsBolt executes.
 void reset()
          Called after the HdfsBolt performs a sync.
 

Method Detail

mark

boolean mark(Tuple 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.



Copyright © 2016 The Apache Software Foundation. All Rights Reserved.