Services/DataX.Utilities/DataX.Utilities.Blob/StorageCreator.cs (6 lines): - line 129: // TODO Refactor: Updated to Async. Validate - line 142: // TODO Refactor: Updated to Async. Validate - line 188: // TODO Refactor: Updated this line. Validate - line 195: // TODO Refactor: Updated this call to Async. Validate - line 292: // TODO Refactor: Updated to use Async - line 333: // TODO Refactor: Updated to use async. Services/DataX.Utilities/DataX.Utilities.Blob/BlobHelper.cs (5 lines): - line 28: // TODO Refactor: Updated - line 104: // TODO Refactor: Uses async - line 108: // TODO Refactor - line 162: // TODO Refactor - line 171: // TODO Refactor DataProcessing/datax-host/src/main/scala/datax/fs/HadoopClient.scala (4 lines): - line 184: .filterNot(storageAccountKeys.contains(_)) //TODO: make storageAccountKeys thread-safe - line 197: //TODO: make storageAccountKeys thread-safe - line 299: //TODO: return a iterator instead of the entire list to reduce memory consumption, may also possibly help optimize job performance - line 422: // TODO: create unique name for each temp file. Services/DataX.Flow/DataX.Flow.InteractiveQuery/HDInsight/HDInsightKernel.cs (2 lines): - line 147: // TODO Refactor - line 198: // TODO Refactor Website/Website/metrics/metricService.js (1 line): - line 58: //TODO: update to 1.1.0 of appinsight package to take latest fixes. Services/DataX.Metrics/DataX.Metrics.Ingestor/Helper/Utility.cs (1 line): - line 13: // TODO: Remove when configuration fully consolidated Services/DataX.Config/DataX.Config/ConfigGeneration/Processor/S630_GenerateProjectionFile.cs (1 line): - line 58: //TODO: make the hardcoded "Raw.*" configurable? Services/JobRunner/JobRunner.cs (1 line): - line 233: // TODO: Can in the future allow for specifiable job timeout on job baseclass. (and if >5m, immediately completes on queue) DataProcessing/datax-host/src/main/scala/datax/input/KafkaStreamingFactory.scala (1 line): - line 50: //TODO: enable external store based checkpoint Services/DataX.Flow/Flow.LiveDataService/LiveDataManager.cs (1 line): - line 17: //TODO: Change the name to represent InteractiveQuery and generateSchema combined together DataProcessing/datax-host/src/main/scala/datax/classloader/ClassLoaderHost.scala (1 line): - line 79: //TODO: ParameterizedType (aka. generic type) cannot be casted to Class[_], Services/DataX.Utilities/DataX.Utilities.EventHub/EventHubUtil.cs (1 line): - line 63: //TODO find a way to use only eventhub connection string (without using subscriptionId) DataProcessing/datax-host/src/main/scala/datax/handler/AzureFunctionHandler.scala (1 line): - line 60: // TODO: Add support for more than 3 input parameters for AzureFunction Services/DataX.Utilities/DataX.Utilities.Web/RolesCheck.cs (1 line): - line 36: /// TODO: Support adding this whitelist on Kubernetes using IConfiguration object Services/DataX.Config/DataX.Config/ConfigGeneration/Processor/S300_ValidateConfig.cs (1 line): - line 48: //TODO: implement the validations. Services/DataX.Config/DataX.Config/InternalService/SparkClusterManager.cs (1 line): - line 32: //TODO: create a client pool to reduce the creation Services/DataX.Config/DataX.Config/ConfigGeneration/Processor/S100_PortConfigurationSettings.cs (1 line): - line 68: // TODO: currently this is a whitelist only port a portion of configuration settings Website/Website/db/keyvaultClient.js (1 line): - line 93: //TODO: automate this launching the local user's browser to finish authentication Services/DataX.Flow/DataX.Flow.CodegenRules/Formatter.cs (1 line): - line 100: // TODO : some delimiter may depend from a specific Dialect/Drive (as ';' to separate multi query) DataProcessing/datax-host/src/main/scala/datax/host/SparkJarLoader.scala (1 line): - line 202: //TODO: complete the implementation Website/Website/server.js (1 line): - line 36: //TODO: move service initialization to the host Services/DataX.Utilities/DataX.Utility.KeyVault/KeyVaultUtility.cs (1 line): - line 56: //TODO: we may want to add some retries here in case network hipcups