Interface AbstractFSWALProvider.Initializer

All Known Implementing Classes:
AbstractProtobufWALReader, ProtobufWALStreamReader, ProtobufWALTailingReader
Enclosing class:
AbstractFSWALProvider<T extends AbstractFSWAL<?>>

public static interface AbstractFSWALProvider.Initializer
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    init(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration c, long startPosition)
    A method to initialize a WAL reader.
  • Method Details

    • init

      void init(org.apache.hadoop.fs.FileSystem fs, org.apache.hadoop.fs.Path path, org.apache.hadoop.conf.Configuration c, long startPosition) throws IOException
      A method to initialize a WAL reader.
      Parameters:
      startPosition - the start position you want to read from, -1 means start reading from the first WAL entry. Notice that, the first entry is not started at position as we have several headers, so typically you should not pass 0 here.
      Throws:
      IOException