10
10
class Application ()
11
11
```
12
12
13
- [[VIEW SOURCE ]](https :// github .com / quixio / quix - streams / blob / d1c312905abaa551ea99b4db5afe2a25d428e445 / quixstreams / app .py # L56)
13
+ [[VIEW SOURCE ]](https :// github .com / quixio / quix - streams / blob / 21415a0a23d113ed8191b9a062c4abaad2b9a124 / quixstreams / app .py # L56)
14
14
15
15
The main Application class .
16
16
@@ -83,7 +83,7 @@ def __init__(broker_address: Optional[Union[str, ConnectionConfig]] = None,
83
83
processing_guarantee: ProcessingGuarantee = " at-least-once" )
84
84
```
85
85
86
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ d1c312905abaa551ea99b4db5afe2a25d428e445 / quixstreams/ app.py# L94)
86
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 21415a0a23d113ed8191b9a062c4abaad2b9a124 / quixstreams/ app.py# L94)
87
87
88
88
89
89
< br>
@@ -186,7 +186,7 @@ def Quix(
186
186
) -> Self
187
187
```
188
188
189
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ d1c312905abaa551ea99b4db5afe2a25d428e445 / quixstreams/ app.py# L330)
189
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 21415a0a23d113ed8191b9a062c4abaad2b9a124 / quixstreams/ app.py# L330)
190
190
191
191
> *** NOTE :*** DEPRECATED : use Application with `quix_sdk_token` argument instead.
192
192
@@ -297,7 +297,7 @@ def topic(name: str,
297
297
timestamp_extractor: Optional[TimestampExtractor] = None ) -> Topic
298
298
```
299
299
300
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ d1c312905abaa551ea99b4db5afe2a25d428e445 / quixstreams/ app.py# L471)
300
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 21415a0a23d113ed8191b9a062c4abaad2b9a124 / quixstreams/ app.py# L471)
301
301
302
302
Create a topic definition.
303
303
@@ -378,7 +378,7 @@ topic = app.topic("input-topic", timestamp_extractor=custom_ts_extractor)
378
378
def dataframe(topic: Topic) -> StreamingDataFrame
379
379
```
380
380
381
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ d1c312905abaa551ea99b4db5afe2a25d428e445 / quixstreams/ app.py# L551)
381
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 21415a0a23d113ed8191b9a062c4abaad2b9a124 / quixstreams/ app.py# L551)
382
382
383
383
A simple helper method that generates a `StreamingDataFrame` , which is used
384
384
@@ -428,7 +428,7 @@ to be used as an input topic.
428
428
def stop(fail: bool = False )
429
429
```
430
430
431
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ d1c312905abaa551ea99b4db5afe2a25d428e445 / quixstreams/ app.py# L590)
431
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 21415a0a23d113ed8191b9a062c4abaad2b9a124 / quixstreams/ app.py# L590)
432
432
433
433
Stop the internal poll loop and the message processing.
434
434
@@ -455,7 +455,7 @@ to unhandled exception, and it shouldn't commit the current checkpoint.
455
455
def get_producer() -> Producer
456
456
```
457
457
458
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ d1c312905abaa551ea99b4db5afe2a25d428e445 / quixstreams/ app.py# L613)
458
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 21415a0a23d113ed8191b9a062c4abaad2b9a124 / quixstreams/ app.py# L613)
459
459
460
460
Create and return a pre- configured Producer instance.
461
461
The Producer is initialized with params passed to Application.
@@ -490,7 +490,7 @@ with app.get_producer() as producer:
490
490
def get_consumer(auto_commit_enable: bool = True ) -> Consumer
491
491
```
492
492
493
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ d1c312905abaa551ea99b4db5afe2a25d428e445 / quixstreams/ app.py# L643)
493
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 21415a0a23d113ed8191b9a062c4abaad2b9a124 / quixstreams/ app.py# L643)
494
494
495
495
Create and return a pre- configured Consumer instance.
496
496
The Consumer is initialized with params passed to Application.
@@ -539,7 +539,7 @@ with app.get_consumer() as consumer:
539
539
def clear_state()
540
540
```
541
541
542
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ d1c312905abaa551ea99b4db5afe2a25d428e445 / quixstreams/ app.py# L690)
542
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 21415a0a23d113ed8191b9a062c4abaad2b9a124 / quixstreams/ app.py# L690)
543
543
544
544
Clear the state of the application.
545
545
@@ -553,7 +553,7 @@ Clear the state of the application.
553
553
def run(dataframe: StreamingDataFrame)
554
554
```
555
555
556
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ d1c312905abaa551ea99b4db5afe2a25d428e445 / quixstreams/ app.py# L696)
556
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 21415a0a23d113ed8191b9a062c4abaad2b9a124 / quixstreams/ app.py# L696)
557
557
558
558
Start processing data from Kafka using provided `StreamingDataFrame`
559
559
0 commit comments