Functions — github.com/airscholar/FlinkCommerce

CodeHub MCPcopy Create free account

hub / github.com/airscholar/FlinkCommerce / functions

Functions9 in github.com/airscholar/FlinkCommerce

⨍ Functions 9 ◇ Types & classes 7

↓ 1 callersMethodconvertTransactionToJson

(Transaction transaction)

src/main/java/utils/JsonUtil.java:10

↓ 1 callersFunctiongenerate_sales_transactions

SalesTransactionGenerator/main.py:11

↓ 1 callersFunctionmain

SalesTransactionGenerator/main.py:33

Functiondelivery_report

SalesTransactionGenerator/main.py:28

Methoddeserialize

src/main/java/Deserializer/JSONValueDeserializationSchema.java:18

MethodgetProducedType

src/main/java/Deserializer/JSONValueDeserializationSchema.java:28

MethodisEndOfStream

(Transaction transaction)

src/main/java/Deserializer/JSONValueDeserializationSchema.java:23

(String[] args)

src/main/java/FlinkCommerce/DataStreamJob.java:51

(InitializationContext context)

src/main/java/Deserializer/JSONValueDeserializationSchema.java:13