\hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs}{}\section{plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs Class Reference}
\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs}\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}


Inheritance diagram for plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs\+:
% FIG 0


Collaboration diagram for plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs\+:
% FIG 1
\subsection*{Public Member Functions}
\begin{DoxyCompactItemize}
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a8e6b5c56394ea6c498881c21c39da7fa}{open\+\_\+filesystem}} (self, hdfs\+\_\+uri, user=\char`\"{}hadoop\char`\"{})
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a256b131c4e838fac7f60c9f2f233a743}{close\+\_\+filesystem}} (self, filesystem=None)
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_af17b43b435cae040528fa5fd8e0954d7}{get\+\_\+filesystem}} (self, force\+\_\+filesystem=None)
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a6e9ce3289db0006ceb4bb61c86a7447e}{exists}} (self, path\+\_\+string, filesystem=None)
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a2cad624458f2c0ea36087da7db5eeeed}{info}} (self, path\+\_\+string, filesystem=None)
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_ab04631616504469c2f9ce369e1c7bc40}{remove}} (self, path\+\_\+string, recursive=True, filesystem=None)
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a857f1126b470aba0c4ea20665b611c0c}{mkdir}} (self, path\+\_\+string, filesystem=None)
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a95b4741d219bae828c361e38f3e1619e}{list\+\_\+files}} (self, path\+\_\+string, recursion\+\_\+level=0, include\+\_\+dir\+\_\+names=False, filesystem=None)
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a4f54c9f9fc2a116f359b635c14fd4623}{open\+\_\+inputstream}} (self, path, filesystem=None)
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a43e143cd18b886573e6db7fcd0063072}{open\+\_\+outputstream}} (self, path, filesystem=None)
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a24d1e82e2f76838ea2c461abcdc93b62}{close\+\_\+stream}} (self, input\+\_\+stream)
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a7bb67099d0614448f55d06976b3460e2}{get\+\_\+stream\+\_\+offset}} (self, input\+\_\+stream)
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_ada770b814e9fb119c137c5c37efd48f4}{get\+\_\+path\+\_\+size}} (self, path, filesystem=None)
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a014c2bc82b1473f77eae6c432fbd3ef5}{read\+\_\+inputstream}} (self, input\+\_\+stream, size=None)
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_ae55c9546f7c07922e64c328d16ce929a}{write\+\_\+outputstream}} (self, output\+\_\+stream, data)
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a0b76071a9c2f322388ba96de6acea0b1}{pass\+\_\+to\+\_\+outputstream}} (self, output\+\_\+stream, input\+\_\+stream)
\item 
def \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_af6c21436c089214b64e61a9974decc15}{seek\+\_\+stream}} (self, stream, offset, whence=os.\+S\+E\+E\+K\+\_\+\+S\+ET)
\end{DoxyCompactItemize}
\subsection*{Static Public Attributes}
\begin{DoxyCompactItemize}
\item 
\mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a4a02b3823e27e43d2a72e08568ff7dd6}{fs}} = None
\end{DoxyCompactItemize}
\subsection*{Additional Inherited Members}


\subsection{Detailed Description}
\begin{DoxyVerb}HDFS driver utilizing PyArrow library.\end{DoxyVerb}
 

\subsection{Member Function Documentation}
\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a256b131c4e838fac7f60c9f2f233a743}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a256b131c4e838fac7f60c9f2f233a743}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!close\_filesystem@{close\_filesystem}}
\index{close\_filesystem@{close\_filesystem}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{close\_filesystem()}{close\_filesystem()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+close\+\_\+filesystem (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{filesystem = {\ttfamily None} }\end{DoxyParamCaption})}

\begin{DoxyVerb}Close a given HDFS filesystem.
:param filesystem: the filesystem
\end{DoxyVerb}
 

Reimplemented from \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1hdfs_1_1_hdfs_af0b55cd11d96e195f365d7c01a04c444}{plaso.\+tarzan.\+lib.\+hdfs.\+Hdfs}}.

\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a24d1e82e2f76838ea2c461abcdc93b62}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a24d1e82e2f76838ea2c461abcdc93b62}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!close\_stream@{close\_stream}}
\index{close\_stream@{close\_stream}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{close\_stream()}{close\_stream()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+close\+\_\+stream (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{input\+\_\+stream }\end{DoxyParamCaption})}

\begin{DoxyVerb}Close a given (previously opened) input-stream for a HDFS file.
:param input_stream: the opened input-stream
\end{DoxyVerb}
 

Reimplemented from \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1hdfs_1_1_hdfs_ab8620c8e39394798b2352be292a7000b}{plaso.\+tarzan.\+lib.\+hdfs.\+Hdfs}}.

