File: __init__.py

package info (click to toggle)
python-streamz 0.6.5-1
  • links: PTS, VCS
  • area: main
  • in suites: forky, sid
  • size: 816 kB
  • sloc: python: 6,739; sh: 18; makefile: 16
file content (16 lines) | stat: -rw-r--r-- 307 bytes parent folder | download 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
 
from __future__ import absolute_import, division, print_function

from .core import *
from .graph import *
from .sources import *
from .sinks import *
from .plugins import load_plugins

load_plugins(Stream)

try:
    from .dask import DaskStream, scatter
except ImportError:
    pass

__version__ = '0.6.5'