ó
¦–Õ\c        	   @   s  d  d l  Z d  d l Z d  d l j j Z d  d l Z d  d l	 Z	 d  d l
 Z
 d  d l m Z d  d l j Z d  d l m Z m Z m Z d  d l m Z d „  Z d „  Z d „  Z d „  Z d	 „  Z d
 „  Z e
 j j d „  ƒ Z d „  Z e
 j j  d d d d g ƒ e
 j j  d d d d g ƒ d „  ƒ ƒ Z! d „  Z" d „  Z# e
 j j  d e j$ i d d d d g d 6d d d d g d  6d! d" d# d$ d% g ƒe j% f e j& d d d d g d& d ƒe j' f g ƒ d' „  ƒ Z( d( „  Z) d) „  Z* d* „  Z+ d+ „  Z, d, „  Z- d- „  Z. d. „  Z/ d S(/   iÿÿÿÿN(   t   sleep(   t   tmpfilet   tmpdirt   dependency_depth(   t	   assert_eqc          C   s´  t  j d ƒ t j i d d d d g d 6d d d	 d
 g d 6d d d d d g ƒ}  t j |  d ƒ } t d ƒ : } | j | d ƒ t j | d ƒ } t	 j
 |  | ƒ Wd  QXt d ƒ @ } | j j | d ƒ t j | d ƒ } t	 j |  j | ƒ Wd  QXt j |  d ƒ } t d ƒ : } | j | d ƒ t j | d ƒ } t	 j
 |  | ƒ Wd  QXt d ƒ L } | j | d d t ƒ} | j ƒ  t j | d ƒ } t	 j
 |  | ƒ Wd  QXd  S(   Nt   tablest   at   bt   ct   dt   xi   i   i   i   t   yt   indexg      ð?g       @g      @g      @t   h5s   /datat   compute(   t   pytestt   importorskipt   pdt	   DataFramet   ddt   from_pandasR   t   to_hdft   read_hdft   tmt   assert_frame_equalR
   t   assert_series_equalt   FalseR   (   t   dfR   t   fnt   outt   r(    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_to_hdf   s,    +
c          C   s²  t  j d ƒ t j i d d d d g d 6d d d	 d
 g d 6d d d d d g ƒ}  t j |  d ƒ } t j i d d d d d d d d d d d d d d d d g d 6d d d	 d
 d d d d  d! d" d# d$ d% d& d' d( g d 6d d d d d d) d* d+ d, d- d. d/ d0 d1 d2 d3 d4 g ƒ} t j | d( ƒ } t d5 ƒ 6 } | j | d6 ƒ t j | d6 ƒ } t	 |  | ƒ Wd  QXt d5 ƒ 6 } | j | d6 ƒ t j | d6 ƒ } t	 | | ƒ Wd  QXt d5 ƒ ‘ } | j | d7 d8 d9 „  ƒt j | d7 ƒ } t	 |  | ƒ t j | d: ƒ } t
 j | |  j d  ƒ t j | d; ƒ } t
 j | |  j d ƒ Wd  QXt d5 ƒ N } t j | ƒ 6 } | j | d6 ƒ t j | d6 ƒ } t	 | | ƒ Wd  QXWd  QXd  S(<   NR   R   R   R   R	   R
   i   i   i   i   R   R   g      ð?g       @g      @g      @t   et   ft   gt   ht   it   jt   kt   lt   mt   nt   ot   pi   i   i   i   i	   i
   i   i   i   i   i   i   g      @g      @g      @g       @g      "@g      $@g      &@g      (@g      *@g      ,@g      .@g      0@R   s   /data*s   /data_*t   name_functionc         S   s   d |  d S(   NR   i   (    (   R$   (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   <lambda>K   t    s   /data_as   /data_aa(   R   R   R   R   R   R   R   R   R   R   R   R   t   iloct   HDFStore(   R   R   t   df16R   R   R   t   hdf(    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_to_hdf_multiple_nodes0   s@    +$'!c          C   s  t  j d ƒ t j i d d d d g d 6d d d	 d
 g d 6d d d d d g ƒ}  t j |  d ƒ } t j i d d d d d d d d d d d d d d d d g d 6d d d	 d
 d d d d  d! d" d# d$ d% d& d' d( g d 6d d d d d d) d* d+ d, d- d. d/ d0 d1 d2 d3 d4 g ƒ} t j | d( ƒ } t ƒ  K } t j j	 | d5 ƒ } | j
 | d6 ƒ t j | d6 ƒ } t |  | ƒ Wd  QXt ƒ  K } t j j	 | d5 ƒ } | j
 | d6 ƒ t j | d6 ƒ } t | | ƒ Wd  QXt ƒ  Ä } t j j	 | d5 ƒ } | j
 | d6 d7 d8 „  ƒt j | d6 ƒ } t |  | ƒ t j t j j	 | d9 ƒ d6 ƒ } t j | |  j d  ƒ t j t j j	 | d: ƒ d6 ƒ } t j | |  j d ƒ Wd  QXt d; ƒ N } t j | ƒ 6 } | j
 | d< ƒ t j | d< ƒ } t |  | ƒ Wd  QXWd  QXd  S(=   NR   R   R   R   R	   R
   i   i   i   i   R   R   g      ð?g       @g      @g      @R    R!   R"   R#   R$   R%   R&   R'   R(   R)   R*   R+   i   i   i   i   i	   i
   i   i   i   i   i   i   g      @g      @g      @g       @g      "@g      $@g      &@g      (@g      *@g      ,@g      .@g      0@s	   data_*.h5s   /dataR,   c         S   s   d |  d S(   NR   i   (    (   R$   (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyR-   z   R.   s	   data_a.h5s
   data_aa.h5R   s   /data*(   R   R   R   R   R   R   R   t   ost   patht   joinR   R   R   R   R   R/   R   R0   (   R   R   R1   R   t   dnR   R   R2   (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_to_hdf_multiple_files\   sF    +$*!!!c          C   s¥  t  j d ƒ t j i d d d d g d 6d d d	 d
 g d 6d d d d d g ƒ}  t j |  d ƒ } t d ƒ U } | j | d ƒ | j | d d d ƒt j | d ƒ } t	 |  j
 |  ƒ | ƒ Wd  QXt j |  d ƒ } t d ƒ L } | j | d ƒ | j | d d d ƒt j | d ƒ } t	 |  | ƒ Wd  QXt j |  d ƒ } t d ƒ U } | j | d ƒ | j | d d d ƒt j | d ƒ } t	 |  j
 |  ƒ | ƒ Wd  QXt j |  d ƒ } t d ƒ L } | j | d ƒ | j | d d d ƒt j | d ƒ } t	 |  | ƒ Wd  QXt j |  d ƒ } t d ƒ k } | j | d ƒ | j | d ƒ | j | d d d d t ƒt j | d ƒ } t	 |  j
 |  ƒ | ƒ Wd  QXd  S(   NR   R   R   R   R	   R
   i   i   i   i   R   R   g      ð?g       @g      @g      @R   s   /data2s   /data*t   modet   ws   /data1t   append(   R   R   R   R   R   R   R   R   R   R   R;   R   (   R   R   R   R   (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt    test_to_hdf_modes_multiple_nodes‹   sD    +c          C   s­  t  j d ƒ t j i d d d d g d 6d d d	 d
 g d 6d d d d d g ƒ}  t j |  d ƒ } t ƒ  y } t j j	 | d ƒ } | j
 t j j	 | d ƒ d ƒ | j
 | d d d ƒt j | d ƒ } t |  j |  ƒ | ƒ Wd  QXt j |  d ƒ } t ƒ  y } t j j	 | d ƒ } | j
 t j j	 | d ƒ d ƒ | j
 | d d d ƒt j | d ƒ } t |  j |  ƒ | ƒ Wd  QXt j |  d ƒ } t ƒ  p } t j j	 | d ƒ } | j
 t j j	 | d ƒ d ƒ | j
 | d d d ƒt j | d ƒ } t |  | ƒ Wd  QXt j |  d ƒ } t ƒ   } t j j	 | d ƒ } | j
 t j j	 | d ƒ d ƒ | j
 | d d d d t ƒt j | d ƒ } t |  j |  ƒ | ƒ Wd  QXd  S(   NR   R   R   R   R	   R
   i   i   i   i   R   R   g      ð?g       @g      @g      @s   data*t   data2s   /dataR9   s   /data*t   data1R:   R;   (   R   R   R   R   R   R   R   R4   R5   R6   R   R   R   R;   R   (   R   R   R7   R   R   (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt    test_to_hdf_modes_multiple_filesº   s>    +c          C   sÁ  t  j d ƒ t j i d d d d d d d d	 d
 d d d d d d d g d 6d d d d d d d d d d d d d d  d! d" g d# 6d$ d% d& d' d( d) d* d+ d, d- d. d/ d0 d1 d2 d3 d4 g ƒ}  t j |  d" ƒ } t ƒ  O } t j j	 | d5 ƒ } | j
 | d6 d7 t ƒ} t | j ƒ d k s&t ‚ Wd8 QXt ƒ  : } | j
 | d9 d7 t ƒ} t | j ƒ d k skt ‚ Wd8 QXt ƒ  A } | j
 | d6 d7 t ƒ} t | j ƒ d | j k s·t ‚ Wd8 QXd8 S(:   sN   testing dask link levels is correct by calculating the depth of the dask graphR   R   R   R   R	   R    R!   R"   R#   R$   R%   R&   R'   R(   R)   R*   R+   R
   i   i   i   i   i   i   i   i   i	   i
   i   i   i   i   i   i   R   R   g      ð?g       @g      @g      @g      @g      @g      @g       @g      "@g      $@g      &@g      (@g      *@g      ,@g      .@g      0@s   data*s   /dataR   Ns   /data*(   R   R   R   R   R   R   R   R4   R5   R6   R   R   R   t   daskt   AssertionErrorR   t   npartitions(   R1   R   R7   R   R	   (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_to_hdf_link_optimizationsä   s$    $*!!!c          C   s¬  t  j d ƒ t j i d d d d d d d d	 d
 d d d d d d d g d 6d d d d d d d d d d d d d d  d! d" g d# 6d$ d% d& d' d( d) d* d+ d, d- d. d/ d0 d1 d2 d3 d4 g ƒ}  t j |  d" ƒ } d5 „  } t ƒ  Q } | j | d6 d d7 | ƒ} | j | d8 ƒ t j	 | d8 ƒ } t
 |  | ƒ Wd  QXt ƒ  f } t j j | d9 ƒ } | j | d6 d d7 | ƒ} | j | d: ƒ t j	 | d: ƒ } t
 |  | ƒ Wd  QXd  S(;   NR   R   R   R   R	   R    R!   R"   R#   R$   R%   R&   R'   R(   R)   R*   R+   R
   i   i   i   i   i   i   i   i   i	   i
   i   i   i   i   i   i   R   R   g      ð?g       @g      @g      @g      @g      @g      @g       @g      "@g      $@g      &@g      (@g      *@g      ,@g      .@g      0@c         S   s-   |  d d k  r) t  d d |  d ƒ n  |  S(   Ni   i
   gš™™™™™¹?(   R    (   R$   (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   delayed_nop  s    t   axist   metas   /data*s   data*s   /data(   R   R   R   R   R   R   R   t   applyR   R   R   R   R4   R5   R6   (   R1   R   RD   R   R   R7   (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_to_hdf_lock_delays  s(    $*!	c          C   s  t  j d ƒ t j i d d d d g d 6d d d	 d
 g d 6d d d d d g ƒ}  t j |  d ƒ } t ƒ  B } t  j t ƒ * t	 j
 j | d ƒ } | j | d ƒ Wd  QXWd  QXt ƒ  E } t j | ƒ - } t  j t ƒ  | j | d ƒ Wd  QXWd  QXWd  QXd  S(   NR   R   R   R   R	   R
   i   i   i   i   R   R   g      ð?g       @g      @g      @s	   data_*.h5s   /data_*s	   /data_*_*(   R   R   R   R   R   R   R   t   raisest
   ValueErrorR4   R5   R6   R   R   R0   (   R   R   R7   R   R2   (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_to_hdf_exceptions(  s    +t	   schedulert   synct   threadst	   processesRB   i   i   i
   c         C   sÉ  t  j d ƒ t j i d d d d d d d d	 d
 d d d d d d d g d 6d d d d d d d d d d d d d d  d! d" g d# 6d$ d% d& d' d( d) d* d+ d, d- d. d/ d0 d1 d2 d3 d4 g ƒ} t j | d5 | ƒ} t d6 ƒ < } | j | d7 d8 |  ƒt j | d7 ƒ } t	 | | ƒ Wd  QXt
 ƒ  Q } t j j | d9 ƒ } | j | d7 d8 |  ƒt j | d7 ƒ } t	 | | ƒ Wd  QXt d6 ƒ < } | j | d: d8 |  ƒt j | d: ƒ } t	 | | ƒ Wd  QXd  S(;   NR   R   R   R   R	   R    R!   R"   R#   R$   R%   R&   R'   R(   R)   R*   R+   R
   i   i   i   i   i   i   i   i   i	   i
   i   i   i   i   i   i   R   R   g      ð?g       @g      @g      @g      @g      @g      @g       @g      "@g      $@g      &@g      (@g      *@g      ,@g      .@g      0@RB   R   s   /dataRL   s	   data_*.h5s   /data*(   R   R   R   R   R   R   R   R   R   R   R   R4   R5   R6   (   RL   RB   R   R   R   R   R7   (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_to_hdf_schedulers;  s$    @:9c          C   sè   t  j d ƒ t j i d d g d 6ƒ }  t j |  d d ƒ} t d ƒ E } | j | d d	 d
 d d ƒt j | d ƒ } t	 j
 |  | ƒ Wd  QXt d ƒ E } | j | d d	 d d d ƒt j | d ƒ } t	 j
 |  | ƒ Wd  QXd  S(   NR   R   t   aaaat   ARB   i   R   t   foo4t   formatt   tablet   min_itemsizei   t   t(   R   R   R   R   R   R   R   R   R   R   R   (   R   t   ddfR   t   df2(    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_to_hdf_kwargsX  s    c          C   sg  t  j d ƒ t j i d d d d d d d d	 d
 d d d d d d d g d 6d d d d d d d d d d d d d d  d! d" g d# 6d$ d% d& d' d( d) d* d+ d, d- d. d/ d0 d1 d2 d3 d4 g ƒ}  t j |  d" ƒ } t d5 ƒ 3 } t  j d  ƒ  | j	 | d6 d7 t
 ƒWd  QXWd  QXt ƒ  E } t  j d  ƒ - t j j | d8 ƒ } | j | d7 t
 ƒWd  QXWd  QXd  S(9   NR   R   R   R   R	   R    R!   R"   R#   R$   R%   R&   R'   R(   R)   R*   R+   R
   i   i   i   i   i   i   i   i   i	   i
   i   i   i   i   i   i   R   R   g      ð?g       @g      @g      @g      @g      @g      @g       @g      "@g      $@g      &@g      (@g      *@g      ,@g      .@g      0@R   s   /data*R,   s
   data_*.csv(   R   R   R   R   R   R   R   t   warnst   NoneR   t   strR   R4   R5   R6   t   to_csv(   R1   R   R   R7   (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_to_fmt_warnsh  s    !"s   data, compareR   R   R   R	   R
   i   i   R   R   g      ð?g       @g      @g      @t   namec         C   s  t  j d ƒ t d ƒ q } |  j | d ƒ y, t j | d d d d d ƒt sW t ‚ Wn+ t k
 r… } d	 t	 | ƒ k s† t ‚ n XWd  QXt d ƒ ú } |  j | d d
 d ƒt j | d d d d d ƒ} | j
 d k sä t ‚ | | j ƒ  |  ƒ | t j | d d d d d d d d d ƒj ƒ  t j | d d d d d ƒƒ t t j | d d d ƒj ƒ t t j | d d d ƒj ƒ k sŽt ‚ Wd  QXt d ƒ u } |  j ƒ  } | j | d d
 d ƒt j | d d d d t d d ƒ} | j
 d k sþt ‚ | | j ƒ  | ƒ Wd  QXd  S(   NR   R   s   /datat   datat	   chunksizei   R9   R   s   format='table'RT   RU   t   starti   t   stopi   t   sorted_index(   R   R   R   R   R   R   R   RA   t	   TypeErrorR]   RB   R   R   t   sortedR@   t
   sort_indext   True(   Ra   t   compareR   R    R   t   sorted_data(    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_read_hdf~  s0    "$0$c          C   s»   t  j d ƒ t j i d d d d g d 6d d d	 d
 g d 6d d d d d g ƒ}  t d ƒ U } |  j | d d d ƒt j | d d ƒ! t j | d d d d d ƒWd QXWd QXd S(   sX   Test that we can read from a file that's already opened elsewhere in
    read-only mode.R   R   R   R   R	   R
   i   i   i   i   R   R   g      ð?g       @g      @g      @R   s   /dataRT   RU   R9   R   Rb   N(	   R   R   R   R   R   R   R0   R   R   (   R   R   (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_read_hdf_multiply_open¦  s    +c          C   sP  t  j d ƒ t j i d d d d d d d d	 d
 d d d d d d d g d 6d d d d d d d d d d d d d d  d! d" g d# 6d$ d% d& d' d( d) d* d+ d, d- d. d/ d0 d1 d2 d3 d4 g ƒ}  t j |  d" ƒ } t d5 ƒ l } | j | d6 ƒ t j | d6 d7 t	 ƒ} | j
 | j
 k s!t ‚ | j | j k s9t ‚ t | | ƒ Wd  QXd  S(8   NR   R   R   R   R	   R    R!   R"   R#   R$   R%   R&   R'   R(   R)   R*   R+   R
   i   i   i   i   i   i   i   i   i	   i
   i   i   i   i   i   i   R   R   g      ð?g       @g      @g      @g      @g      @g      @g       @g      "@g      $@g      &@g      (@g      *@g      ,@g      .@g      0@R   s   /data*Re   (   R   R   R   R   R   R   R   R   R   Ri   RB   RA   t	   divisionsR   (   R   R   R   R   (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_read_hdf_multiple²  s    !c          C   sU  t  j d ƒ t j i d d d d g d 6d d d	 d
 g d 6d d d d d g ƒ}  t d ƒ ï } |  j | d d d ƒt  j t ƒ  } t j	 | d d d ƒWd  QXd t
 | ƒ k s¿ t ‚ t  j t ƒ  } t j	 | d d d ƒWd  QXd t
 | ƒ k st ‚ t  j t ƒ  } t j	 | d d d ƒWd  QXd t
 | ƒ k sKt ‚ Wd  QXd  S(   NR   R   R   R   R	   R
   i   i   i   i   R   R   g      ð?g       @g      @g      @R   s   /dataRT   RU   Rd   i
   s   number of rowsRc   s   is above or equal toRb   iÿÿÿÿs   positive integer(   R   R   R   R   R   R   RI   RJ   R   R   R]   RA   (   R   R   R    (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_read_hdf_start_stop_valuesÄ  s    +c          C   sã  t  j d ƒ t j i d d d d g d 6d d d	 d
 g d 6d d d d d g ƒ}  t ƒ  €} |  j t j j | d ƒ d d d ƒ|  j t j j | d ƒ d d d ƒ|  j t j j | d ƒ d d d ƒt	 j
 j d d ƒ ót j t j j | d ƒ d d d ƒ} | j d k s!t ‚ t j | j ƒ  |  ƒ t j t j j | d ƒ d d d d d d d	 ƒ} t j t j j | d ƒ d d d d d	 ƒ} t j | j ƒ  | ƒ t j t j j | d ƒ d d d ƒ} | j d k sét ‚ t j | j ƒ  t j |  g d ƒ ƒ t j t j j | d ƒ d d d ƒ} | j d k sKt ‚ t j | j ƒ  t j |  g d ƒ ƒ t j t j j | d ƒ d d d ƒ} | j d! k s­t ‚ t j | j ƒ  t j |  g d	 ƒ ƒ Wd  QXWd  QXd  S("   NR   R   R   R   R	   R
   i   i   i   i   R   R   g      ð?g       @g      @g      @s   one.h5s	   /foo/dataRT   RU   s   two.h5s	   /bar/dataRL   RM   s   /*/dataRb   Rc   Rd   s   *.h5i   i   i   i   (   R   R   R   R   R   R   R4   R5   R6   R@   t   configt   setR   R   RB   RA   R   R   R   t   concat(   R   t   tdirt   rest   expected(    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_hdf_globbingØ  s4    +%%%	'&'&'c          C   s0  t  j d ƒ t j i d d d d g d 6d d d	 d
 g d 6d d d d d g ƒ}  t ƒ  Í } |  j d  j t j j	 | d ƒ d d d ƒ|  j d j t j j	 | d ƒ d d d ƒt
 j j d d ƒ W t j j	 | d ƒ t j j	 | d ƒ g } t j | d ƒ } t j | j ƒ  |  ƒ Wd  QXWd  QXd  S(   NR   R   R   R   R	   R
   i   i   i   i   R   R   g      ð?g       @g      @g      @s   one.h5t	   dataframeRT   RU   s   two.h5RL   RM   (   R   R   R   R   R   R/   R   R4   R5   R6   R@   Rq   Rr   R   R   R   R   R   (   R   Rt   t   input_filesRu   (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_hdf_file_listû  s    +,,*c          C   s¨   t  j d ƒ t d ƒ ‰ }  d } t j t j j | d ƒ ƒ } t j |  d d ƒ } | j	 d | ƒ Wd  QXt
 j |  d d d	 ƒ} t | ƒ | k sž t ‚ Wd  QXd  S(
   NR   R   i(   i   R9   R:   s   /xRb   i   (   R   R   R   R   R   t   npt   randomt   randnR0   R;   R   R   t   lenRA   (   R   t   NR   t   storeRX   (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_read_hdf_doesnt_segfault
  s    c          C   s«   t  j d ƒ t j i d d d d g d 6d d d	 d
 g d 6d d d d d g ƒ}  t j |  d d ƒ} | j d d ƒ d d g k s t ‚ t j	 d ƒ t j	 d ƒ d  S(   NR   R   R   R   R	   R
   i   i   i   i   R   R   g      ð?g       @g      @g      @RB   s	   foo*.hdf5t   keys	   foo0.hdf5s	   foo1.hdf5(
   R   R   R   R   R   R   R   RA   R4   t   remove(   R   RX   (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   test_hdf_filenames  s    +$(0   t   numpyR{   t   pandasR   t   pandas.util.testingt   utilt   testingR   R4   R@   R   t   timeR    t   dask.dataframeRx   R   t
   dask.utilsR   R   R   t   dask.dataframe.utilsR   R   R3   R8   R<   R?   RC   t   markt   slowRH   RK   t   parametrizeRP   RZ   R_   R   R   t   SeriesR   Rl   Rm   Ro   Rp   Rw   Rz   R   R„   (    (    (    s?   lib/python2.7/site-packages/dask/dataframe/io/tests/test_hdf.pyt   <module>   sD   		,	/	/	*	!#	*		(	#				#		