I have a stream of events of a custom type. I want to know how to convert
these events into Rows that can be queried. More specifically how do I
attach type information to the stream of rows that is generated?

I have the following code

```
    val execEnv = StreamExecutionEnvironment.getExecutionEnvironment
    val tableEnv: StreamTableEnvironment =
TableEnvironment.getTableEnvironment(execEnv)

    val eventStream : DataStream[Event] = ...
    val rowStream: DataStream[Row] = eventStream.map({e: Event => toRow(e)})
    tableEnv.registerDataStream("some_name", rowStream)

    tableEnv.sql("select bedrooms from some_name") 
```

This code compiles. But clearly wouldn't work because I didn't specify the
type or position of `bedrooms`. 


So what API do I use to specify the typeInformation of my rowStream?



--
Sent from: http://apache-flink-user-mailing-list-archive.2336050.n4.nabble.com/

Reply via email to