src/main/java/com/amazonaws/services/neptune/propertygraph/io/RewriteAndMergeCsv.java [77:97]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        taskExecutor.shutdown();

        try {
            taskExecutor.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            throw new RuntimeException(e);
        }

        for (Future<MasterLabelSchema> future : futures) {
            if (future.isCancelled()) {
                throw new IllegalStateException("Unable to complete rewrite because at least one task was cancelled");
            }
            if (!future.isDone()) {
                throw new IllegalStateException("Unable to complete rewrite because at least one task has not completed");
            }
            MasterLabelSchema masterLabelSchema = future.get();
            updatedSchemas.put(masterLabelSchema.labelSchema().label(), masterLabelSchema);
        }

        return new MasterLabelSchemas(updatedSchemas, graphElementType);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -



src/main/java/com/amazonaws/services/neptune/propertygraph/io/RewriteCsv.java [76:96]:
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -
        taskExecutor.shutdown();

        try {
            taskExecutor.awaitTermination(Long.MAX_VALUE, TimeUnit.NANOSECONDS);
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
            throw new RuntimeException(e);
        }

        for (Future<MasterLabelSchema> future : futures) {
            if (future.isCancelled()) {
                throw new IllegalStateException("Unable to complete rewrite because at least one task was cancelled");
            }
            if (!future.isDone()) {
                throw new IllegalStateException("Unable to complete rewrite because at least one task has not completed");
            }
            MasterLabelSchema masterLabelSchema = future.get();
            updatedSchemas.put(masterLabelSchema.labelSchema().label(), masterLabelSchema);
        }

        return new MasterLabelSchemas(updatedSchemas, graphElementType);
- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -