:py:mod:`flow.record.adapter`
=============================

.. py:module:: flow.record.adapter


Submodules
----------
.. toctree::
   :titlesonly:
   :maxdepth: 1

   archive/index.rst
   avro/index.rst
   broker/index.rst
   csvfile/index.rst
   duckdb/index.rst
   elastic/index.rst
   jsonfile/index.rst
   line/index.rst
   mongo/index.rst
   split/index.rst
   splunk/index.rst
   sqlite/index.rst
   stream/index.rst
   text/index.rst
   xlsx/index.rst


Package Contents
----------------

Classes
~~~~~~~

.. autoapisummary::

   flow.record.adapter.AbstractWriter
   flow.record.adapter.AbstractReader



Functions
~~~~~~~~~

.. autoapisummary::
   :nosignatures:

   flow.record.adapter.with_metaclass



Attributes
~~~~~~~~~~

.. autoapisummary::

   flow.record.adapter.__path__


.. py:data:: __path__

   

.. py:function:: with_metaclass(meta, *bases)

   Create a base class with a metaclass. Python 2 and 3 compatible.


.. py:class:: AbstractWriter


   Bases: :py:obj:`with_metaclass`\ (\ :py:obj:`abc.ABCMeta`\ , :py:obj:`object`\ )

   .. py:method:: write(rec)
      :abstractmethod:

      Write a record.


   .. py:method:: flush()
      :abstractmethod:

      Flush any buffered writes.


   .. py:method:: close()
      :abstractmethod:

      Close the Writer, no more writes will be possible.


   .. py:method:: __del__()


   .. py:method:: __enter__()


   .. py:method:: __exit__(*args)



.. py:class:: AbstractReader


   Bases: :py:obj:`with_metaclass`\ (\ :py:obj:`abc.ABCMeta`\ , :py:obj:`object`\ )

   .. py:method:: __iter__()
      :abstractmethod:

      Return a record iterator.


   .. py:method:: close()

      Close the Reader, can be overriden to properly free resources.


   .. py:method:: __enter__()


   .. py:method:: __exit__(*args)