\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a6e9ce3289db0006ceb4bb61c86a7447e}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a6e9ce3289db0006ceb4bb61c86a7447e}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!exists@{exists}}
\index{exists@{exists}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{exists()}{exists()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+exists (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{path\+\_\+string,  }\item[{}]{filesystem = {\ttfamily None} }\end{DoxyParamCaption})}

\begin{DoxyVerb}Check if a given HDFS path exists in the given HDFS filesystem.
:param path_string: the path
:param filesystem: the filesystem
:return: True if the path exists in the filesystem, False otherwise
\end{DoxyVerb}
 

Reimplemented from \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1hdfs_1_1_hdfs_ad8190898c582d609230adec16617f5a6}{plaso.\+tarzan.\+lib.\+hdfs.\+Hdfs}}.

\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_af17b43b435cae040528fa5fd8e0954d7}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_af17b43b435cae040528fa5fd8e0954d7}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!get\_filesystem@{get\_filesystem}}
\index{get\_filesystem@{get\_filesystem}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{get\_filesystem()}{get\_filesystem()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+get\+\_\+filesystem (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{force\+\_\+filesystem = {\ttfamily None} }\end{DoxyParamCaption})}

\begin{DoxyVerb}Get a given or a default HDFS filesystem.
:param force_filesystem: the given filesystem
:return: the filesystem
\end{DoxyVerb}
 

Reimplemented from \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1hdfs_1_1_hdfs_af21716f7e7b5a6065f1e92c836291c8a}{plaso.\+tarzan.\+lib.\+hdfs.\+Hdfs}}.

\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_ada770b814e9fb119c137c5c37efd48f4}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_ada770b814e9fb119c137c5c37efd48f4}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!get\_path\_size@{get\_path\_size}}
\index{get\_path\_size@{get\_path\_size}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{get\_path\_size()}{get\_path\_size()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+get\+\_\+path\+\_\+size (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{path,  }\item[{}]{filesystem = {\ttfamily None} }\end{DoxyParamCaption})}

\begin{DoxyVerb}Get the size of a given HDFS path (a file) in a given filesystem.
:param path: the path
:param filesystem: the filesystem
:return: the size
\end{DoxyVerb}
 

Reimplemented from \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1hdfs_1_1_hdfs_ae4454e22c5ef146f838bb9a901ae745f}{plaso.\+tarzan.\+lib.\+hdfs.\+Hdfs}}.

\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a7bb67099d0614448f55d06976b3460e2}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a7bb67099d0614448f55d06976b3460e2}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!get\_stream\_offset@{get\_stream\_offset}}
\index{get\_stream\_offset@{get\_stream\_offset}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{get\_stream\_offset()}{get\_stream\_offset()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+get\+\_\+stream\+\_\+offset (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{input\+\_\+stream }\end{DoxyParamCaption})}

\begin{DoxyVerb}Get the current position (an offset) in a given (previously opened) input-stream for a HDFS file.
:param input_stream: the opened input-stream
:return: the position/offset
\end{DoxyVerb}
 

Reimplemented from \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1hdfs_1_1_hdfs_a1b96f67a49bd8cacbd8dea9cc299ce6b}{plaso.\+tarzan.\+lib.\+hdfs.\+Hdfs}}.

\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a2cad624458f2c0ea36087da7db5eeeed}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a2cad624458f2c0ea36087da7db5eeeed}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!info@{info}}
\index{info@{info}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{info()}{info()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+info (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{path\+\_\+string,  }\item[{}]{filesystem = {\ttfamily None} }\end{DoxyParamCaption})}

\begin{DoxyVerb}Get metadata of a given path in a given or a default filesystem.
:param path_string: the path
:param filesystem: the filesystem
:return: the metadata dictionary
\end{DoxyVerb}
 

Reimplemented from \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1hdfs_1_1_hdfs_aaa6549ca7976f4ed684baa5a5b3eb57b}{plaso.\+tarzan.\+lib.\+hdfs.\+Hdfs}}.

\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a95b4741d219bae828c361e38f3e1619e}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a95b4741d219bae828c361e38f3e1619e}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!list\_files@{list\_files}}
\index{list\_files@{list\_files}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{list\_files()}{list\_files()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+list\+\_\+files (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{path\+\_\+string,  }\item[{}]{recursion\+\_\+level = {\ttfamily 0},  }\item[{}]{include\+\_\+dir\+\_\+names = {\ttfamily False},  }\item[{}]{filesystem = {\ttfamily None} }\end{DoxyParamCaption})}

\begin{DoxyVerb}Get a list of files (optionally recursively to the specified level) in a given HDFS path of a given filesystem.
:param path_string: the path
:param recursion_level: the level for the recursion (0 is just a current directory without any recursion)
:param include_dir_names: True to include also names of directories (suffixed by /)
:param filesystem: the filesystem
:return: the list of files in the path
\end{DoxyVerb}
 

Reimplemented from \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1hdfs_1_1_hdfs_a0170fd27227e697be8a748fd99aad752}{plaso.\+tarzan.\+lib.\+hdfs.\+Hdfs}}.

