private Map < String , List < ViewWorldbankIndicatorDataCountrySummary > > getTopicIndicatorMap ( ) { final DataContainer < ViewWorldbankIndicatorDataCountrySummary , WorldbankIndicatorDataCountrySummaryEmbeddedId > indicatorDataCountrSummaryDailyDataContainer = applicationManager . getDataContainer ( ViewWorldbankIndicatorDataCountrySummary . class ) ; return indicatorDataCountrSummaryDailyDataContainer . findListByEmbeddedProperty ( ViewWorldbankIndicatorDataCountrySummary . class , ViewWorldbankIndicatorDataCountrySummary_ . embeddedId , WorldbankIndicatorDataCountrySummaryEmbeddedId . class , WorldbankIndicatorDataCountrySummaryEmbeddedId_ . countryId , "SE" ) . parallelStream ( ) . filter ( t -> t != null && t . getSourceValue ( ) != null && t . getEndYear ( ) > DATA_POINTS_FOR_YEAR_ABOVE && t . getDataPoint ( ) > MINIMUM_NUMBER_DATA_POINTS ) . flatMap ( t -> Arrays . asList ( t . getTopics ( ) . split ( ";" ) ) . stream ( ) . map ( topic -> new AbstractMap . SimpleEntry <> ( topic , t ) ) ) . collect ( Collectors . groupingBy ( SimpleEntry :: getKey , Collectors . mapping ( SimpleEntry :: getValue , Collectors . toList ( ) ) ) ) ; }
Gets the topic indicator map .