Skip to main content
Ctrl+K
PyFlink 1.20+vvr.11.7.dev0 documentation - Home PyFlink 1.20+vvr.11.7.dev0 documentation - Home
  • API Reference
  • Examples
  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
  • PyFlink DataStream
  • PyFlink DataFrame
    • DataFrame
    • DataFrame Creation
    • Input/Output
    • SQL
    • DataType
    • User Defined Functions
    • Configuration
    • GPU Support
    • AI / LLM
  • PyFlink Common
  • API Reference
  • PyFlink DataFrame
  • AI / LLM
  • pyflink.dataframe.ai.llm.LLMAccessor.ai_summarize

pyflink.dataframe.ai.llm.LLMAccessor.ai_summarize#

LLMAccessor.ai_summarize(input_col: str | Expression, max_length: int, *, provider: str = None, model: str = None, config: Dict[str, str] = None) → DataFrame[source]#

Summarize text to a maximum length.

Parameters:
  • input_col – Column name (str) or Expression for the input text.

  • max_length – Maximum length of the summary in characters. Must be greater than 0.

  • provider – Provider name.

  • model – Model name.

  • config – Optional runtime config.

Returns:

  • summary (STRING): the summarized text.

Return type:

A new DataFrame with a column appended

Example:

>>> df.llm.ai_summarize("article", 200, model="qwen-plus")

previous

pyflink.dataframe.ai.llm.LLMAccessor.ai_translate

next

pyflink.dataframe.ai.llm.LLMAccessor.ai_mask

On this page
  • LLMAccessor.ai_summarize()

This Page

  • Show Source

Created using Sphinx 7.4.7.

Built with the PyData Sphinx Theme 0.16.1.