FilesExpand file tree

 master

/

test.py

Copy path

Blame

More file actions

Blame

More file actions

Latest commit

 

History

History

History

7 lines (5 loc) · 231 Bytes

 master

/

test.py

Copy path

Top

File metadata and controls

• Code
• Blame

7 lines (5 loc) · 231 Bytes

Raw

Copy raw file

Download raw file

Open symbols panel

Edit and raw actions

1

2

3

4

5

6

7

from pyflink.table import DataTypes

from pyflink.table.udf import udf

@udf(input_types=[DataTypes.STRING()], result_type=DataTypes.STRING())

def func1(s: str):

return s.replace('buy', 'sold')#把字符串中的buy替换为sold