10
10
class Application ()
11
11
```
12
12
13
- [[VIEW SOURCE ]](https :// github .com / quixio / quix - streams / blob / chore / reorganize - connectors / 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
@@ -84,7 +84,7 @@ def __init__(broker_address: Optional[Union[str, ConnectionConfig]] = None,
84
84
processing_guarantee: ProcessingGuarantee = " at-least-once" )
85
85
```
86
86
87
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ chore / reorganize - connectors / quixstreams/ app.py# L101)
87
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L101)
88
88
89
89
90
90
< br>
@@ -173,7 +173,7 @@ instead of the default one.
173
173
def Quix(cls , * args, ** kwargs)
174
174
```
175
175
176
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ chore / reorganize - connectors / quixstreams/ app.py# L355)
176
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L355)
177
177
178
178
RAISES EXCEPTION : DEPRECATED .
179
179
@@ -196,7 +196,7 @@ def topic(name: str,
196
196
timestamp_extractor: Optional[TimestampExtractor] = None ) -> Topic
197
197
```
198
198
199
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ chore / reorganize - connectors / quixstreams/ app.py# L370)
199
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L370)
200
200
201
201
Create a topic definition.
202
202
@@ -278,7 +278,7 @@ def dataframe(topic: Optional[Topic] = None,
278
278
source: Optional[BaseSource] = None ) -> StreamingDataFrame
279
279
```
280
280
281
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ chore / reorganize - connectors / quixstreams/ app.py# L450)
281
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L450)
282
282
283
283
A simple helper method that generates a `StreamingDataFrame` , which is used
284
284
@@ -334,7 +334,7 @@ to be used as an input topic.
334
334
def stop(fail: bool = False )
335
335
```
336
336
337
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ chore / reorganize - connectors / quixstreams/ app.py# L505)
337
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L505)
338
338
339
339
Stop the internal poll loop and the message processing.
340
340
@@ -361,7 +361,7 @@ to unhandled exception, and it shouldn't commit the current checkpoint.
361
361
def get_producer() -> Producer
362
362
```
363
363
364
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ chore / reorganize - connectors / quixstreams/ app.py# L550)
364
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L550)
365
365
366
366
Create and return a pre- configured Producer instance.
367
367
The Producer is initialized with params passed to Application.
@@ -396,7 +396,7 @@ with app.get_producer() as producer:
396
396
def get_consumer(auto_commit_enable: bool = True ) -> Consumer
397
397
```
398
398
399
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ chore / reorganize - connectors / quixstreams/ app.py# L580)
399
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L580)
400
400
401
401
Create and return a pre- configured Consumer instance.
402
402
@@ -453,7 +453,7 @@ with app.get_consumer() as consumer:
453
453
def clear_state()
454
454
```
455
455
456
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ chore / reorganize - connectors / quixstreams/ app.py# L630)
456
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L630)
457
457
458
458
Clear the state of the application.
459
459
@@ -467,7 +467,7 @@ Clear the state of the application.
467
467
def add_source(source: BaseSource, topic: Optional[Topic] = None ) -> Topic
468
468
```
469
469
470
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ chore / reorganize - connectors / quixstreams/ app.py# L636)
470
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L636)
471
471
472
472
Add a source to the application.
473
473
@@ -493,7 +493,7 @@ Default: the source default
493
493
def run(dataframe: Optional[StreamingDataFrame] = None )
494
494
```
495
495
496
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ chore / reorganize - connectors / quixstreams/ app.py# L657)
496
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L657)
497
497
498
498
Start processing data from Kafka using provided `StreamingDataFrame`
499
499
@@ -529,7 +529,7 @@ app.run()
529
529
def setup_topics()
530
530
```
531
531
532
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ chore / reorganize - connectors / quixstreams/ app.py# L779)
532
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L779)
533
533
534
534
Validate and create the topics
535
535
@@ -541,7 +541,7 @@ Validate and create the topics
541
541
class ApplicationConfig(BaseSettings)
542
542
```
543
543
544
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ chore / reorganize - connectors / quixstreams/ app.py# L955)
544
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L955)
545
545
546
546
Immutable object holding the application configuration
547
547
@@ -564,7 +564,7 @@ def settings_customise_sources(
564
564
) -> Tuple[PydanticBaseSettingsSource, ... ]
565
565
```
566
566
567
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ chore / reorganize - connectors / quixstreams/ app.py# L990)
567
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L990)
568
568
569
569
Included to ignore reading/ setting values from the environment
570
570
@@ -578,7 +578,7 @@ Included to ignore reading/setting values from the environment
578
578
def copy(** kwargs) -> Self
579
579
```
580
580
581
- [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ chore / reorganize - connectors / quixstreams/ app.py# L1003)
581
+ [[VIEW SOURCE ]](https:// github.com/ quixio/ quix- streams/ blob/ main / quixstreams/ app.py# L1003)
582
582
583
583
Update the application config and return a copy
584
584
0 commit comments