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
    • TableEnvironment
    • Table
    • Data Types
    • Window
    • Expressions
    • User Defined Functions
    • Descriptors
    • StatementSet
    • Catalog
  • PyFlink DataStream
  • PyFlink DataFrame
  • PyFlink Common
  • API Reference
  • PyFlink Table
  • Expressions
  • pyflink.table.expressions.unix_timestamp

pyflink.table.expressions.unix_timestamp#

unix_timestamp(date_str: str | Expression[str] | None = None, format: str | Expression[str] | None = None) → Expression[source]#

Gets the current unix timestamp in seconds if no arguments are not specified. This function is not deterministic which means the value would be recalculated for each record.

If the date time string date_str is specified, it will convert the given date time string in the specified format (by default: yyyy-MM-dd HH:mm:ss if not specified) to unix timestamp (in seconds), using the specified timezone in table config.

Added in version 1.12.0.

previous

pyflink.table.expressions.from_unixtime

next

pyflink.table.expressions.array

On this page
  • unix_timestamp()

This Page

  • Show Source

Created using Sphinx 7.4.7.

Built with the PyData Sphinx Theme 0.16.1.