import typing as T
from ella.types import DataType

class Publisher:
    def write(self, *args, **kwargs) -> None: ...
    def flush(self) -> None: ...
    def write_batch(self, *args, **kwargs) -> None: ...
    def close(self) -> None: ...
    def __enter__(self) -> "Publisher": ...
    def __exit__(self, exc_type, exc_value, traceback) -> None: ...

class Table:
    @property
    def id(self) -> str: ...
    def publish(self) -> Publisher: ...

class TableInfo: ...
class TopicInfo(TableInfo): ...

class TableAccessor:
    def get(self, table: str) -> T.Optional[Table]: ...
    def get_or_create(self, table: str, info: TableInfo) -> Table: ...
    def create(self, table: str, info: TableInfo) -> Table: ...
    def drop(self, table: str) -> None: ...
    def __getitem__(self, key: str) -> Table: ...

class ColumnInfo:
    @property
    def name(self) -> str: ...
    @property
    def dtype(self) -> DataType: ...
    @property
    def required(self) -> bool: ...
    @property
    def row_shape(self) -> T.Optional[T.List[int]]: ...