Skip to content
Merged
Show file tree
Hide file tree
Changes from all commits
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
9 changes: 6 additions & 3 deletions docs/api-reference/quixstreams.md
Original file line number Diff line number Diff line change
Expand Up @@ -2938,7 +2938,7 @@ It should return the final aggregation result.
class Collector(ABC, Generic[I])
```

[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/dataframe/windows/aggregations.py#L169)
[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/dataframe/windows/aggregations.py#L174)

Base class for window collections.

Expand All @@ -2958,7 +2958,7 @@ To reduce incoming items as they come in use an `Aggregator`.
def column() -> Column
```

[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/dataframe/windows/aggregations.py#L182)
[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/dataframe/windows/aggregations.py#L187)

The column to collect.

Expand All @@ -2973,7 +2973,7 @@ Use `ROOT` to collect the whole message.
def result(items: Iterable[I]) -> Any
```

[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/dataframe/windows/aggregations.py#L191)
[[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/dataframe/windows/aggregations.py#L196)

This method is triggered when a window is closed.
It should return the final collection result.
Expand Down Expand Up @@ -3826,6 +3826,7 @@ def __init__(token: str,
time_precision: TimePrecision = "ms",
allow_missing_fields: bool = False,
include_metadata_tags: bool = False,
convert_ints_to_floats: bool = False,
batch_size: int = 1000,
enable_gzip: bool = True,
request_timeout_ms: int = 10_000,
Expand Down Expand Up @@ -3890,6 +3891,8 @@ Default - `False`
- `include_metadata_tags`: if True, includes record's key, topic,
and partition as tags.
Default - `False`.
- `convert_ints_to_floats`: if True, converts all integer values to floats.
Default - `False`.
- `batch_size`: how many records to write to InfluxDB in one request.
Note that it only affects the size of one write request, and not the number
of records flushed on each checkpoint.
Expand Down
3 changes: 3 additions & 0 deletions docs/api-reference/sinks.md
Original file line number Diff line number Diff line change
Expand Up @@ -342,6 +342,7 @@ def __init__(token: str,
time_precision: TimePrecision = "ms",
allow_missing_fields: bool = False,
include_metadata_tags: bool = False,
convert_ints_to_floats: bool = False,
batch_size: int = 1000,
enable_gzip: bool = True,
request_timeout_ms: int = 10_000,
Expand Down Expand Up @@ -408,6 +409,8 @@ Default - `False`
- `include_metadata_tags`: if True, includes record's key, topic,
and partition as tags.
Default - `False`.
- `convert_ints_to_floats`: if True, converts all integer values to floats.
Default - `False`.
- `batch_size`: how many records to write to InfluxDB in one request.
Note that it only affects the size of one write request, and not the number
of records flushed on each checkpoint.
Expand Down