protected static Map < String , WriteWindowedToBigQuery . FieldInfo < Double > > configureSessionWindowWrite ( ) { Map < String , WriteWindowedToBigQuery . FieldInfo < Double > > tableConfigure = new HashMap <> ( ) ; tableConfigure . put ( "window_start" , new WriteWindowedToBigQuery . FieldInfo <> ( "STRING" , ( c , w ) -> { IntervalWindow window = ( IntervalWindow ) w ; return GameConstants . DATE_TIME_FORMATTER . print ( window . start ( ) ) ; } ) ) ; tableConfigure . put ( "mean_duration" , new WriteWindowedToBigQuery . FieldInfo <> ( "FLOAT" , ( c , w ) -> c . element ( ) ) ) ; return tableConfigure ; }
Create a map of information that describes how to write pipeline output to BigQuery . This map is used to write information about mean user session time .