@ Override public Promise < StreamSupplier < T > > read ( int partition ) { Path path = partitionPath ( partition ) ; return AsyncFile . openAsync ( executor , path , set ( READ ) ) . map ( file -> ChannelFileReader . readFile ( file ) . withBufferSize ( readBlockSize ) . transformWith ( ChannelLZ4Decompressor . create ( ) ) . transformWith ( ChannelDeserializer . create ( serializer ) ) . withLateBinding ( ) ) ; }
Returns supplier for reading data from this storage . It read it from external memory decompresses and deserializes it