|
21 | 21 | The Pulsar Python client library is based on the existing C++ client library. |
22 | 22 | All the same features are exposed through the Python interface. |
23 | 23 |
|
24 | | -Currently, the supported Python versions are 3.9, 3.10, 3.11, 3.12, 3.13, and 3.14. |
| 24 | +Currently, the supported Python versions are 3.7, 3.8, 3.9, 3.10, 3.11, 3.12, 3.13, and 3.14. |
25 | 25 |
|
26 | 26 | ================= |
27 | 27 | Install from PyPI |
|
43 | 43 | """ |
44 | 44 |
|
45 | 45 | import logging |
46 | | -from typing import Callable, List, Optional, Tuple, Union |
| 46 | +from typing import Callable, List, Tuple, Optional, Union |
47 | 47 |
|
48 | 48 | import _pulsar |
49 | | -from _pulsar import ( |
50 | | - BatchingType, |
51 | | - BatchReceivePolicy, |
52 | | - CompressionType, |
53 | | - ConsumerCryptoFailureAction, |
54 | | - ConsumerType, |
55 | | - DeadLetterPolicyBuilder, # noqa: F401 |
56 | | - InitialPosition, |
57 | | - KeySharedMode, |
58 | | - KeySharedPolicy, |
59 | | - LoggerLevel, |
60 | | - PartitionsRoutingMode, |
61 | | - ProducerAccessMode, |
62 | | - RegexSubscriptionMode, |
63 | | - Result, |
64 | | -) |
65 | 49 |
|
66 | | -from pulsar import schema |
| 50 | +from _pulsar import Result, CompressionType, ConsumerType, InitialPosition, PartitionsRoutingMode, BatchingType, \ |
| 51 | + LoggerLevel, BatchReceivePolicy, KeySharedPolicy, KeySharedMode, ProducerAccessMode, RegexSubscriptionMode, \ |
| 52 | + DeadLetterPolicyBuilder, ConsumerCryptoFailureAction # noqa: F401 |
| 53 | + |
67 | 54 | from pulsar.__about__ import __version__ |
| 55 | + |
68 | 56 | from pulsar.exceptions import * |
69 | | -from pulsar.functions.context import Context |
70 | | -from pulsar.functions.function import Function |
71 | | -from pulsar.functions.serde import IdentitySerDe, PickleSerDe, SerDe |
72 | 57 | from pulsar.schema.schema import BytesSchema |
73 | 58 | from pulsar.tableview import TableView |
74 | 59 |
|
| 60 | +from pulsar.functions.function import Function |
| 61 | +from pulsar.functions.context import Context |
| 62 | +from pulsar.functions.serde import SerDe, IdentitySerDe, PickleSerDe |
| 63 | +from pulsar import schema |
75 | 64 | _schema = schema |
76 | 65 |
|
77 | 66 | import re |
78 | | - |
79 | 67 | _retype = type(re.compile('x')) |
80 | 68 |
|
81 | 69 | from datetime import timedelta |
|
0 commit comments