AskOverflow.Dev

AskOverflow.Dev Logo AskOverflow.Dev Logo

AskOverflow.Dev Navigation

  • Início
  • system&network
  • Ubuntu
  • Unix
  • DBA
  • Computer
  • Coding
  • LangChain

Mobile menu

Close
  • Início
  • system&network
    • Recentes
    • Highest score
    • tags
  • Ubuntu
    • Recentes
    • Highest score
    • tags
  • Unix
    • Recentes
    • tags
  • DBA
    • Recentes
    • tags
  • Computer
    • Recentes
    • tags
  • Coding
    • Recentes
    • tags
Início / coding / Perguntas / 79429531
Accepted
Quinten
Quinten
Asked: 2025-02-11 17:57:15 +0800 CST2025-02-11 17:57:15 +0800 CST 2025-02-11 17:57:15 +0800 CST

Selecione a primeira e a última linha por grupo no dataframe Polars

  • 772

Estou tentando usar polarsdataframe onde gostaria de selecionar a linha firste lastpor grupo. Aqui está um exemplo simples selecionando a primeira linha por grupo:

import polars as pl

df = pl.DataFrame(
    {
        "a": [1, 2, 2, 3, 4, 5],
        "b": [0.5, 0.5, 4, 10, 14, 13],
        "c": [True, True, True, False, False, True],
        "d": ["Apple", "Apple", "Apple", "Banana", "Banana", "Banana"],
    }
)
result = df.group_by("d", maintain_order=True).first()
print(result)

Saída:

shape: (2, 4)
┌────────┬─────┬──────┬───────┐
│ d      ┆ a   ┆ b    ┆ c     │
│ ---    ┆ --- ┆ ---  ┆ ---   │
│ str    ┆ i64 ┆ f64  ┆ bool  │
╞════════╪═════╪══════╪═══════╡
│ Apple  ┆ 1   ┆ 0.5  ┆ true  │
│ Banana ┆ 3   ┆ 10.0 ┆ false │
└────────┴─────┴──────┴───────┘

Isso funciona bem e podemos usar .lastpara fazer isso na última fileira. Mas como podemos combinar essas duas em uma group_by?

python
  • 3 3 respostas
  • 58 Views

3 respostas

  • Voted
  1. Best Answer
    mozway
    2025-02-11T18:00:38+08:002025-02-11T18:00:38+08:00

    Como colunas

    Você pode usar agg, você terá que adicionar um suffix(ou prefix) para diferenciar os nomes das colunas:

    result = (df.group_by('d', maintain_order=True)
                .agg(pl.all().first().name.suffix('_first'),
                     pl.all().last().name.suffix('_last'))
             )
    

    Saída:

    ┌────────┬─────────┬─────────┬─────────┬────────┬────────┬────────┐
    │ d      ┆ a_first ┆ b_first ┆ c_first ┆ a_last ┆ b_last ┆ c_last │
    │ ---    ┆ ---     ┆ ---     ┆ ---     ┆ ---    ┆ ---    ┆ ---    │
    │ str    ┆ i64     ┆ f64     ┆ bool    ┆ i64    ┆ f64    ┆ bool   │
    ╞════════╪═════════╪═════════╪═════════╪════════╪════════╪════════╡
    │ Apple  ┆ 1       ┆ 0.5     ┆ true    ┆ 2      ┆ 4.0    ┆ true   │
    │ Banana ┆ 3       ┆ 10.0    ┆ false   ┆ 5      ┆ 13.0   ┆ true   │
    └────────┴─────────┴─────────┴─────────┴────────┴────────┴────────┘
    

    Como linhas

    Se você quiser várias linhas, precisará concat:

    g = df.group_by('d', maintain_order=True)
    
    result = pl.concat([g.first(), g.last()]).sort(by='d', maintain_order=True)
    

    Saída:

    ┌────────┬─────┬──────┬───────┐
    │ d      ┆ a   ┆ b    ┆ c     │
    │ ---    ┆ --- ┆ ---  ┆ ---   │
    │ str    ┆ i64 ┆ f64  ┆ bool  │
    ╞════════╪═════╪══════╪═══════╡
    │ Apple  ┆ 1   ┆ 0.5  ┆ true  │
    │ Apple  ┆ 2   ┆ 4.0  ┆ true  │
    │ Banana ┆ 3   ┆ 10.0 ┆ false │
    │ Banana ┆ 5   ┆ 13.0 ┆ true  │
    └────────┴─────┴──────┴───────┘
    

    Ou usando filtercom int_range+ over:

    result = df.filter((pl.int_range(pl.len()).over('d') == 0)
                      |(pl.int_range(pl.len(), 0, -1).over('d') == 1)
                      )
    

    Saída:

    ┌─────┬──────┬───────┬────────┐
    │ a   ┆ b    ┆ c     ┆ d      │
    │ --- ┆ ---  ┆ ---   ┆ ---    │
    │ i64 ┆ f64  ┆ bool  ┆ str    │
    ╞═════╪══════╪═══════╪════════╡
    │ 1   ┆ 0.5  ┆ true  ┆ Apple  │
    │ 2   ┆ 4.0  ┆ true  ┆ Apple  │
    │ 3   ┆ 10.0 ┆ false ┆ Banana │
    │ 5   ┆ 13.0 ┆ true  ┆ Banana │
    └─────┴──────┴───────┴────────┘
    
    • 2
  2. Hericks
    2025-02-11T20:18:56+08:002025-02-11T20:18:56+08:00

    As soluções do @mozway funcionam bem! Para completar, eu também queria compartilhar duas soluções que dependem de pl.Expr.gather.

    Em um contexto selecionado

    df.select(
        pl.all().gather([0, -1]).over("d", mapping_strategy="explode")
    )
    

    Em um contexto de agrupamento por

    (
        df
        .group_by("d", maintain_order=True)
        .agg(
            pl.all().gather([0, -1])
        )
        .explode(pl.exclude("d"))
    )
    

    Considerações sobre desempenho

    Também executei cronometragem preliminar desses métodos (no pequeno conjunto de dados de exemplo).

    Método Tempos (média ± desvio padrão de 7 execuções, 1.000 loops cada)
    group_by+concat 452 μs ± 7,34 μs por loop
    filter 396 μs ± 10,2 μs por loop
    group_by+gather 255 μs ± 4,09 μs por loop
    select+gather 172 μs ± 1,29 μs por loop
    • 2
  3. jqurious
    2025-02-11T21:57:47+08:002025-02-11T21:57:47+08:00

    Existem métodos dedicados de primeiro/último.

    • .is_first_distinct()
    • .is_last_distinct()
    df.filter(
        pl.any_horizontal(
            pl.col("d").is_first_distinct(),
            pl.col("d").is_last_distinct()
        )
    )
    
    shape: (4, 4)
    ┌─────┬──────┬───────┬────────┐
    │ a   ┆ b    ┆ c     ┆ d      │
    │ --- ┆ ---  ┆ ---   ┆ ---    │
    │ i64 ┆ f64  ┆ bool  ┆ str    │
    ╞═════╪══════╪═══════╪════════╡
    │ 1   ┆ 0.5  ┆ true  ┆ Apple  │
    │ 2   ┆ 4.0  ┆ true  ┆ Apple  │
    │ 3   ┆ 10.0 ┆ false ┆ Banana │
    │ 5   ┆ 13.0 ┆ true  ┆ Banana │
    └─────┴──────┴───────┴────────┘
    

    Você pode usar uma struct se o identificador do grupo tiver várias colunas.

    pl.struct("c", "d").is_first_distinct()
    
    • 1

relate perguntas

  • Como divido o loop for em 3 quadros de dados individuais?

  • Como verificar se todas as colunas flutuantes em um Pandas DataFrame são aproximadamente iguais ou próximas

  • Como funciona o "load_dataset", já que não está detectando arquivos de exemplo?

  • Por que a comparação de string pandas.eval() retorna False

  • Python tkinter/ ttkboostrap dateentry não funciona quando no estado somente leitura

Sidebar

Stats

  • Perguntas 205573
  • respostas 270741
  • best respostas 135370
  • utilizador 68524
  • Highest score
  • respostas
  • Marko Smith

    Reformatar números, inserindo separadores em posições fixas

    • 6 respostas
  • Marko Smith

    Por que os conceitos do C++20 causam erros de restrição cíclica, enquanto o SFINAE antigo não?

    • 2 respostas
  • Marko Smith

    Problema com extensão desinstalada automaticamente do VScode (tema Material)

    • 2 respostas
  • Marko Smith

    Vue 3: Erro na criação "Identificador esperado, mas encontrado 'import'" [duplicado]

    • 1 respostas
  • Marko Smith

    Qual é o propósito de `enum class` com um tipo subjacente especificado, mas sem enumeradores?

    • 1 respostas
  • Marko Smith

    Como faço para corrigir um erro MODULE_NOT_FOUND para um módulo que não importei manualmente?

    • 6 respostas
  • Marko Smith

    `(expression, lvalue) = rvalue` é uma atribuição válida em C ou C++? Por que alguns compiladores aceitam/rejeitam isso?

    • 3 respostas
  • Marko Smith

    Um programa vazio que não faz nada em C++ precisa de um heap de 204 KB, mas não em C

    • 1 respostas
  • Marko Smith

    PowerBI atualmente quebrado com BigQuery: problema de driver Simba com atualização do Windows

    • 2 respostas
  • Marko Smith

    AdMob: MobileAds.initialize() - "java.lang.Integer não pode ser convertido em java.lang.String" para alguns dispositivos

    • 1 respostas
  • Martin Hope
    Fantastic Mr Fox Somente o tipo copiável não é aceito na implementação std::vector do MSVC 2025-04-23 06:40:49 +0800 CST
  • Martin Hope
    Howard Hinnant Encontre o próximo dia da semana usando o cronógrafo 2025-04-21 08:30:25 +0800 CST
  • Martin Hope
    Fedor O inicializador de membro do construtor pode incluir a inicialização de outro membro? 2025-04-15 01:01:44 +0800 CST
  • Martin Hope
    Petr Filipský Por que os conceitos do C++20 causam erros de restrição cíclica, enquanto o SFINAE antigo não? 2025-03-23 21:39:40 +0800 CST
  • Martin Hope
    Catskul O C++20 mudou para permitir a conversão de `type(&)[N]` de matriz de limites conhecidos para `type(&)[]` de matriz de limites desconhecidos? 2025-03-04 06:57:53 +0800 CST
  • Martin Hope
    Stefan Pochmann Como/por que {2,3,10} e {x,3,10} com x=2 são ordenados de forma diferente? 2025-01-13 23:24:07 +0800 CST
  • Martin Hope
    Chad Feller O ponto e vírgula agora é opcional em condicionais bash com [[ .. ]] na versão 5.2? 2024-10-21 05:50:33 +0800 CST
  • Martin Hope
    Wrench Por que um traço duplo (--) faz com que esta cláusula MariaDB seja avaliada como verdadeira? 2024-05-05 13:37:20 +0800 CST
  • Martin Hope
    Waket Zheng Por que `dict(id=1, **{'id': 2})` às vezes gera `KeyError: 'id'` em vez de um TypeError? 2024-05-04 14:19:19 +0800 CST
  • Martin Hope
    user924 AdMob: MobileAds.initialize() - "java.lang.Integer não pode ser convertido em java.lang.String" para alguns dispositivos 2024-03-20 03:12:31 +0800 CST

Hot tag

python javascript c++ c# java typescript sql reactjs html

Explore

  • Início
  • Perguntas
    • Recentes
    • Highest score
  • tag
  • help

Footer

AskOverflow.Dev

About Us

  • About Us
  • Contact Us

Legal Stuff

  • Privacy Policy

Language

  • Pt
  • Server
  • Unix

© 2023 AskOverflow.DEV All Rights Reserve