Wrapper a row obejct for pekko-connectors #297
laglangyue
started this conversation in
General
Replies: 1 comment
-
For me, I can use Spark SQL Row and implement function to map the input and output for pekko-connectors. I am not sure if other members of pekko-community have meet this problem. |
Beta Was this translation helpful? Give feedback.
0 replies
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
I am using pekko to build ETL app,like this
I would use pekko-connector to build the reader/writer, I find a questtion is that our connector's input and output are not unified,some is bytestring,some is type T and so on.
so I will change my app,
Which I want to discussion with the community is that can we provide a simple row, like a jdbc row for connectors.
If we implement this unified row, different pekko-connectors can freely connect to each other.
Beta Was this translation helpful? Give feedback.
All reactions