Hi to all, I have a use case where I need to tell a Flink cluster to give me a sample of X records using parametrizable sampling functions. Is there any best practice or advice to do that?
Should I create a Remote ExecutionEnvironment or should I use the Flink client (I don't know if it uses REST services or RPC or whatever)? Is there any java snippet for that? Best, Flavio
