Class ProgressCounterInputStream

  • All Implemented Interfaces:
    Closeable, AutoCloseable

    public final class ProgressCounterInputStream
    extends FilterInputStream
    This class implements a FilterInputStream that inform Hadoop of the progress of task using counters.
    Since:
    1.0
    Author:
    Laurent Jourdren