Path	Lines of Code
DataProcessing/datax-host/src/main/scala/datax/app/BatchApp.scala	10
DataProcessing/datax-host/src/main/scala/datax/app/BlobStreamingApp.scala	14
DataProcessing/datax-host/src/main/scala/datax/app/DirectKafkaStreamingApp.scala	14
DataProcessing/datax-host/src/main/scala/datax/app/DirectLocalStreamingApp.scala	14
DataProcessing/datax-host/src/main/scala/datax/app/DirectStreamingApp.scala	14
DataProcessing/datax-host/src/main/scala/datax/app/KafkaProducer.scala	68
DataProcessing/datax-host/src/main/scala/datax/checkpoint/EventhubCheckpointer.scala	60
DataProcessing/datax-host/src/main/scala/datax/classloader/ClassLoaderHost.scala	91
DataProcessing/datax-host/src/main/scala/datax/client/cosmosdb/CosmosDBBase.scala	4
DataProcessing/datax-host/src/main/scala/datax/client/eventhub/EventHubBase.scala	18
DataProcessing/datax-host/src/main/scala/datax/client/eventhub/EventHubConf.scala	2
DataProcessing/datax-host/src/main/scala/datax/client/eventhub/EventHubSender.scala	54
DataProcessing/datax-host/src/main/scala/datax/client/http/HttpPostSender.scala	50
DataProcessing/datax-host/src/main/scala/datax/client/redis/RedisBase.scala	140
DataProcessing/datax-host/src/main/scala/datax/client/redis/RedisConnection.scala	7
DataProcessing/datax-host/src/main/scala/datax/client/sql/SqlConf.scala	21
DataProcessing/datax-host/src/main/scala/datax/config/ConfigManager.scala	105
DataProcessing/datax-host/src/main/scala/datax/data/FileInternal.scala	25
DataProcessing/datax-host/src/main/scala/datax/data/ProcessResult.scala	2
DataProcessing/datax-host/src/main/scala/datax/executor/ExecutorHelper.scala	58
DataProcessing/datax-host/src/main/scala/datax/fs/HadoopClient.scala	508
DataProcessing/datax-host/src/main/scala/datax/handler/AzureFunctionHandler.scala	52
DataProcessing/datax-host/src/main/scala/datax/handler/BuiltInFunctionsHandler.scala	11
DataProcessing/datax-host/src/main/scala/datax/handler/ExtendedUDFHandler.scala	83
DataProcessing/datax-host/src/main/scala/datax/handler/InputNormalizerHandler.scala	29
DataProcessing/datax-host/src/main/scala/datax/handler/JarUDFHandler.scala	49
DataProcessing/datax-host/src/main/scala/datax/handler/MetricsHandler.scala	22
DataProcessing/datax-host/src/main/scala/datax/handler/PreProjectionHandler.scala	30
DataProcessing/datax-host/src/main/scala/datax/handler/ProjectionHandler.scala	35
DataProcessing/datax-host/src/main/scala/datax/handler/PropertiesHandler.scala	27
DataProcessing/datax-host/src/main/scala/datax/handler/ReferenceDataHandler.scala	50
DataProcessing/datax-host/src/main/scala/datax/handler/StateTableHandler.scala	107
DataProcessing/datax-host/src/main/scala/datax/handler/TimeWindowHandler.scala	54
DataProcessing/datax-host/src/main/scala/datax/handler/TransformHandler.scala	42
DataProcessing/datax-host/src/main/scala/datax/host/BlobBatchingHost.scala	81
DataProcessing/datax-host/src/main/scala/datax/host/CommonAppHost.scala	33
DataProcessing/datax-host/src/main/scala/datax/host/Logger.scala	11
DataProcessing/datax-host/src/main/scala/datax/host/SparkJarLoader.scala	161
DataProcessing/datax-host/src/main/scala/datax/host/SparkSessionSingleton.scala	19
DataProcessing/datax-host/src/main/scala/datax/host/StreamingHost.scala	76
DataProcessing/datax-host/src/main/scala/datax/host/UdfInitializer.scala	11
DataProcessing/datax-host/src/main/scala/datax/input/BatchBlobInputSetting.scala	36
DataProcessing/datax-host/src/main/scala/datax/input/BlobPointerInput.scala	143
DataProcessing/datax-host/src/main/scala/datax/input/BlobPointerInputSetting.scala	67
DataProcessing/datax-host/src/main/scala/datax/input/EventHubInputSetting.scala	46
DataProcessing/datax-host/src/main/scala/datax/input/EventHubStreamingFactory.scala	95
DataProcessing/datax-host/src/main/scala/datax/input/InputManager.scala	5
DataProcessing/datax-host/src/main/scala/datax/input/InputSetting.scala	10
DataProcessing/datax-host/src/main/scala/datax/input/KafkaInputSetting.scala	108
DataProcessing/datax-host/src/main/scala/datax/input/KafkaStreamingFactory.scala	69
DataProcessing/datax-host/src/main/scala/datax/input/LocalInputSetting.scala	14
DataProcessing/datax-host/src/main/scala/datax/input/LocalStreamingFactory.scala	36
DataProcessing/datax-host/src/main/scala/datax/input/LocalStreamingSource.scala	23
DataProcessing/datax-host/src/main/scala/datax/input/RouterSetting.scala	46
DataProcessing/datax-host/src/main/scala/datax/input/SchemaFile.scala	24
DataProcessing/datax-host/src/main/scala/datax/input/StreamingFactory.scala	23
DataProcessing/datax-host/src/main/scala/datax/input/StreamingInputSetting.scala	17
DataProcessing/datax-host/src/main/scala/datax/processor/BatchBlobProcessor.scala	10
DataProcessing/datax-host/src/main/scala/datax/processor/BlobPointerProcessor.scala	15
DataProcessing/datax-host/src/main/scala/datax/processor/CommonProcessor.scala	22
DataProcessing/datax-host/src/main/scala/datax/processor/CommonProcessorFactory.scala	488
DataProcessing/datax-host/src/main/scala/datax/processor/DirectKafkaProcessor.scala	13
DataProcessing/datax-host/src/main/scala/datax/processor/DirectLocalProcessor.scala	13
DataProcessing/datax-host/src/main/scala/datax/processor/DirectProcessor.scala	13
DataProcessing/datax-host/src/main/scala/datax/processor/EventHubStructuredStreamingProcessor.scala	7
DataProcessing/datax-host/src/main/scala/datax/processor/JsonProcessor.scala	13
DataProcessing/datax-host/src/main/scala/datax/processor/StreamingProcessor.scala	7
DataProcessing/datax-host/src/main/scala/datax/processor/StructuredStreamingProcessor.scala	6
DataProcessing/datax-host/src/main/scala/datax/securedsetting/KeyVaultClient.scala	80
DataProcessing/datax-host/src/main/scala/datax/sink/BlobOutputSetting.scala	32
DataProcessing/datax-host/src/main/scala/datax/sink/BlobSinker.scala	190
DataProcessing/datax-host/src/main/scala/datax/sink/CosmosDBOutputSetting.scala	22
DataProcessing/datax-host/src/main/scala/datax/sink/CosmosDBSinker.scala	119
DataProcessing/datax-host/src/main/scala/datax/sink/EventHubOutputSetting.scala	36
DataProcessing/datax-host/src/main/scala/datax/sink/EventHubStreamPoster.scala	69
DataProcessing/datax-host/src/main/scala/datax/sink/HttpPostOutputSetting.scala	22
DataProcessing/datax-host/src/main/scala/datax/sink/HttpPoster.scala	67
DataProcessing/datax-host/src/main/scala/datax/sink/OutputManager.scala	131
DataProcessing/datax-host/src/main/scala/datax/sink/OutputSetting.scala	3
DataProcessing/datax-host/src/main/scala/datax/sink/SqlOutputSetting.scala	52
DataProcessing/datax-host/src/main/scala/datax/sink/SqlSinker.scala	75
DataProcessing/datax-host/src/main/scala/datax/sql/TransformSqlParser.scala	79
DataProcessing/datax-host/src/main/scala/datax/telemetry/AppInsightLogger.scala	86
DataProcessing/datax-host/src/main/scala/datax/telemetry/MetricLogger.scala	80