MCPcopy
hub / github.com/pathwaycom/pathway / _flatten

Method _flatten

python/pathway/internals/table.py:2380–2403  ·  view source on GitHub ↗
(
        self,
        flatten_name: str,
    )

Source from the content-addressed store, hash-verified

2378
2379 @contextualized_operator
2380 def _flatten(
2381 self,
2382 flatten_name: str,
2383 ) -> Table:
2384 flatten_column = self._columns[flatten_name]
2385
2386 context = clmn.FlattenContext(
2387 orig_universe=self._universe,
2388 flatten_column=flatten_column,
2389 )
2390
2391 columns = {
2392 name: self._wrap_column_in_context(context, column, name)
2393 for name, column in self._columns.items()
2394 if name != flatten_name
2395 }
2396
2397 return Table(
2398 _columns={
2399 flatten_name: context.flatten_result_column,
2400 **columns,
2401 },
2402 _context=context,
2403 )
2404
2405 @trace_user_frame
2406 @desugar

Callers 2

flattenMethod · 0.80
index-BCRWi5Lr.jsFile · 0.80

Calls 3

TableClass · 0.85
itemsMethod · 0.80

Tested by

no test coverage detected