@@ -2938,7 +2938,7 @@ It should return the final aggregation result.
2938
2938
class Collector(ABC, Generic[I])
2939
2939
```
2940
2940
2941
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/dataframe/windows/aggregations.py#L169 )
2941
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/dataframe/windows/aggregations.py#L174 )
2942
2942
2943
2943
Base class for window collections.
2944
2944
@@ -2958,7 +2958,7 @@ To reduce incoming items as they come in use an `Aggregator`.
2958
2958
def column() -> Column
2959
2959
```
2960
2960
2961
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/dataframe/windows/aggregations.py#L182 )
2961
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/dataframe/windows/aggregations.py#L187 )
2962
2962
2963
2963
The column to collect.
2964
2964
@@ -2973,7 +2973,7 @@ Use `ROOT` to collect the whole message.
2973
2973
def result(items: Iterable[I]) -> Any
2974
2974
```
2975
2975
2976
- [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/dataframe/windows/aggregations.py#L191 )
2976
+ [[VIEW SOURCE]](https://github.com/quixio/quix-streams/blob/main/quixstreams/dataframe/windows/aggregations.py#L196 )
2977
2977
2978
2978
This method is triggered when a window is closed.
2979
2979
It should return the final collection result.
@@ -3826,6 +3826,7 @@ def __init__(token: str,
3826
3826
time_precision: TimePrecision = "ms",
3827
3827
allow_missing_fields: bool = False,
3828
3828
include_metadata_tags: bool = False,
3829
+ convert_ints_to_floats: bool = False,
3829
3830
batch_size: int = 1000,
3830
3831
enable_gzip: bool = True,
3831
3832
request_timeout_ms: int = 10_000,
@@ -3890,6 +3891,8 @@ Default - `False`
3890
3891
- `include_metadata_tags`: if True, includes record's key, topic,
3891
3892
and partition as tags.
3892
3893
Default - `False`.
3894
+ - `convert_ints_to_floats`: if True, converts all integer values to floats.
3895
+ Default - `False`.
3893
3896
- `batch_size`: how many records to write to InfluxDB in one request.
3894
3897
Note that it only affects the size of one write request, and not the number
3895
3898
of records flushed on each checkpoint.
0 commit comments