Package org.apache.nifi.sql

Interface ResettableDataSource

public interface ResettableDataSource
A Source of data for a database

  • Method Summary

    Modifier and Type
    Method
    Description
    NiFiTableSchema
    getSchema()
     
    RowStream
    reset()
    Resets the data source and establishes a RowStream that can be used for iterating over data

  • Method Details

    • getSchema

      NiFiTableSchema getSchema()
      Returns:
      the schema that the rows returned by the RowStream will adhere to

    • reset

      RowStream reset() throws IOException
      Resets the data source and establishes a RowStream that can be used for iterating over data
      Returns:
      the newly established RowStream
      Throws:
      IOException - if unable to obtain a RowStream due to IO failures