Class PbfDecoder

java.lang.Object
com.graphhopper.reader.osm.pbf.PbfDecoder

public class PbfDecoder extends Object
Decodes all blocks from a PBF stream using worker threads, and passes the results to the downstream sink.

Author:
Brett Henderson
  • Constructor Details

    • PbfDecoder

      public PbfDecoder(PbfStreamSplitter streamSplitter, ExecutorService executorService, int maxPendingBlobs, Sink sink, SkipOptions skipOptions)
      Creates a new instance.

      Parameters:
      streamSplitter - The PBF stream splitter providing the source of blobs to be decoded.
      executorService - The executor service managing the thread pool.
      maxPendingBlobs - The maximum number of blobs to have in progress at any point in time.
      sink - The sink to send all decoded entities to.
  • Method Details

    • run

      public void run()