Builds The KStream and GlobalKTable

buildingKStreamAndGlobalKTable.java

 // configuration and Serde creation left out for clarity
 KStream<String, String> dataByAirportStream = builder.stream("raw-airline-data");
 
 GlobalKTable<String, byte[]> regressionsByAirPortTable = builder.globalTable(Serdes.String(),
                                                                              byteArraySerde, 
                                                                             "onlineRegression-by-airport");
 // stream reads raw data joins with coefficients then makes prediction
 dataByAirportStream.join(regressionsByAirPortTable,
                          (k, v) -> k,
                      	  DataRegression::new)