Hello all,
I am writing a utility to push data to PubSub. My data class looks
something like so:
==========
class MyData {
String someId;
Row someRow;
Row someOtherRow;
}
==============
The schema for the Rows is not known a-priori. It is contained by the Row.
I am then pushing this data to pubsub:
===========
MyData pushingData = ....
WhatCoder? coder = ....
ByteArrayOutputStream os = new ByteArrayOutputStream();
coder.encode(this, os);
pubsubClient.connect();
pubsubClient.push(PubSubMessage.newBuilder().setData(os.toByteArray()).build());
pubsubClient.close();
=================
What's the right coder to use in this case? I don't know if SchemaCoder
will work, because it seems that it requires the Row's schema a priori. I
have not been able to make AvroCoder work.
Any tips?
Best
-P.
