private CompletableFuture < List < EpochRecord > > getEpochRecords ( String scope , String stream , int epoch , OperationContext context ) { List < CompletableFuture < EpochRecord >> list = new ArrayList <> ( ) ; list . add ( streamMetadataStore . getEpoch ( scope , stream , epoch , context , executor ) ) ; list . add ( streamMetadataStore . getActiveEpoch ( scope , stream , context , true , executor ) ) ; return Futures . allOfWithResults ( list ) ; }
Fetches epoch history records for active epoch and the supplied epoch from the store .