10
10
class Application ()
11
11
```
12
12
13
- [[VIEW SOURCE ]](https :// github .com / quixio / quix - streams / blob / 3.0 .0 - docs / quixstreams / app .py # L63)
13
+ [[VIEW SOURCE ]](https :// github .com / quixio / quix - streams / blob / main / quixstreams / app .py # L63)
14
14
15
15
The main Application class .
16
16
@@ -85,7 +85,7 @@ def __init__(broker_address: Optional[Union[str, ConnectionConfig]] = None,
85
85
processing_guarantee: ProcessingGuarantee = " at-least-once" )
86
86
```
87
87
88
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 3.0 .0 - docs / quixstreams/ app.py# L101)
88
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L101)
89
89
90
90
91
91
< br>
@@ -174,7 +174,7 @@ instead of the default one.
174
174
def Quix(cls , * args, ** kwargs)
175
175
```
176
176
177
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 3.0 .0 - docs / quixstreams/ app.py# L356)
177
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L356)
178
178
179
179
RAISES EXCEPTION : DEPRECATED .
180
180
@@ -197,7 +197,7 @@ def topic(name: str,
197
197
timestamp_extractor: Optional[TimestampExtractor] = None ) -> Topic
198
198
```
199
199
200
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 3.0 .0 - docs / quixstreams/ app.py# L371)
200
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L371)
201
201
202
202
Create a topic definition.
203
203
@@ -279,7 +279,7 @@ def dataframe(topic: Optional[Topic] = None,
279
279
source: Optional[BaseSource] = None ) -> StreamingDataFrame
280
280
```
281
281
282
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 3.0 .0 - docs / quixstreams/ app.py# L451)
282
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L451)
283
283
284
284
A simple helper method that generates a `StreamingDataFrame` , which is used
285
285
@@ -335,7 +335,7 @@ to be used as an input topic.
335
335
def stop(fail: bool = False )
336
336
```
337
337
338
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 3.0 .0 - docs / quixstreams/ app.py# L506)
338
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L506)
339
339
340
340
Stop the internal poll loop and the message processing.
341
341
@@ -362,7 +362,7 @@ to unhandled exception, and it shouldn't commit the current checkpoint.
362
362
def get_producer() -> Producer
363
363
```
364
364
365
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 3.0 .0 - docs / quixstreams/ app.py# L551)
365
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L551)
366
366
367
367
Create and return a pre- configured Producer instance.
368
368
The Producer is initialized with params passed to Application.
@@ -397,7 +397,7 @@ with app.get_producer() as producer:
397
397
def get_consumer(auto_commit_enable: bool = True ) -> Consumer
398
398
```
399
399
400
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 3.0 .0 - docs / quixstreams/ app.py# L581)
400
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L581)
401
401
402
402
Create and return a pre- configured Consumer instance.
403
403
@@ -454,7 +454,7 @@ with app.get_consumer() as consumer:
454
454
def clear_state()
455
455
```
456
456
457
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 3.0 .0 - docs / quixstreams/ app.py# L631)
457
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L631)
458
458
459
459
Clear the state of the application.
460
460
@@ -468,7 +468,7 @@ Clear the state of the application.
468
468
def add_source(source: BaseSource, topic: Optional[Topic] = None ) -> Topic
469
469
```
470
470
471
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 3.0 .0 - docs / quixstreams/ app.py# L637)
471
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L637)
472
472
473
473
Add a source to the application.
474
474
@@ -494,7 +494,7 @@ Default: the source default
494
494
def run(dataframe: Optional[StreamingDataFrame] = None )
495
495
```
496
496
497
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 3.0 .0 - docs / quixstreams/ app.py# L658)
497
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L658)
498
498
499
499
Start processing data from Kafka using provided `StreamingDataFrame`
500
500
@@ -530,7 +530,7 @@ app.run()
530
530
def setup_topics()
531
531
```
532
532
533
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 3.0 .0 - docs / quixstreams/ app.py# L780)
533
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L780)
534
534
535
535
Validate and create the topics
536
536
@@ -542,7 +542,7 @@ Validate and create the topics
542
542
class ApplicationConfig(BaseSettings)
543
543
```
544
544
545
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 3.0 .0 - docs / quixstreams/ app.py# L956)
545
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L956)
546
546
547
547
Immutable object holding the application configuration
548
548
@@ -565,7 +565,7 @@ def settings_customise_sources(
565
565
) -> Tuple[PydanticBaseSettingsSource, ... ]
566
566
```
567
567
568
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 3.0 .0 - docs / quixstreams/ app.py# L991)
568
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L991)
569
569
570
570
Included to ignore reading/ setting values from the environment
571
571
@@ -579,7 +579,7 @@ Included to ignore reading/setting values from the environment
579
579
def copy(** kwargs) -> Self
580
580
```
581
581
582
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ 3.0 .0 - docs / quixstreams/ app.py# L1004)
582
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L1004)
583
583
584
584
Update the application config and return a copy
585
585
0 commit comments