Ctrl+K
Logo image Logo image

Site Navigation

  • API Reference
  • Examples

Site Navigation

  • API Reference
  • Examples

Section Navigation

  • PyFlink Table
    • TableEnvironment
    • Table
    • Data Types
    • Window
    • Expressions
    • User Defined Functions
    • Descriptors
    • StatementSet
    • Catalog
  • PyFlink DataStream
  • PyFlink Common

pyflink.table.expressions.unix_timestamp#

unix_timestamp(date_str: Optional[Union[str, Expression[str]]] = None, format: Optional[Union[str, Expression[str]]] = 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.

New in version 1.12.0.

previous

pyflink.table.expressions.from_unixtime

next

pyflink.table.expressions.array

On this page
  • unix_timestamp()
Show Source

Created using Sphinx 5.3.0.