| __enter__(self) | grepros.outputs.Sink | |
| __exit__(self, exc_type, exc_value, traceback) | grepros.outputs.Sink | |
| __init__(self, args=None, **kwargs) | grepros.plugins.parquet.ParquetSink | |
| _batch_meta | grepros.outputs.Sink | private |
| _caches | grepros.plugins.parquet.ParquetSink | private |
| _close_printed | grepros.plugins.parquet.ParquetSink | private |
| _configure(self) | grepros.plugins.parquet.ParquetSink | private |
| _configure_ids(self) | grepros.plugins.parquet.ParquetSink | private |
| _counts | grepros.outputs.Sink | private |
| _ensure_stamp_index(self, topic, msg, stamp=None, index=None) | grepros.outputs.Sink | private |
| _extra_basecols | grepros.plugins.parquet.ParquetSink | private |
| _extra_basevals | grepros.plugins.parquet.ParquetSink | private |
| _filebase | grepros.plugins.parquet.ParquetSink | private |
| _filenames | grepros.plugins.parquet.ParquetSink | private |
| _idgenerator | grepros.plugins.parquet.ParquetSink | private |
| _make_column_type(self, typename, fallback=None) | grepros.plugins.parquet.ParquetSink | private |
| _make_column_value(self, value, typename=None) | grepros.plugins.parquet.ParquetSink | private |
| _nesting | grepros.plugins.parquet.ParquetSink | private |
| _overwrite | grepros.plugins.parquet.ParquetSink | private |
| _patterns | grepros.plugins.parquet.ParquetSink | private |
| _process_message(self, topic, index, stamp, msg, match=None, rootmsg=None, parent_type=None, parent_id=None) | grepros.plugins.parquet.ParquetSink | private |
| _process_type(self, topic, msg, rootmsg=None) | grepros.plugins.parquet.ParquetSink | private |
| _schemas | grepros.plugins.parquet.ParquetSink | private |
| _write_table(self, typekey) | grepros.plugins.parquet.ParquetSink | private |
| _writers | grepros.plugins.parquet.ParquetSink | private |
| args | grepros.outputs.Sink | |
| ARROW_TYPES | grepros.plugins.parquet.ParquetSink | static |
| autodetect(cls, target) | grepros.outputs.Sink | |
| bind(self, source) | grepros.outputs.Sink | |
| CHUNK_SIZE | grepros.plugins.parquet.ParquetSink | static |
| close(self) | grepros.plugins.parquet.ParquetSink | |
| COMMON_TYPES | grepros.plugins.parquet.ParquetSink | static |
| DEFAULT_ARGS | grepros.plugins.parquet.ParquetSink | static |
| DEFAULT_TYPE | grepros.plugins.parquet.ParquetSink | static |
| emit(self, topic, msg, stamp=None, match=None, index=None) | grepros.plugins.parquet.ParquetSink | |
| emit_meta(self) | grepros.outputs.Sink | |
| FILE_EXTENSIONS | grepros.plugins.parquet.ParquetSink | static |
| flush(self) | grepros.outputs.Sink | |
| is_highlighting(self) | grepros.outputs.Sink | |
| MESSAGE_TYPE_BASECOLS | grepros.plugins.parquet.ParquetSink | static |
| MESSAGE_TYPE_BASECOLS | grepros.plugins.parquet.ParquetSink | |
| MESSAGE_TYPE_NESTCOLS | grepros.plugins.parquet.ParquetSink | static |
| MESSAGE_TYPE_NESTCOLS | grepros.plugins.parquet.ParquetSink | |
| source | grepros.outputs.Sink | |
| thread_excepthook(self, text, exc) | grepros.outputs.Sink | |
| valid | grepros.plugins.parquet.ParquetSink | |
| validate(self) | grepros.plugins.parquet.ParquetSink | |
| WRITER_ARGS | grepros.plugins.parquet.ParquetSink | static |