Method add

python/pathway/internals/helpers.py:112–113 · view source on GitHub ↗

(self, element: T)

Source from the content-addressed store, hash-verified

110	return f"{type_name}({values})"
111
112	def add(self, element: T) -> None:
113	self._inner[element] = None
114
115	def discard(self, element: T) -> None:
116	self._inner.pop(element, None)

_table_joinMethod · 0.95

dependenciesMethod · 0.95

input_operatorsMethod · 0.95

_compute_column_dependencies_iterateMethod · 0.95

computeMethod · 0.95

maybe_flatten_input_storagesMethod · 0.95

computeMethod · 0.95

fuzzy_match_tablesFunction · 0.95

get_snapshot_diffMethod · 0.45

add_nodeMethod · 0.45

relevant_nodesMethod · 0.45

no outgoing calls

run_single_iterationFunction · 0.36

test_iceberg_streamingFunction · 0.36

test_mssql_read_static_no_persistence_with_partial_cdc_captured_columnsFunction · 0.36

test_mssql_read_rejects_multiple_capture_instancesFunction · 0.36

test_neondb_streaming_cdcFunction · 0.36

test_elasticsearch_streaming_detects_late_arrival_below_max_timestampFunction · 0.36

test_postgres_inputFunction · 0.36

test_parse_pdf_multi_page_outputFunction · 0.36

run_csv_reader_with_path_filterFunction · 0.36

topic_statsMethod · 0.36

test_kafka_static_modeFunction · 0.36

test_kafka_message_metadataFunction · 0.36