-
Notifications
You must be signed in to change notification settings - Fork 392
Expand file tree
/
Copy path__init__.py
More file actions
110 lines (99 loc) · 2.48 KB
/
__init__.py
File metadata and controls
110 lines (99 loc) · 2.48 KB
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
from __future__ import absolute_import, division, print_function
try:
import h5py # if we import h5py after tables we segfault
except ImportError:
pass
from pandas import DataFrame
from odo import odo, convert, append, drop, resource
from odo.backends.csv import CSV
from odo.backends.json import JSON, JSONLines
from multipledispatch import halt_ordering, restart_ordering
halt_ordering() # Turn off multipledispatch ordering
from datashape import dshape, discover
from .utils import ignoring
import warnings
from .expr import (
Symbol,
broadcast_collect,
by,
cast,
coalesce,
count,
count_values,
date,
datetime,
day,
distinct,
distinct, head,
head,
hour,
join,
label,
like,
mean,
merge,
microsecond,
millisecond,
month,
ndim,
nunique,
relabel,
sample,
second,
selection,
shape,
sort,
summary,
symbol,
time,
transform,
var,
year,
)
from .expr.arrays import (tensordot, transpose)
from .expr.functions import *
from .index import create_index
from .interactive import *
from .compute.pmap import set_default_pmap
from .compute.csv import *
from .compute.json import *
from .compute.python import *
from .compute.pandas import *
from .compute.numpy import *
from .compute.core import *
from .compute.core import compute
from .cached import CachedDataset
with ignoring(ImportError):
from .server import *
with ignoring(ImportError):
from .sql import *
from .compute.sql import *
with ignoring(ImportError):
from .compute.dask import *
with ignoring(ImportError, AttributeError):
from .compute.spark import *
with ignoring(ImportError, TypeError):
from .compute.sparksql import *
with ignoring(ImportError):
from .compute.h5py import *
with ignoring(ImportError):
from .compute.hdfstore import *
with ignoring(ImportError):
from .compute.pytables import *
with ignoring(ImportError):
from .compute.chunks import *
with ignoring(ImportError):
from .compute.bcolz import *
with ignoring(ImportError):
from .mongo import *
from .compute.mongo import *
with ignoring(ImportError):
from .pytables import *
from .compute.pytables import *
from .expr import concat # Some module re-export toolz.concat and * catches it.
restart_ordering() # Restart multipledispatch ordering and do ordering
inf = float('inf')
nan = float('nan')
from ._version import get_versions
__version__ = get_versions()['version']
del get_versions