KafkaConverter 類別
- 繼承
-
KafkaConverterKafkaConverter
建構函式
KafkaConverter()方法
| check_input_type_annotation | |
| check_output_type_annotation | |
| decode | |
| decode_multiple_events | |
| decode_single_event | |
| encode | |
| has_implicit_output |
check_input_type_annotation
check_input_type_annotation(pytype) -> bool參數
| 名稱 | Description |
|---|---|
|
pytype
必要
|
|
check_output_type_annotation
check_output_type_annotation(pytype) -> bool參數
| 名稱 | Description |
|---|---|
|
pytype
必要
|
|
decode
decode(data: Datum, *, trigger_metadata) -> KafkaEvent | List[KafkaEvent]參數
| 名稱 | Description |
|---|---|
|
data
必要
|
|
僅限關鍵字的參數
| 名稱 | Description |
|---|---|
|
trigger_metadata
必要
|
|
decode_multiple_events
decode_multiple_events(data: Datum, trigger_metadata) -> List[KafkaEvent]參數
| 名稱 | Description |
|---|---|
|
data
必要
|
|
|
trigger_metadata
必要
|
|
decode_single_event
decode_single_event(data: Datum, trigger_metadata) -> KafkaEvent參數
| 名稱 | Description |
|---|---|
|
data
必要
|
|
|
trigger_metadata
必要
|
|
encode
encode(obj: Any, *, expected_type: type | None) -> Datum參數
| 名稱 | Description |
|---|---|
|
obj
必要
|
|
僅限關鍵字的參數
| 名稱 | Description |
|---|---|
|
expected_type
必要
|
|
has_implicit_output
abstract classmethod has_implicit_output() -> bool