I just did that:
public T nextRecord(final T reuse) throws IOException {
if (this.rs == null){
// throw new IOException("No table result scanner provided!");
return null;
}
...
because in the class FileSourceFunction we have:
@Override public void run(SourceContext ctx) throws Exception { while
>From the code it looks like the open method of the TableInputFormat is
never called. What are you doing differently in the
StreamingTableInputFormat?
– Ufuk
On Mon, Jun 6, 2016 at 1:49 PM, Christophe Salperwyck
wrote:
> Hi all,
>
> I am trying to read data from HBase and use the windows functi
