pyella 0.1.5

Python bindings for the ella datastore.
Documentation 
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

__all__ = [
    "types",
    "table",
    "frame",
    "open",
    "connect",
    "column",
    "topic",
    "Ella",
    "now",
    "bool_",
    "int8",
    "int16",
    "int32",
    "int64",
    "uint8",
    "uint16",
    "uint32",
    "uint64",
    "float32",
    "float64",
    "timestamp",
    "duration",
    "string",
]

import numpy
import typing as T

from ella import types, table, frame
from ella.types import (
    bool_,
    int8,
    int16,
    int32,
    int64,
    uint8,
    uint16,
    uint32,
    uint64,
    float32,
    float64,
    timestamp,
    duration,
    string,
)

def now() -> numpy.datetime64: ...

class Ella:
    @property
    def tables(self) -> table.TableAccessor: ...
    @property
    def config(self) -> T.Mapping[str, T.Any]: ...
    def query(self, sql: str) -> frame.Lazy: ...
    def shutdown(self) -> None: ...
    def __enter__(self) -> "Ella": ...
    def __exit__(self, exc_type, exc_value, traceback) -> None: ...

def open(
    root: str,
    serve: T.Optional[str] = "127.0.0.1:50052",
    config: T.Optional[T.Mapping[str, T.Any]] = None,
    create: bool = False,
) -> Ella: ...
def connect(addr: str) -> Ella: ...
def column(
    name: str,
    data_type: types.DataType,
    required: bool = False,
    row_shape: T.Optional[T.Sequence[int]] = None,
) -> table.ColumnInfo: ...
def topic(
    *columns: table.ColumnInfo,
    temporary: bool = False,
    index: T.List[T.Tuple[str, bool]] = []
) -> table.TopicInfo: ...