Hi again,
To be extra sure it isn't something related to scala I've created the same
example in Java:
import java.math.BigDecimal;
> import java.time.Instant;
> import java.time.temporal.ChronoUnit;
> import org.apache.flink.api.common.typeinfo.TypeInformation;
> import org.apache.flink.streaming
Hi all,
I would like to interchangeably convert between Tables and DataStreams with
the ability to specify what are the types used in the conversion from a
POJO to a Table and vice-versa.
To convert from a POJO to a table I'm creating a Schema using a ROW-based
DataType, and to convert from a Tab