\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a857f1126b470aba0c4ea20665b611c0c}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a857f1126b470aba0c4ea20665b611c0c}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!mkdir@{mkdir}}
\index{mkdir@{mkdir}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{mkdir()}{mkdir()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+mkdir (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{path\+\_\+string,  }\item[{}]{filesystem = {\ttfamily None} }\end{DoxyParamCaption})}

\begin{DoxyVerb}Make a new directory (if does not exist) of a given path in a given or a default filesystem.
:param path_string: the path
:param filesystem: the filesystem
\end{DoxyVerb}
 

Reimplemented from \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1hdfs_1_1_hdfs_a27669442ad41b934274fc0864e77a9e9}{plaso.\+tarzan.\+lib.\+hdfs.\+Hdfs}}.

\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a8e6b5c56394ea6c498881c21c39da7fa}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a8e6b5c56394ea6c498881c21c39da7fa}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!open\_filesystem@{open\_filesystem}}
\index{open\_filesystem@{open\_filesystem}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{open\_filesystem()}{open\_filesystem()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+open\+\_\+filesystem (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{hdfs\+\_\+uri,  }\item[{}]{user = {\ttfamily \char`\"{}hadoop\char`\"{}} }\end{DoxyParamCaption})}

\begin{DoxyVerb}Open HDFS filesystem of a given URI and as a given HDFS user.
:param hdfs_uri: HDFS URI to open
:param user: HDFS user to act as when opening
:return: the opened filesystem as an object of pyarrow.HadoopFileSystem
\end{DoxyVerb}
 

Reimplemented from \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1hdfs_1_1_hdfs_a7ad63eae72305955a13f532f9daf4466}{plaso.\+tarzan.\+lib.\+hdfs.\+Hdfs}}.

\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a4f54c9f9fc2a116f359b635c14fd4623}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a4f54c9f9fc2a116f359b635c14fd4623}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!open\_inputstream@{open\_inputstream}}
\index{open\_inputstream@{open\_inputstream}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{open\_inputstream()}{open\_inputstream()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+open\+\_\+inputstream (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{path,  }\item[{}]{filesystem = {\ttfamily None} }\end{DoxyParamCaption})}

\begin{DoxyVerb}Open and get an input-stream for a HDFS file given by its path in a given filesystem.
:param path: the path
:param filesystem: the filesystem
:return: the opened input-stream
\end{DoxyVerb}
 

Reimplemented from \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1hdfs_1_1_hdfs_a11d5a72d4292333cdd8415536d54ad59}{plaso.\+tarzan.\+lib.\+hdfs.\+Hdfs}}.

\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a43e143cd18b886573e6db7fcd0063072}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a43e143cd18b886573e6db7fcd0063072}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!open\_outputstream@{open\_outputstream}}
\index{open\_outputstream@{open\_outputstream}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{open\_outputstream()}{open\_outputstream()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+open\+\_\+outputstream (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{path,  }\item[{}]{filesystem = {\ttfamily None} }\end{DoxyParamCaption})}

\begin{DoxyVerb}Open and get an output-stream for a HDFS file given by its path in a given filesystem.
:param path: the path
:param filesystem: the filesystem
:return: the opened output-stream
\end{DoxyVerb}
 

Reimplemented from \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1hdfs_1_1_hdfs_a047da47fd6b54c9462158a50ca663db4}{plaso.\+tarzan.\+lib.\+hdfs.\+Hdfs}}.

\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a0b76071a9c2f322388ba96de6acea0b1}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a0b76071a9c2f322388ba96de6acea0b1}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!pass\_to\_outputstream@{pass\_to\_outputstream}}
\index{pass\_to\_outputstream@{pass\_to\_outputstream}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{pass\_to\_outputstream()}{pass\_to\_outputstream()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+pass\+\_\+to\+\_\+outputstream (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{output\+\_\+stream,  }\item[{}]{input\+\_\+stream }\end{DoxyParamCaption})}

\begin{DoxyVerb}Pass data from the input stream to the output stream to a HDFS file.
:param output_stream: the output-stream of the HDFS file
:param input_stream: the input-stream
\end{DoxyVerb}
 \mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a014c2bc82b1473f77eae6c432fbd3ef5}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a014c2bc82b1473f77eae6c432fbd3ef5}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!read\_inputstream@{read\_inputstream}}
