bulkimport/src/main/java/com/microsoft/azure/documentdb/bulkimport/DocumentBulkImporter.java
private void initialize() throws DocumentClientException {
        logger.debug("Initializing ...");

        this.bulkImportStoredProcLink = String.format("%s/sprocs/%s", collectionLink, BULK_IMPORT_STORED_PROCECURE_NAME);

        logger.trace("Fetching partition map of collection");
        Range<String> fullRange = new Range<String>(
                PartitionKeyInternal.MinimumInclusiveEffectivePartitionKey,
                PartitionKeyInternal.MaximumExclusiveEffectivePartitionKey,
                true,
                false);

        this.collectionRoutingMap = getCollectionRoutingMap(client);
        Collection<PartitionKeyRange> partitionKeyRanges = this.collectionRoutingMap.getOverlappingRanges(fullRange);

        this.partitionKeyRangeIds = partitionKeyRanges.stream().map(partitionKeyRange -> partitionKeyRange.getId()).collect(Collectors.toList());

        logger.debug("Initialization completed");
    }
private void initialize() throws DocumentClientException {
        logger.debug("Initializing ...");

        this.bulkImportStoredProcLink = String.format("%s/sprocs/%s", collectionLink, BULK_IMPORT_STORED_PROCECURE_NAME);

        logger.trace("Fetching partition map of collection");
        Range<String> fullRange = new Range<String>(
                PartitionKeyInternal.MinimumInclusiveEffectivePartitionKey,
                PartitionKeyInternal.MaximumExclusiveEffectivePartitionKey,
                true,
                false);

        this.collectionRoutingMap = getCollectionRoutingMap(client);
        Collection<PartitionKeyRange> partitionKeyRanges = this.collectionRoutingMap.getOverlappingRanges(fullRange);

        this.partitionKeyRangeIds = partitionKeyRanges.stream().map(partitionKeyRange -> partitionKeyRange.getId()).collect(Collectors.toList());

        logger.debug("Initialization completed");
    }
private void initialize ( ) throws DocumentClientException { logger . debug ( "Initializing ..." ) ; this . bulkImportStoredProcLink = String . format ( "%s/sprocs/%s" , collectionLink , BULK_IMPORT_STORED_PROCECURE_NAME ) ; logger . trace ( "Fetching partition map of collection" ) ; Range < String > fullRange = new Range < String > ( PartitionKeyInternal . MinimumInclusiveEffectivePartitionKey , PartitionKeyInternal . MaximumExclusiveEffectivePartitionKey , true , false ) ; this . collectionRoutingMap = getCollectionRoutingMap ( client ) ; Collection < PartitionKeyRange > partitionKeyRanges = this . collectionRoutingMap . getOverlappingRanges ( fullRange ) ; this . partitionKeyRangeIds = partitionKeyRanges . stream ( ) . map ( partitionKeyRange -> partitionKeyRange . getId ( ) ) . collect ( Collectors . toList ( ) ) ; logger . debug ( "Initialization completed" ) ; }
Initializes {@link DocumentBulkImporter}. This happens only once
@throws DocumentClientException
Initializes {