OsmSegmenter

java.lang.Object
- org.ka2ddo.yaac.osm.OsmSegmenter

Direct Known Subclasses:

OsmPbfSegmenter, OsmXmlSegmenter
```
public abstract class OsmSegmenter
extends java.lang.Object
```
Common code for different OpenStreetMap dataset file format loaders.

Author:

Andrew Pavlin, KA2DDO

Nested Class Summary

Nested Classes
Modifier and Type	Class and Description
`protected static class`	`OsmSegmenter.AcceptTileSubdirsOrPlanetWays` This class provides a FileFilter for identifying the relevant temporary files for sorting the results of an OSM import.
`protected static class`	`OsmSegmenter.BoundsToNameTag` Class of bounding box to name of an area.
`protected static class`	`OsmSegmenter.OpenRandomAccessFileCache` LIFO cache for random access files, so as to minimize file opens and reloads while not exceeding the maximum number of open file descriptors.
`static interface`	`OsmSegmenter.ReportUpdates` Callback interface for OsmSegmenter instances reporting updates to a progress indicator.
`protected class`	`OsmSegmenter.WayFileSorter` This class handles the logic of sorting a temporary .ways file into the proper order for correct rendering.

Field Summary

Fields
Modifier and Type	Field and Description
`static long`	`ESTIMATED_EXTRA_TILE_SPACE` Kilobytes of free disk space needed on the tile directory's partition to handle importing a new OSM file, over and above the size of the generated new tile way and node files.
`static long`	`ESTIMATED_TEMP_TILE_SPACE` Kilobytes of free disk space needed on the temporary directory's partition to handle importing a new OSM file.
`protected static java.lang.String[]`	`FILETYPE_SUFFIXES` Filetypes for different types of Way files.
`protected static int`	`FILETYPE_SWAY` Flag indicating OSM Ways not properly labeled for rendering.
`protected static int`	`FILETYPE_WAY` Flag indicating OSM Ways properly labeled for rendering.
`protected boolean`	`flushUntiled`
`protected int`	`fullPostalQueueDelay` Total number of milliseconds the OSMImporter thread was blocked because the postal_address writing queue was full.
`protected StatusListener`	`listener`
`protected static int`	`MAX_LATITUDE` Maximum latitude in millionths of degrees.
`protected static int`	`MAX_LONGITUDE` Maximum longitude in millionths of degrees.
`protected static int`	`MAX_WAY_READ_FILES` Maximum number of Way files being read back to build Relations (to avoid exceeding operating system open file limits).
`protected static int`	`MIN_LATITUDE` Minimum latitude in millionths of degrees.
`protected static int`	`MIN_LONGITUDE` Minimum longitude in millionths of degrees.
`protected int`	`minWaysToWrite` Smallest backlog of Ways to consider opening a .ways file for writing.
`protected long`	`numAddressesSaved` Number of postal_address records written to database.
`protected int`	`numDupWaysDeleted` Counter of number of duplicate Ways deleted from the collection of Way files.
`protected int[]`	`numInvalidPostal` Number of invalid conditions for postal_address records not written to database.
`protected int`	`numNodeFiles` Counter of processed Node files (used by common reporting code).
`protected int`	`numPatchedAddresses` Total number of address records modified by Relations with additional address data,
`protected int`	`numPostalQueueEmpty` Number of times the postal_address writing queue ran empty.
`protected int`	`numPostalQueueFull` Number of times the postal_address writing queue filled up.
`protected int`	`numRelations`
`protected int`	`numSortFailures` Counter of failed sorts of Way and Node files.
`protected int`	`numTileWays`
`protected int`	`numWayFiles` Counter of processed Way files (used by common reporting code).
`protected int`	`numWayReaderOpens`
`protected int`	`numWayReads`
`protected java.io.PrintStream`	`out` PrintStream used to write the OSM import log file.
`protected NonshareableBufferedDataOutputStream`	`planetDos` Shared area for stream to planet.ways.tmp file.
`protected static org.ka2ddo.yaac.osm.OsmSegmenter.RelationsStatsMapEntryComparator`	`RELATIONS_STATS_MAP_ENTRY_COMPARATOR` Comparator to sort the per-type statistics for OSM Relations in descending order of appearances.
`static java.lang.String`	`S_LOG_TIMESTAMP_FMT` Format string for SimpleDateFormat `sdfLogTimestamp`.
`protected java.text.SimpleDateFormat`	`sdfLogTimestamp` Non-thread-safe date formatter for logging.
`protected static java.io.File`	`tileRootDirectory` File identifying the directory used by YAAC to store map tile file latitude directories.
`protected java.io.File`	`tileTmpDirectory` File identifying the directory used by OpenStreetMap importers for high-data-access-rate temporary files.
`protected java.util.ArrayList<java.io.File>`	`unsavedWayFileCache`
`protected int`	`unsavedWaysFileCounter`
`protected NonshareableBufferedDataOutputStream`	`untiledDos`
`protected static byte[]`	`WAY_INDEX_PREFILL` Buffer initialization pattern for non-existent way index records.
`protected static int`	`WAY_READBACK_BUF_SIZE` Size of buffers for `MultiBufferedRandomAccessFile`s used to read back Ways from ways files.
`protected static int`	`WAY_READBACK_MAX_BUFFERS` Quantity of buffers for `MultiBufferedRandomAccessFile`s used to read back Ways from ways files.
`protected HugeBitSet`	`wayIdUsedSet` BitSet keeping track of Way ID numbers that have been used.
`protected MultiBufferedRandomAccessFile`	`wayIndex` Disk-buffered index of where all the complete Ways (indexed by their ID's) are stored on disk.
`protected boolean`	`wayQueuesAreEmpty`
`protected GenericTaggedQueue[]`	`wayWriterQueues`
`protected java.lang.Thread`	`wayWriterThread`
`protected java.util.HashSet<java.lang.Number>`	`zeroLengthWayIds`

Constructor Summary

Constructors
Modifier Constructor and Description

protected OsmSegmenter(java.lang.String rootTilePath)
Abstract pre-constructor for any OSM file segmenter,

Constructors
Modifier	Constructor and Description
`protected`	`OsmSegmenter(java.lang.String rootTilePath)` Abstract pre-constructor for any OSM file segmenter,

Method Summary

All Methods Static Methods Instance Methods Abstract Methods Concrete Methods
Modifier and Type	Method and Description
`java.lang.String`	`checkDiskSpace(long filesize)` Check if sufficient disk space is available to import the OSM file.
`protected void`	`closePostalAddresses()` Finish any final batch of inserts and close the connection to the DB (if it was opened).
`protected static int`	`computeActiveQueueCount(GenericTaggedQueue[] queues)` Helper method to compute the current count of non-empty queues.
`protected static int`	`computeQueuesBacklog(GenericTaggedQueue[] queues)` Helper method to compute the current backlog count of queued objects.
`protected void`	`copyAddressFromNodeToOther(Relation relation)` For relation type=associated_street, copy the address information from the role=address node to all the other elements of the relation.
`static void`	`ensurePostalTablesExist(StatusListener listener, java.sql.Connection dbConn, java.io.PrintStream out)` Verify that the database tables for postal addresses have been created, create them if not, and empty the tables if they already exist so a new set of records can be inserted.
`protected static GenericTaggedQueue`	`findBiggestQueue(GenericTaggedQueue[] writerQueues, int upperLimitQueueSize)` Helper method to find the queue with the largest backlog in an array of queues.
`protected void`	`flushPostalAddressesToDB()` Flush any incomplete batches of PostalAddress record inserts.
`protected org.ka2ddo.yaac.osm.OsmSegmenter.WayIndexRecord`	`getFileForIndexedWay(long wayId)`
`protected abstract long`	`getMinHeapRequired()` Report the minimum total size of data structures that will be simultaneously allocated during import.
`protected int`	`getPostalAddressQueueSize()` Get the number of entries in the postal address writing queue.
`protected Way`	`getWayForRelation(org.ka2ddo.yaac.osm.OsmSegmenter.WayIndexRecord wayIndexRecord)`
`protected boolean`	`isPostalDbInUse()` Test if the OsmSegmenter is using the postal DB.
`abstract void`	`parse(java.io.FileInputStream fileInputStream, NonshareableCountingBufferedDataInputStream inputStream, java.io.File inputFile, boolean useFixMe, StatusListener listener)` Parse a OpenStreetMap snapshot file into YAAC's version of OpenStreetMap tiles.
`protected static java.lang.String`	`processNonStdAmenityTypes(GenericTaggedNode<?> gtn, java.lang.Object[] decodedTagArray, java.lang.String origAmenityTypeName, java.lang.String amenityTypeName)` Process non-standard amenity types that have had prefixes or suffixes attached to the type name value.
`protected java.lang.String`	`produceSortStatusMessage(java.io.File latDir)` Generate a string reporting the current state of sorting the tile files.
`static void`	`refreshMapWindows()` Tell all map windows to redraw their maps based upon the updated map tile files.
`protected void`	`tryToSetUpPostalDB(StatusListener listener)` Attempt to set up access to the postal database.
`protected void`	`updateAddressesWithStreet(Relation relation, java.lang.String relationType)` Patch PostalAddress DB records that are missing their street names but have them provided by a Relation of type "associatedStreet" or "street".
`protected void`	`writePostalAddressToDb(PostalAddress postalAddress, int latitude, int longitude)` If the postal DB is in use, insert a PostalAddress record into the database.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Field Detail
  - ESTIMATED_EXTRA_TILE_SPACE
```
public static final long ESTIMATED_EXTRA_TILE_SPACE
```
    Kilobytes of free disk space needed on the tile directory's partition to handle importing a new OSM file, over and above the size of the generated new tile way and node files.
    
    See Also:
    
    Constant Field Values
  - ESTIMATED_TEMP_TILE_SPACE
```
public static final long ESTIMATED_TEMP_TILE_SPACE
```
    Kilobytes of free disk space needed on the temporary directory's partition to handle importing a new OSM file. The temporary directory is used instead of the tile directory when the Java system property alt.tile.dir is defined; if not defined, this usage is added to the tile directory's usage.
    
    See Also:
    
    ESTIMATED_EXTRA_TILE_SPACE, Constant Field Values
  - MAX_LATITUDE
```
protected static final int MAX_LATITUDE
```
    Maximum latitude in millionths of degrees.
    
    See Also:
    
    Constant Field Values
  - MIN_LATITUDE
```
protected static final int MIN_LATITUDE
```
    Minimum latitude in millionths of degrees.
    
    See Also:
    
    Constant Field Values
  - MAX_LONGITUDE
```
protected static final int MAX_LONGITUDE
```
    Maximum longitude in millionths of degrees.
    
    See Also:
    
    Constant Field Values
  - MIN_LONGITUDE
```
protected static final int MIN_LONGITUDE
```
    Minimum longitude in millionths of degrees.
    
    See Also:
    
    Constant Field Values
  - FILETYPE_SUFFIXES
```
protected static final java.lang.String[] FILETYPE_SUFFIXES
```
    Filetypes for different types of Way files.
    
    See Also:
    
    FILETYPE_WAY, FILETYPE_SWAY
  - MAX_WAY_READ_FILES
```
protected static final int MAX_WAY_READ_FILES
```
    Maximum number of Way files being read back to build Relations (to avoid exceeding operating system open file limits).
    
    See Also:
    
    Constant Field Values
  - WAY_READBACK_BUF_SIZE
```
protected static final int WAY_READBACK_BUF_SIZE
```
    Size of buffers for MultiBufferedRandomAccessFiles used to read back Ways from ways files.
    
    See Also:
    
    Constant Field Values
  - WAY_READBACK_MAX_BUFFERS
```
protected static final int WAY_READBACK_MAX_BUFFERS
```
    Quantity of buffers for MultiBufferedRandomAccessFiles used to read back Ways from ways files.
    
    See Also:
    
    Constant Field Values
  - WAY_INDEX_PREFILL
```
protected static final byte[] WAY_INDEX_PREFILL
```
    Buffer initialization pattern for non-existent way index records.
  - FILETYPE_WAY
```
protected static final int FILETYPE_WAY
```
    Flag indicating OSM Ways properly labeled for rendering.
    
    See Also:
    
    Constant Field Values
  - FILETYPE_SWAY
```
protected static final int FILETYPE_SWAY
```
    Flag indicating OSM Ways not properly labeled for rendering.
    
    See Also:
    
    Constant Field Values
  - S_LOG_TIMESTAMP_FMT
```
public static final java.lang.String S_LOG_TIMESTAMP_FMT
```
    Format string for SimpleDateFormat sdfLogTimestamp.
    
    See Also:
    
    Constant Field Values
  - sdfLogTimestamp
```
protected final java.text.SimpleDateFormat sdfLogTimestamp
```
    Non-thread-safe date formatter for logging. If more than one thread will be doing the logging, this SimpleDateFormat instance should be cloned for the other threads.
  - numRelations
```
protected int numRelations
```
  - numWayReaderOpens
```
protected transient int numWayReaderOpens
```
  - numWayReads
```
protected transient int numWayReads
```
  - listener
```
protected StatusListener listener
```
  - numTileWays
```
protected int numTileWays
```
  - zeroLengthWayIds
```
protected transient java.util.HashSet<java.lang.Number> zeroLengthWayIds
```
  - wayWriterThread
```
protected transient java.lang.Thread wayWriterThread
```
  - wayWriterQueues
```
protected transient GenericTaggedQueue[] wayWriterQueues
```
  - wayQueuesAreEmpty
```
protected transient boolean wayQueuesAreEmpty
```
  - unsavedWaysFileCounter
```
protected transient int unsavedWaysFileCounter
```
  - untiledDos
```
protected transient NonshareableBufferedDataOutputStream untiledDos
```
  - flushUntiled
```
protected transient boolean flushUntiled
```
  - wayIndex
```
protected transient MultiBufferedRandomAccessFile wayIndex
```
    Disk-buffered index of where all the complete Ways (indexed by their ID's) are stored on disk. The record format is: byte 0 - latitude of tile file in whole degrees, or 0x80 for non-tile file bytes 1-2 - longitude of tile file in whole degrees, or 0 to N for non-tile (unsaved) way files bytes 3-7 - 40-bit file position of start of Way object's storage in file Note that files storing unsaved Ways are not permitted to exceed (1<<31) bytes, but some tiles actually have enough Ways that their file size exceeds 2 GB, so the extracted file position will be zero-extended (not sign-extended) to a seek position just in case something screws up and makes a file bigger than 2 GB. The position of a record in the index file is 8*way.id
  - wayIdUsedSet
```
protected transient HugeBitSet wayIdUsedSet
```
    BitSet keeping track of Way ID numbers that have been used.
  - unsavedWayFileCache
```
protected transient java.util.ArrayList<java.io.File> unsavedWayFileCache
```
  - minWaysToWrite
```
protected int minWaysToWrite
```
    Smallest backlog of Ways to consider opening a .ways file for writing. Used to reduce file opens and closes for small queue backlogs. May be set to zero so wayWriterThread can flush queues entirely.
  - RELATIONS_STATS_MAP_ENTRY_COMPARATOR
```
protected static final org.ka2ddo.yaac.osm.OsmSegmenter.RelationsStatsMapEntryComparator RELATIONS_STATS_MAP_ENTRY_COMPARATOR
```
    Comparator to sort the per-type statistics for OSM Relations in descending order of appearances.
  - tileRootDirectory
```
protected static java.io.File tileRootDirectory
```
    File identifying the directory used by YAAC to store map tile file latitude directories.
  - tileTmpDirectory
```
protected final java.io.File tileTmpDirectory
```
    File identifying the directory used by OpenStreetMap importers for high-data-access-rate temporary files. If not defined as a separate location, has the same value as tileRootDirectory.
    
    See Also:
    
    tileRootDirectory
  - planetDos
```
protected transient NonshareableBufferedDataOutputStream planetDos
```
    Shared area for stream to planet.ways.tmp file. Used for ocean way processing.
  - numWayFiles
```
protected transient int numWayFiles
```
    Counter of processed Way files (used by common reporting code).
  - numNodeFiles
```
protected transient int numNodeFiles
```
    Counter of processed Node files (used by common reporting code).
  - numSortFailures
```
protected transient int numSortFailures
```
    Counter of failed sorts of Way and Node files.
  - numDupWaysDeleted
```
protected transient int numDupWaysDeleted
```
    Counter of number of duplicate Ways deleted from the collection of Way files.
  - out
```
protected transient java.io.PrintStream out
```
    PrintStream used to write the OSM import log file.
  - numAddressesSaved
```
protected transient long numAddressesSaved
```
    Number of postal_address records written to database.
    
    Since:
    
    PROVIDER_API_VERSION == 47
  - numInvalidPostal
```
protected transient int[] numInvalidPostal
```
    Number of invalid conditions for postal_address records not written to database.
    
    Since:
    
    PROVIDER_API_VERSION == 47
  - numPostalQueueEmpty
```
protected transient int numPostalQueueEmpty
```
    Number of times the postal_address writing queue ran empty.
    
    Since:
    
    PROVIDER_API_VERSION == 47
    
    See Also:
    
    numPostalQueueFull
  - numPostalQueueFull
```
protected transient int numPostalQueueFull
```
    Number of times the postal_address writing queue filled up.
    
    Since:
    
    PROVIDER_API_VERSION == 47
    
    See Also:
    
    fullPostalQueueDelay, writePostalAddressToDb(PostalAddress, int, int)
  - fullPostalQueueDelay
```
protected transient int fullPostalQueueDelay
```
    Total number of milliseconds the OSMImporter thread was blocked because the postal_address writing queue was full.
    
    Since:
    
    PROVIDER_API_VERSION == 47
    
    See Also:
    
    numPostalQueueFull
  - numPatchedAddresses
```
protected transient int numPatchedAddresses
```
    Total number of address records modified by Relations with additional address data,
    
    Since:
    
    PROVIDER_API_VERSION == 47
    
    See Also:
    
    updateAddressesWithStreet(Relation, String)
- Constructor Detail
  - OsmSegmenter
```
protected OsmSegmenter(java.lang.String rootTilePath)
                throws java.io.IOException
```
    Abstract pre-constructor for any OSM file segmenter,
    
    Parameters:
    
    rootTilePath - String pathname of the configured tile directory
    
    Throws:
    
    java.io.IOException - if tile directory cannot be created
- Method Detail
  - parse
```
public abstract void parse(java.io.FileInputStream fileInputStream,
                           NonshareableCountingBufferedDataInputStream inputStream,
                           java.io.File inputFile,
                           boolean useFixMe,
                           StatusListener listener)
                    throws java.io.IOException,
                           javax.xml.parsers.ParserConfigurationException,
                           org.xml.sax.SAXException
```
    Parse a OpenStreetMap snapshot file into YAAC's version of OpenStreetMap tiles.
    
    Parameters:
    
    fileInputStream - FileInputStream underlying the input stream being used
    
    inputStream - NonshareableCountingBufferedDataInputStream reading the snapshot file of whatever format the implementing class supports
    
    inputFile - File of the OpenStreetMap snapshot file being read
    
    useFixMe - boolean true if FIXME-tagged elements of the OSM data are to be included
    
    listener - StatusListener to receive progress report of the import
    
    Throws:
    
    java.io.IOException - if the input file cannot be read or any of the output files cannot be written
    
    javax.xml.parsers.ParserConfigurationException - if the Java runtime's XML parser cannot handle its configuration parameters
    
    org.xml.sax.SAXException - if the XML parser cannot decode the file
  - getMinHeapRequired
```
protected abstract long getMinHeapRequired()
```
    Report the minimum total size of data structures that will be simultaneously allocated during import.
    
    Returns:
    
    long byte count for estimated minimum heap
  - checkDiskSpace
```
public java.lang.String checkDiskSpace(long filesize)
                                throws java.io.IOException
```
    Check if sufficient disk space is available to import the OSM file.
    
    Parameters:
    
    filesize - long byte-count size of the OSM file to read (to estimate resulting tile size)
    
    Returns:
    
    error message if not enough disk space, or null if no apparent problem
    
    Throws:
    
    java.io.IOException - if FileStores (partitions) for the two directories could not be obtained
  - findBiggestQueue
```
protected static GenericTaggedQueue findBiggestQueue(GenericTaggedQueue[] writerQueues,
                                                     int upperLimitQueueSize)
```
    Helper method to find the queue with the largest backlog in an array of queues.
    
    Parameters:
    
    writerQueues - array of GenericTaggedQueues
    
    upperLimitQueueSize - int threshold of largest queue capacity, so scan can stop as soon as the fullest possible queue is found
    
    Returns:
    
    fullest GenericTaggedQueue in array, or null if all queues are empty
  - computeQueuesBacklog
```
protected static int computeQueuesBacklog(GenericTaggedQueue[] queues)
```
    Helper method to compute the current backlog count of queued objects. This is not synchronized, so the count may be an approximation if other threads are inserting to or draining the queues.
    
    Parameters:
    
    queues - array of GenericTaggedQueues
    
    Returns:
    
    count of objects in all the queues in the array
  - computeActiveQueueCount
```
protected static int computeActiveQueueCount(GenericTaggedQueue[] queues)
```
    Helper method to compute the current count of non-empty queues. This is not synchronized, so the count may be an approximation if other threads are inserting to or draining the queues.
    
    Parameters:
    
    queues - array of GenericTaggedQueues
    
    Returns:
    
    count of non-empty queues in the array
  - produceSortStatusMessage
```
protected java.lang.String produceSortStatusMessage(java.io.File latDir)
```
    Generate a string reporting the current state of sorting the tile files.
    
    Parameters:
    
    latDir - File of the latitude diectory currently being processed
    
    Returns:
    
    formatted string of import progress
  - processNonStdAmenityTypes
```
protected static java.lang.String processNonStdAmenityTypes(GenericTaggedNode<?> gtn,
                                                            java.lang.Object[] decodedTagArray,
                                                            java.lang.String origAmenityTypeName,
                                                            java.lang.String amenityTypeName)
```
    Process non-standard amenity types that have had prefixes or suffixes attached to the type name value.
    
    Parameters:
    
    gtn - GenericTaggedNode with the amenityTypeName value
    
    decodedTagArray - GenericTaggedNode.decodedtagArray of the gtn parameter
    
    origAmenityTypeName - the String value of amenityTypeName before case-normalization and tokenizing
    
    amenityTypeName - String of the current normalized amenityTypeName token to process
    
    Returns:
    
    the passed-in amenityTypeName if not consumed, or null if it was reprocessed successfully
  - getWayForRelation
```
protected Way getWayForRelation(org.ka2ddo.yaac.osm.OsmSegmenter.WayIndexRecord wayIndexRecord)
                         throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - getFileForIndexedWay
```
protected org.ka2ddo.yaac.osm.OsmSegmenter.WayIndexRecord getFileForIndexedWay(long wayId)
                                                                        throws java.io.IOException
```
    Throws:
    
    java.io.IOException
  - refreshMapWindows
```
public static void refreshMapWindows()
```
    Tell all map windows to redraw their maps based upon the updated map tile files.
  - tryToSetUpPostalDB
```
protected void tryToSetUpPostalDB(StatusListener listener)
```
    Attempt to set up access to the postal database. Note this should not be called until after the out log file has been set up by the subclass's implementation of parse(FileInputStream, NonshareableCountingBufferedDataInputStream, File, boolean, StatusListener).
    
    Parameters:
    
    listener - StatusListener to receive DB action statuses
    
    Since:
    
    PROVIDER_API_VERSION == 47
  - ensurePostalTablesExist
```
public static void ensurePostalTablesExist(StatusListener listener,
                                           java.sql.Connection dbConn,
                                           java.io.PrintStream out)
                                    throws java.sql.SQLException
```
    Verify that the database tables for postal addresses have been created, create them if not, and empty the tables if they already exist so a new set of records can be inserted.
    
    Parameters:
    
    listener - StatusListener to receive updates, or null to not report to the UI
    
    dbConn - java.sql.Connection to use to access the database
    
    out - PrintStream to receive log messages
    
    Throws:
    
    java.sql.SQLException - if DB cannot be queried or tables cannot be created or emptied
    
    Since:
    
    PROVIDER_API_VERSION == 47
  - isPostalDbInUse
```
protected boolean isPostalDbInUse()
```
    Test if the OsmSegmenter is using the postal DB.
    
    Returns:
    
    boolean true if postal DB being used
    
    Since:
    
    PROVIDER_API_VERSION == 47
  - getPostalAddressQueueSize
```
protected int getPostalAddressQueueSize()
```
    Get the number of entries in the postal address writing queue.
    
    Returns:
    
    queue content quantity
    
    Since:
    
    PROVIDER_API_VERSION == 47
  - writePostalAddressToDb
```
protected void writePostalAddressToDb(PostalAddress postalAddress,
                                      int latitude,
                                      int longitude)
```
    If the postal DB is in use, insert a PostalAddress record into the database.
    
    Parameters:
    
    postalAddress - PostalAddress record to insert
    
    latitude - int latitude in millionths of degrees North
    
    longitude - int longitude in millionths of degrees East
    
    Since:
    
    PROVIDER_API_VERSION == 47
  - flushPostalAddressesToDB
```
protected void flushPostalAddressesToDB()
                                 throws java.io.IOException
```
    Flush any incomplete batches of PostalAddress record inserts.
    
    Throws:
    
    java.io.IOException - if inserts fail for any reason
    
    Since:
    
    PROVIDER_API_VERSION == 47
  - updateAddressesWithStreet
```
protected void updateAddressesWithStreet(Relation relation,
                                         java.lang.String relationType)
```
    Patch PostalAddress DB records that are missing their street names but have them provided by a Relation of type "associatedStreet" or "street".
    
    Parameters:
    
    relation - Relation proving the street name
    
    relationType - relation type
    
    Since:
    
    PROVIDER_API_VERSION == 47
    
    See Also:
    
    numPatchedAddresses
  - copyAddressFromNodeToOther
```
protected void copyAddressFromNodeToOther(Relation relation)
                                   throws java.io.IOException
```
    For relation type=associated_street, copy the address information from the role=address node to all the other elements of the relation.
    
    Parameters:
    
    relation - Relation to analyze
    
    Throws:
    
    java.io.IOException
    
    Since:
    
    PROVIDER_API_VERSION == 47
  - closePostalAddresses
```
protected void closePostalAddresses()
                             throws java.io.IOException
```
    Finish any final batch of inserts and close the connection to the DB (if it was opened). Note this assumes the queue was drained before this is called.
    
    Throws:
    
    java.io.IOException - if final inserts or close failed
    
    Since:
    
    PROVIDER_API_VERSION == 47

Class OsmSegmenter

Nested Class Summary

Field Summary

Constructor Summary

Method Summary

Methods inherited from class java.lang.Object

Field Detail

ESTIMATED_EXTRA_TILE_SPACE

ESTIMATED_TEMP_TILE_SPACE

MAX_LATITUDE

MIN_LATITUDE

MAX_LONGITUDE

MIN_LONGITUDE

FILETYPE_SUFFIXES

MAX_WAY_READ_FILES

WAY_READBACK_BUF_SIZE

WAY_READBACK_MAX_BUFFERS

WAY_INDEX_PREFILL

FILETYPE_WAY

FILETYPE_SWAY

S_LOG_TIMESTAMP_FMT

sdfLogTimestamp

numRelations

numWayReaderOpens

numWayReads

listener

numTileWays

zeroLengthWayIds

wayWriterThread

wayWriterQueues

wayQueuesAreEmpty

unsavedWaysFileCounter

untiledDos

flushUntiled

wayIndex

wayIdUsedSet

unsavedWayFileCache

minWaysToWrite

RELATIONS_STATS_MAP_ENTRY_COMPARATOR

tileRootDirectory

tileTmpDirectory

planetDos

numWayFiles

numNodeFiles

numSortFailures

numDupWaysDeleted

out

numAddressesSaved

numInvalidPostal

numPostalQueueEmpty

numPostalQueueFull

fullPostalQueueDelay

numPatchedAddresses

Constructor Detail

OsmSegmenter

Method Detail

parse

getMinHeapRequired

checkDiskSpace

findBiggestQueue

computeQueuesBacklog

computeActiveQueueCount

produceSortStatusMessage

processNonStdAmenityTypes

getWayForRelation

getFileForIndexedWay

refreshMapWindows

tryToSetUpPostalDB

ensurePostalTablesExist

isPostalDbInUse

getPostalAddressQueueSize

writePostalAddressToDb

flushPostalAddressesToDB

updateAddressesWithStreet

copyAddressFromNodeToOther

closePostalAddresses