I searched in Flink (and hbase) for GeneratedMessageV3 but didn't find any
reference.
Which version of protobuf did you use to generate the class ?
Please copy user@ in the future so that more people can help.
On Fri, Aug 4, 2017 at 8:27 AM, Sridhar Chellappa
wrote:
> public final class Custom
Can you show how CustomerMessage is defined ?
Thanks
On Fri, Aug 4, 2017 at 7:22 AM, Sridhar Chellappa
wrote:
> Folks,
>
> I wrote a custom Data source to test me CEP logic. The custom data source
> looks like :
>
> public class CustomerDataSource extends RichParallelSourceFunction {
> priv
Folks,
I wrote a custom Data source to test me CEP logic. The custom data source
looks like :
public class CustomerDataSource extends RichParallelSourceFunction {
private boolean running = true;
private final Random random;
public CustomerDataSource() {
this.random = new Rand