\index{read\_inputstream@{read\_inputstream}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{read\_inputstream()}{read\_inputstream()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+read\+\_\+inputstream (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{input\+\_\+stream,  }\item[{}]{size = {\ttfamily None} }\end{DoxyParamCaption})}

\begin{DoxyVerb}Read data form a given opened input stream for a HDFS file.
:param input_stream: the input-stream
:param size: the size of data to read
:return: the data
\end{DoxyVerb}
 

Reimplemented from \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1hdfs_1_1_hdfs_a431e11f59e42a642db26d38f6d51e450}{plaso.\+tarzan.\+lib.\+hdfs.\+Hdfs}}.

\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_ab04631616504469c2f9ce369e1c7bc40}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_ab04631616504469c2f9ce369e1c7bc40}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!remove@{remove}}
\index{remove@{remove}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{remove()}{remove()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+remove (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{path\+\_\+string,  }\item[{}]{recursive = {\ttfamily True},  }\item[{}]{filesystem = {\ttfamily None} }\end{DoxyParamCaption})}

\begin{DoxyVerb}Remove (optionally recursively) a HDFS file/directory given by its path in a given or a default filesystem.
:param path_string: the path
:param recursive: True to remove recursively
:param filesystem: the filesystem
\end{DoxyVerb}
 

Reimplemented from \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1hdfs_1_1_hdfs_a5e46f7a3ef2e6c0ee72cb57704195509}{plaso.\+tarzan.\+lib.\+hdfs.\+Hdfs}}.

\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_af6c21436c089214b64e61a9974decc15}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_af6c21436c089214b64e61a9974decc15}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!seek\_stream@{seek\_stream}}
\index{seek\_stream@{seek\_stream}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{seek\_stream()}{seek\_stream()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+seek\+\_\+stream (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{stream,  }\item[{}]{offset,  }\item[{}]{whence = {\ttfamily os.SEEK\+\_\+SET} }\end{DoxyParamCaption})}

\begin{DoxyVerb}Set a given position (an offset) in a given (previously opened) input-stream for a HDFS file.
:param stream: the opened stream
:param offset: the position/offset
:param whence: the direction
\end{DoxyVerb}
 

Reimplemented from \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1hdfs_1_1_hdfs_a3a8a7cb2f7d4ab4181c5168cd4396831}{plaso.\+tarzan.\+lib.\+hdfs.\+Hdfs}}.

\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_ae55c9546f7c07922e64c328d16ce929a}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_ae55c9546f7c07922e64c328d16ce929a}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!write\_outputstream@{write\_outputstream}}
\index{write\_outputstream@{write\_outputstream}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{write\_outputstream()}{write\_outputstream()}}
{\footnotesize\ttfamily def plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+write\+\_\+outputstream (\begin{DoxyParamCaption}\item[{}]{self,  }\item[{}]{output\+\_\+stream,  }\item[{}]{data }\end{DoxyParamCaption})}

\begin{DoxyVerb}Write data buffer to a given opened output stream for a HDFS file.
:param output_stream: the output-stream
:param data: the data buffer to write
:return: the number of bytes written
\end{DoxyVerb}
 

Reimplemented from \mbox{\hyperlink{classplaso_1_1tarzan_1_1lib_1_1hdfs_1_1_hdfs_add3aaf5fdbfae0f71debdad0d3e988de}{plaso.\+tarzan.\+lib.\+hdfs.\+Hdfs}}.



\subsection{Member Data Documentation}
\mbox{\Hypertarget{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a4a02b3823e27e43d2a72e08568ff7dd6}\label{classplaso_1_1tarzan_1_1lib_1_1pyarrow__hdfs_1_1_py_arrow_hdfs_a4a02b3823e27e43d2a72e08568ff7dd6}} 
\index{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}!fs@{fs}}
\index{fs@{fs}!plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs@{plaso.tarzan.lib.pyarrow\_hdfs.PyArrowHdfs}}
\subsubsection{\texorpdfstring{fs}{fs}}
{\footnotesize\ttfamily plaso.\+tarzan.\+lib.\+pyarrow\+\_\+hdfs.\+Py\+Arrow\+Hdfs.\+fs = None\hspace{0.3cm}{\ttfamily [static]}}



The documentation for this class was generated from the following file\+:\begin{DoxyCompactItemize}
\item 
/home/rychly/repos/pyspark-\/plaso/src/plaso/tarzan/lib/\mbox{\hyperlink{pyarrow__hdfs_8py}{pyarrow\+\_\+hdfs.\+py}}\end{DoxyCompactItemize}
