org.apache.nifi.provenance.toc

Class NopTocWriter

java.lang.Object

org.apache.nifi.provenance.toc.NopTocWriter

All Implemented Interfaces:

java.io.Closeable, java.lang.AutoCloseable, TocWriter

public class NopTocWriter
extends java.lang.Object
implements TocWriter

Constructor Summary

Constructors

Constructor and Description
NopTocWriter()

Method Summary

Modifier and Type	Method and Description
void	addBlockOffset(long offset, long firstEventId) Adds the given block offset as the next Block Offset in the Table of Contents
void	close()
int	getCurrentBlockIndex()
java.io.File	getFile()
void	sync() Synchronizes the data with the underlying storage device

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

NopTocWriter

public NopTocWriter()

Method Detail

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Specified by:

close in interface java.lang.AutoCloseable

Throws:

java.io.IOException

addBlockOffset

public void addBlockOffset(long offset,
                           long firstEventId)
                    throws java.io.IOException

Description copied from interface: TocWriter

Adds the given block offset as the next Block Offset in the Table of Contents

Specified by:

addBlockOffset in interface TocWriter

Parameters:

offset - the byte offset at which the block begins

firstEventId - the ID of the first Provenance Event that will be in the block

Throws:

java.io.IOException - if unable to persist the block index

getCurrentBlockIndex

public int getCurrentBlockIndex()

Specified by:

getCurrentBlockIndex in interface TocWriter

Returns:

the index of the current Block

getFile

public java.io.File getFile()

Specified by:

getFile in interface TocWriter

Returns:

the file that is currently being written to

sync

public void sync()
          throws java.io.IOException

Description copied from interface: TocWriter

Synchronizes the data with the underlying storage device

Specified by:

sync in interface TocWriter

Throws:

java.io.IOException - if unable to synchronize the data with the underlying storage device