data-accelerator
Data Accelerator for Apache Spark simplifies onboarding to Streaming of Big Data. It offers a rich, easy to use experience to help with creation, editing and management of Spark jobs on Azure HDInsights or Databricks while enabling the full power of the Spark engine.
File Explorer
Download Latest Version (.zip)- data-accelerator-bug-report.md
- data-accelerator-feature-request.md
- DataXSparkValidation.yml
- dependabot.yml
- settings.json
- HttpGetter.scala
- ManagedIdentity.scala
- DefaultValue.scala
- SettingDictionary.scala
- SettingNamespace.scala
- SparkEnvVariables.scala
- UnifiedConfig.scala
- BlobProperties.scala
- ColumnName.scala
- DatasetName.scala
- FeatureName.scala
- JobArgument.scala
- MetricName.scala
- NamePrefix.scala
- ProcessingPropertyName.scala
- ProductConstant.scala
- EngineException.scala
- DynamicUDF.scala
- PreProjectionProcessor.scala
- StringNormalizer.scala
- AppHost.scala
- ConfigService.scala
- TelemetryService.scala
- package.scala
- pom.xml
- BatchApp.scala
- BlobStreamingApp.scala
- DirectKafkaStreamingApp.scala
- DirectLocalStreamingApp.scala
- DirectStreamingApp.scala
- KafkaProducer.scala
- LocalBatchApp.scala
- EventhubCheckpointer.scala
- ClassLoaderHost.scala
- CosmosDBBase.scala
- EventHubBase.scala
- EventHubConf.scala
- EventHubSender.scala
- HttpPostSender.scala
- RedisBase.scala
- RedisConnection.scala
- SqlConf.scala
- ConfigManager.scala
- FileInternal.scala
- ProcessResult.scala
- ExecutorHelper.scala
- HadoopClient.scala
- AzureFunctionHandler.scala
- BuiltInFunctionsHandler.scala
- ExtendedUDFHandler.scala
- InputNormalizerHandler.scala
- JarUDFHandler.scala
- MetricsHandler.scala
- PreProjectionHandler.scala
- ProjectionHandler.scala
- PropertiesHandler.scala
- ReferenceDataHandler.scala
- StateTableHandler.scala
- TimeWindowHandler.scala
- TransformHandler.scala
- BlobBatchingHost.scala
- CommonAppHost.scala
- Logger.scala
- SparkJarLoader.scala
- SparkSessionSingleton.scala
- StreamingHost.scala
- UdfInitializer.scala
- BatchBlobInputSetting.scala
- BlobPointerInput.scala
- BlobPointerInputSetting.scala
- EventHubInputSetting.scala
- EventHubStreamingFactory.scala
- InputManager.scala
- InputSetting.scala
- KafkaInputSetting.scala
- KafkaStreamingFactory.scala
- LocalInputSetting.scala
- LocalStreamingFactory.scala
- LocalStreamingSource.scala
- RouterSetting.scala
- SchemaFile.scala
- StreamingFactory.scala
- StreamingInputSetting.scala
- BatchBlobProcessor.scala
- BlobPointerProcessor.scala
- CommonProcessor.scala
- CommonProcessorFactory.scala
- DirectKafkaProcessor.scala
- DirectLocalProcessor.scala
- DirectProcessor.scala
- EventHubStructuredStreamingProcessor.scala
- JsonProcessor.scala
- StreamingProcessor.scala
- StructuredStreamingProcessor.scala
- KeyVaultClient.scala
- BlobOutputSetting.scala
- BlobSinker.scala
- CosmosDBOutputSetting.scala
- CosmosDBSinker.scala
- EventHubOutputSetting.scala
- EventHubStreamPoster.scala
- HttpPoster.scala
- HttpPostOutputSetting.scala
- OutputManager.scala
- OutputSetting.scala
- SqlOutputSetting.scala
- SqlSinker.scala
- TransformSqlParser.scala
- AppInsightLogger.scala
- MetricLogger.scala
- BatchAppTests.scala
- ClassLoaderTests.scala
- ConfigManagerTests.scala
- HadoopClientTests.scala
- BlobBatchingHost.scala
- BlobPointerInputTest.scala
- RedisTests.scala
- TransformSQLParserTests.scala
- pom.xml
- with-dependencies.xml
- MANIFEST.MF
- KeyVaultMsiAuthenticatorClient.scala
- .gitignore
- pom.xml
- with-dependencies.xml
- DynamicUdfHelloWorld.scala
- RemoveInvalidChars.scala
- UdafLastThreshold.scala
- UdfHelloWorld.scala
- pom.xml
- ArgumentsParser.scala
- AzureFunctionCaller.scala
- ConcurrentDateFormat.scala
- ConverterUtil.scala
- CSVUtil.scala
- DataGenerator.scala
- DataMerger.scala
- DataNormalization.scala
- DateTimeUtil.scala
- FutureUtil.scala
- GuidUtil.scala
- GZipHelper.scala
- MapManipulation.scala
- SinkerUtil.scala
- StreamingUtility.scala
- Validation.scala
- ConcurrentDateFormatTests.scala
- DataGeneratorTests.scala
- MapManipulationTests.scala
- pom.xml
- DataX.Utility.CodeSign.csproj
- FinalPublicKey.snk
- .gitignore
- DataX.Utilities.sln
- .gitignore
- CONTRIBUTING.md
- deploy.cmd
- README.md
- Spark.nuspec
- adminsteps.parameters.txt
- commons.json
- configgenConfigs.json
- flows.json
- sparkClusters.json
- sparkJobs.json
- UtilityModule.psm1
- NuGet.exe
- Databricks-Parameter.json
- Resource-Parameter.json
- SF-Parameter.json
- Spark-AutoScale-Parameter.json
- Spark-Parameter.json
- Databricks-Template.json
- Resource-Template.json
- SF-Template.json
- Spark-AutoScale-Template.json
- Spark-Template.json
- msalmsiserver.py
- msalmsiserverapp.service
- msiserver.py
- msiserverapp.service
- startmsalmsiserverservice.sh
- startmsiserverservice.sh
- deployResources.ps1
- IotHub-Parameter.json
- Kafka-Parameter.json
- SampleOutputs-Parameter.json
- IotHub-Template.json
- Kafka-Template.json
- SampleOutputs-Template.json
- eventhub-product.json
- eventhubbatch-product.json
- eventhubkafka-product.json
- iotsample-product.json
- nativekafka-product.json
- eventhubbatch-sample.json
- iotsample.json
- eventhub-4C530FCD6194E97955B37A448BAAA78C.json
- eventhubbatch-F6968C9911243571CD556B0650EA5B19.json
- eventhubkafka-AF621A4B9DE903CF6518435E867C858A.json
- iotsample-091610A6B869B8C9318E988F390F46AB.json
- nativekafka-A219AF29664A4375E894A779DD5DCEB7.json
- devices.csv
- queryupdatesample.sql
- readme.txt
- udfsample.jar
- DataXFlow.Parameters.json
- DataXGateway.Parameters.json
- DataXMetrics.Parameters.json
- DataXSimulatedData.Parameters.json
- DataXFlow.Template.json
- DataXGateway.Template.json
- DataXMetrics.Template.json
- DataXSimulatedData.Template.json
- adminSteps.ps1
- common.parameters.txt
- deploy.bat
- deployApps.ps1
- deploySample.ps1
- runAdminSteps.bat
- jobRunner-Parameter.json
- jobRunner-Template.json
- deployResources.ps1
- README.md
- ScenarioTestDatabricks.json
- ScenarioTestHDInsights.json
- utilities.psm1
- deployment.yaml
- install-pod-identity-service.sh
- managed-service-identity-binding.yaml
- managed-service-identity.yaml
- reinstall-pod-identity-service.sh
- uninstall-pod-identity-service.sh
- Dockerfile
- finalrun.sh
- flow-interactive-query-service.yaml
- flow-live-data-service.yaml
- flow-management-service.yaml
- flow-schema-inference-service.yaml
- ResourceNameTests.ps1
- runTests.bat
- .gitignore
- README.md
- BasicLocal.json
- HomeAutomationLocal.json
- Dockerfile
- finalrun.sh
- README.md
- Data Accelerator for Apache Spark.pdf
- Data Accelerator Introductory Whitepaper.pdf
- FlowManagementControllerDelete.cs
- launchSettings.json
- appsettings.Development.json
- appsettings.json
- DataX.FlowManagement.csproj
- DataXSettings.cs
- FinalPublicKey.snk
- Program.cs
- Startup.cs
- DataX.FlowManagement.sln
- defaultFlowConfig.json
- defaultSparkJob.json
- flattenerConfig.json
- IKeyVaultClient.cs
- ISparkJobClient.cs
- ISparkJobClientFactory.cs
- SparkJobSyncResult.cs
- CommonDataConfig.cs
- FlattenerConfig.cs
- FlattenerMappingArray.cs
- FlattenerMappingDictionary.cs
- FlattenerMappingExcludeDefaultValue.cs
- FlattenerMappingObject.cs
- FlattenerMappingProps.cs
- FlattenerMappingScopedObject.cs
- FlattenerMappingStringList.cs
- FlowCommonProcessor.cs
- FlowConfig.cs
- JobMetadata.cs
- FlowGuiConfig.cs
- FlowGuiFunction.cs
- FlowGuiFunctionProperties.cs
- FlowGuiInput.cs
- FlowGuiInputBatchInput.cs
- FlowGuiInputBatchInputProperties.cs
- FlowGuiInputBatchJob.cs
- FlowGuiInputBatchJobProperties.cs
- FlowGuiInputProperties.cs
- FlowGuiJobConfig.cs
- FlowGuiOutput.cs
- FlowGuiOutputProperties.cs
- FlowGuiOutputTemplate.cs
- FlowGuiProcess.cs
- FlowGuiReferenceData.cs
- FlowGuiReferenceDataProperties.cs
- FlowGuiRule.cs
- MetricsConfig.cs
- MetricSource.cs
- MetricSourceInput.cs
- MetricSourceInputDataKey.cs
- MetricSourceOutput.cs
- MetricWidget.cs
- AzureFunctionSpec.cs
- FlowBlobOutputSpec.cs
- FlowCosmosDbOutputSpec.cs
- FlowEventHubOutputSpec.cs
- FlowHttpOutputSpec.cs
- FlowOutputSpec.cs
- FlowSqlOutputSpec.cs
- InputBatchingSpec.cs
- JarUdfSpec.cs
- ReferenceDataSpec.cs
- StateTableSpec.cs
- TimeWindowSpec.cs
- Constants.cs
- EntityConfig.cs
- JsonConfig.cs
- PropertiesDictionary.cs
- SparkClusterConfig.cs
- SparkJobConfig.cs
- SparkJobFrontEnd.cs
- ProcessorBase.cs
- S100_PortConfigurationSettings.cs
- S200_MergeDefaultConfig.cs
- S300_ValidateConfig.cs
- S400_PrepareJobConfigVariables.cs
- S450_PrepareTransformFile.cs
- S500_PrepareProjectionFile.cs
- S500_PrepareSchemaFile.cs
- S500_ResolveAzureFunction.cs
- S500_ResolveJarUDF.cs
- S500_ResolveOutputs.cs
- S500_ResolveReferenceData.cs
- S500_ResolveSparkJobParams.cs
- S500_ResolveStateTable.cs
- S500_ResolveStreamming.cs
- S500_ResolveTimestampColumn.cs
- S500_ResolveTimeWindow.cs
- S550_ResolveBatchInput.cs
- S600_GenerateJobConfig.cs
- S600_GenerateJobConfigBatch.cs
- S610_GenerateTransformFile.cs
- S630_GenerateProjectionFile.cs
- S630_GenerateSchemaFile.cs
- S650_FlattenJobConfig.cs
- S700_DeployJobConfigFile.cs
- S800_DeploySparkJob.cs
- S850_UpdateFlowMetrics.cs
- S900_Finalizer.cs
- ConfigGenerationException.cs
- DeploymentSession.cs
- FlowDeploymentSession.cs
- IFlowDeploymentProcessor.cs
- ISequentialProcessor.cs
- JobConfig.cs
- JobDeploymentSession.cs
- ConfigFlattener.cs
- ConfigFlattenerManager.cs
- DesignTimeCommonDataManager.cs
- FileBasedCommonDataManager.cs
- FlowConfigBuilder.cs
- FlowDataManager.cs
- ICommonDataManager.cs
- JobDataManager.cs
- JobState.cs
- RuleDefinitionGenerator.cs
- SparkClusterData.cs
- SparkClusterManager.cs
- SparkJobData.cs
- SparkJobOperation.cs
- SparkJobTemplateManager.cs
- FlowOperation.cs
- JobOperation.cs
- RuntimeConfigGeneration.cs
- IDesignTimeConfigStorage.cs
- IRuntimeConfigStorage.cs
- Token.cs
- TokenDictionary.cs
- TokenReplacement.cs
- TokenType.cs
- Comparison.cs
- ConfigHelper.cs
- DictionaryExtension.cs
- GenerationLockDictionary.cs
- KeyVaultUri.cs
- LocalUtility.cs
- LoggerExportDescriptorProvider.cs
- ResourcePathUtil.cs
- TaskExtensions.cs
- VersionGeneration.cs
- ConfigGenConfiguration.cs
- DataX.Config.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- IConfigGenConfigurationProvider.cs
- InitialConfiguration.cs
- CosmosDbConfigurationProvider.cs
- DataX.Config.ConfigurationProviders.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- ConnectionStringParser.cs
- DatabricksClient.cs
- DatabricksClientConnectionInfo.cs
- DatabricksClientFactory.cs
- DatabricksHttpClient.cs
- DatabricksHttpClientFactory.cs
- DatabricksHttpResult.cs
- DatabricksJobResult.cs
- DataX.Config.DatabricksClient.csproj
- FinalPublicKey.snk
- HttpMethod.cs
- IDatabricksHttpClient.cs
- IDatabricksHttpClientFactory.cs
- DatabricksClientTest.cs
- DataX.Config.DatabricksClient.Test.csproj
- CreateEventHubConsumerGroup.cs
- DataX.Config.Input.EventHub.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- DataX.Config.KeyVault.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- HashGenerator.cs
- KeyVaultClient.cs
- ConnectionStringParser.cs
- DataX.Config.LivyClient.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- HttpMethod.cs
- ILivyHttpClient.cs
- ILivyHttpClientFactory.cs
- LivyBatchesResult.cs
- LivyBatchResult.cs
- LivyClient.cs
- LivyClientConnectionInfo.cs
- LivyClientFactory.cs
- LivyHttpClient.cs
- LivyHttpClientFactory.cs
- LivyHttpResult.cs
- HttpClient.cs
- HttpClientFactory.cs
- DataX.Config.LivyClient.Test.csproj
- JobOperationTest.cs
- AzureBlobConfigStorage.cs
- CosmosDBConfigStorage.cs
- DataX.Config.Storage.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- CommonDataExtension.cs
- ConfigurationProvider.cs
- DesignTimeStorage.cs
- EventHubInputConfigGenProcessor.cs
- KeyVaultClient.cs
- RuntimeStorage.cs
- SparkJobClientFactory.cs
- config.json
- input.json
- output.conf
- batchFlow.json
- batchFlowDefault.json
- batchJobConfig.conf
- batchSparkJobTemplate.json
- configgentest-combined.txt
- customFlattenerConfig.json
- customFlow.json
- customJobConfig1.conf
- customJobConfig2.conf
- databricksFlowSaved.json
- databricksFlowStarted.json
- databricksJobConfig.conf
- databricksJobConfig.json
- dbconfiggentest-combined.txt
- flattenerConfig.json
- flowDefault.json
- flowSaved.json
- flowStarted.json
- guiInput.json
- jobConfig.conf
- jobConfig.json
- jsonTest.json
- projection.txt
- schema.json
- sparkJobTemplate.json
- CompositionTest.cs
- ConfigHelperTest.cs
- CustomRuntimeConfigGenerationTest.cs
- DatabricksRuntimeConfigGenerationTest.cs
- DataX.Config.Test.csproj
- FinalPublicKey.snk
- FlattenerTest.cs
- FlowOperationTest.cs
- GlobalSuppressions.cs
- JsonConverterTest.cs
- LoggerFactory.cs
- LoggerTest.cs
- RuleDefinitionGeneratorTest.cs
- RuntimeConfigGenerationBatchTest.cs
- RuntimeConfigGenerationTest.cs
- SparkJobOperationTest.cs
- TokenReplacementTest.cs
- CacheLogger.cs
- MockBase.cs
- DataX.Config.Test.Utility.csproj
- FinalPublicKey.snk
- ConnectionStringParser.cs
- DataX.Utility.EventHub.csproj
- EventHubInfo.cs
- EventHubManagementRestClient.cs
- EventHubUtil.cs
- FinalPublicKey.snk
- GlobalSuppressions.cs
- DataX.Utility.Extensions.csproj
- TaskExtensions.cs
- .editorconfig
- DataX.Config.CICDTests.playlist
- DataX.Config.PrimaryTests.playlist
- DataX.Config.sln
- GeneralException.cs
- ApiResult.cs
- FailedResult.cs
- Result.cs
- SuccessResult.cs
- DataXSettings.cs
- DataXSettingsConstants.cs
- DataX.Contract.csproj
- Ensure.cs
- FinalPublicKey.snk
- GlobalSuppressions.cs
- ResourceUtility.cs
- ApplicationManifest.xml
- Cloud.xml
- Local.1Node.xml
- Local.5Node.xml
- Cloud.xml
- Local.1Node.xml
- Local.5Node.xml
- Deploy-FabricApplication.ps1
- DataX.Flow.sfproj
- packages.config
- defaultOutputTemplate.xml
- defaultQueryTemplate.xml
- CodeGen.cs
- DataX.Flow.CodegenRules.csproj
- Engine.cs
- FinalPublicKey.snk
- Formatter.cs
- GlobalSuppressions.cs
- Metrics.cs
- OutputTemplates.cs
- OutputTemplates.Designer.cs
- OutputTemplates.xsc
- OutputTemplates.xsd
- OutputTemplates.xss
- QueryTemplates.cs
- Rule.cs
- cgen.txt
- CGenAggAlDerTable.txt
- CGenAggRulDerTable.txt
- CGenAggWithDot.txt
- CGenCreateMetric.txt
- CGenCreateMetric2.txt
- cgenDefault.txt
- CGenIoTSample.txt
- CGenMixedAlert.txt
- CGenMixedAlertWithTick.txt
- CGenNoCode.txt
- CGenNoPivots.txt
- CGenSimAlDerTable.txt
- CGenSimRulDerTable.txt
- CGenSimRulNonTable.txt
- CGenSimWithDot.txt
- CGenWithTick.txt
- CodegenTests.cs
- DataX.Flow.CodegenRules.Tests.csproj
- FinalPublicKey.snk
- OutputTemplates.xml
- QueryTemplates.xml
- Rules.json
- Rules2.json
- usercode.txt
- UserCodeAggAlDerTable.txt
- UserCodeAggRulDerTable.txt
- UserCodeAggWithDot.txt
- UserCodeCreateMetric.txt
- UserCodeCreateMetric2.txt
- UserCodeIoTSample.txt
- UserCodeSimAlDerTable.txt
- UserCodeSimRulDerTable.txt
- UserCodeSimRulNonTable.txt
- UserCodeSimWithDot.txt
- UserCodeWithTick.txt
- FlowConfigObject.cs
- FunctionObject.cs
- InteractiveQueryObject.cs
- ProductConfigObject.cs
- DataX.Flow.Common.csproj
- EngineEnvironment.cs
- FinalPublicKey.snk
- GlobalSuppressions.cs
- Helper.cs
- TemplateGenerator.cs
- DataX.Flow.Common.Tests.csproj
- FinalPublicKey.snk
- GeneratorHelperTests.cs
- GeneratorTests.cs
- ConfigDeleter.cs
- DataX.Flow.DeleteHelper.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- DatabricksKernel.cs
- DatabricksKernelService.cs
- HDInsightKernel.cs
- HDInsightKernelService.cs
- DataX.Flow.InteractiveQuery.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- IKernel.cs
- InteractiveQueryManager.cs
- KernelService.cs
- SetupSteps.cs
- DataX.Flow.InteractiveQuery.Tests.csproj
- InteractiveQueryTests.cs
- DataX.Flow.Scheduler.csproj
- FinalPublicKey.snk
- TimedScheduler.cs
- BlobMessageBus.cs
- EventhubMessageBus.cs
- EventProcessor.cs
- EventProcessorFactory.cs
- KafkaMessageBus.cs
- DataX.Flow.SchemaInference.csproj
- Engine.cs
- EventRaw.cs
- EventsData.cs
- FinalPublicKey.snk
- GlobalSuppressions.cs
- IMessageBus.cs
- Schema.cs
- SchemaGenerator.cs
- SchemaInferenceManager.cs
- DataX.Flow.SchemaInference.Tests.csproj
- events.json
- events4.json
- events5.json
- events5errors.txt
- FinalPublicKey.snk
- result.txt
- SchemaTests.cs
- SchemaUtilityTests.cs
- Analyzer.cs
- DataX.Flow.SqlParser.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- InputSchema.cs
- SqlParser.cs
- cgen.txt
- DataX.Flow.SqlParser.Tests.csproj
- expectedComplexTest.txt
- FinalPublicKey.snk
- inputschema.json
- SqlParserTests.cs
- usercode.txt
- DataX.Utilities.Composition.csproj
- FinalPublicKey.snk
- InstanceExportDescriptorProvider.cs
- DataX.Utility.ServiceCommunication.csproj
- FinalPublicKey.snk
- InterServiceCommunicator.cs
- ConnectedService.json
- InteractiveQueryController.cs
- Settings.xml
- ServiceManifest.xml
- launchSettings.json
- app.config
- appsettings.Development.json
- appsettings.json
- FinalPublicKey.snk
- Flow.InteractiveQueryService.csproj
- FlowInteractiveQueryServiceStartup.cs
- GlobalSuppressions.cs
- InteractiveQueryService.cs
- Program.cs
- ServiceEventSource.cs
- ConnectedService.json
- LiveDataController.cs
- Settings.xml
- ServiceManifest.xml
- launchSettings.json
- app.config
- appsettings.Development.json
- appsettings.json
- FinalPublicKey.snk
- Flow.LiveDataService.csproj
- FlowLiveDataServiceStartup.cs
- GlobalSuppressions.cs
- LiveDataManager.cs
- LiveDataService.cs
- Program.cs
- ServiceEventSource.cs
- ConnectedService.json
- FlowManagementController.cs
- FlowManagementControllerDelete.cs
- Settings.xml
- ServiceManifest.xml
- launchSettings.json
- app.config
- appsettings.Development.json
- appsettings.json
- FinalPublicKey.snk
- Flow.ManagementService.csproj
- FlowManagementService.cs
- FlowManagementServiceStartup.cs
- GlobalSuppressions.cs
- Program.cs
- ServiceCollectionExtensions.cs
- ServiceEventSource.cs
- ConnectedService.json
- SchemaInferenceController.cs
- Settings.xml
- ServiceManifest.xml
- launchSettings.json
- app.config
- appsettings.Development.json
- appsettings.json
- FinalPublicKey.snk
- Flow.SchemaInferenceService.csproj
- FlowSchemaInferenceServiceStartup.cs
- GlobalSuppressions.cs
- Program.cs
- SchemaInferenceService.cs
- ServiceEventSource.cs
- DataX.Flow.sln
- Flow.nuspec
- GitVersion.yml
- README.md
- ApplicationManifest.xml
- Cloud.xml
- Local.1Node.xml
- Local.5Node.xml
- Cloud.xml
- Local.1Node.xml
- Local.5Node.xml
- Deploy-FabricApplication.ps1
- DataX.Gateway.sfproj
- packages.config
- GatewayController.cs
- Settings.xml
- ServiceManifest.xml
- AssemblyInfo.cs
- Api.cs
- App.config
- DataX.Gateway.Api.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- JsonContentNegotiator.cs
- OwinCommunicationListener.cs
- packages.config
- Program.cs
- Startup.cs
- Validator.cs
- AssemblyInfo.cs
- app.config
- DataX.Gateway.Api.Tests.csproj
- FinalPublicKey.snk
- packages.config
- Constants.cs
- DataX.Gateway.Contract.csproj
- FinalPublicKey.snk
- DataX.Gateway.sln
- DataXGateway.nuspec
- GitVersion.yml
- ApplicationManifest.xml
- Cloud.xml
- Local.1Node.xml
- Local.5Node.xml
- Cloud.xml
- Local.1Node.xml
- Local.5Node.xml
- Deploy-FabricApplication.ps1
- DataX.Metrics.sfproj
- packages.config
- ConnectedService.json
- IngestorEventProcessor.cs
- IngestorEventProcessorFactory.cs
- MetricItem.cs
- MetricOutput.cs
- SecretStore.cs
- Utility.cs
- Settings.xml
- ServiceManifest.xml
- launchSettings.json
- appsettings.Development.json
- appsettings.json
- DataX.Metrics.Ingestor.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- Ingestor.cs
- Program.cs
- ServiceEventSource.cs
- Startup.cs
- DataX.Metrics.Tests.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- MetricsIngestorTests.cs
- DataX.Metrics.sln
- DataXMetrics.nuspec
- GitVersion.yml
- DataXOneBoxRequirement.cs
- DataXAuthRequirement.cs
- DataX.ServiceHost.csproj
- FinalPublicKey.snk
- HostUtil.cs
- DataXAuthorizationExtensions.cs
- DataXReaderRequirement.cs
- DataXWriterRequirement.cs
- DataXReaderAttribute.cs
- DataXWriterAttribute.cs
- DataXAuthConstants.cs
- DataXAuthorizeAttribute.cs
- DataXPolicyBuilder.cs
- DataXApplicationBuilderExtensions.cs
- DataXServiceCollectionExtensions.cs
- DataXWebHostBuilderExtensions.cs
- DataXServiceStartup.cs
- IDataXServiceStartup.cs
- DataX.ServiceHost.AspNetCore.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- StartUpBase.cs
- DataXDefaultGatewayPolicy.cs
- ServiceFabricConfigurationBuilderExtensions.cs
- DataX.ServiceHost.ServiceFabric.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- ServiceEventSource.cs
- ServiceFabricConfigurationSource.cs
- ServiceFabricUtil.cs
- DataX.ServiceHost.sln
- ApplicationManifest.xml
- Cloud.xml
- Local.1Node.xml
- Local.5Node.xml
- Cloud.xml
- Local.1Node.xml
- Local.5Node.xml
- Deploy-FabricApplication.ps1
- DataX.SimulatedData.sfproj
- packages.config
- DataSchema.cs
- KafkaConnection.cs
- Settings.xml
- ServiceManifest.xml
- DataGen.cs
- DataGenService.cs
- DataX.SimulatedData.DataGenService.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- Program.cs
- ServiceEventSource.cs
- DataGenUnitTests.cs
- DataX.SimulatedData.DataGenServiceTest.csproj
- FinalPublicKey.snk
- testinput1.json
- testinput2Array.json
- testrandomexpecteddata1.json
- testrandomexpecteddata2.json
- testrulesexpecteddata1.json
- DataX.ruleset
- DataX.SimulatedData.sln
- DataXSimulatedData.nuspec
- BlobHelper.cs
- BlobStorage.cs
- BlobStorageMSI.cs
- DataX.Utilities.Blob.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- StorageCreator.cs
- CosmosDB.cs
- CosmosDBUtil.cs
- DataX.Utilities.CosmosDB.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- DataX.Utilities.EventHub.csproj
- EventHub.cs
- EventHubUtil.cs
- FinalPublicKey.snk
- GlobalSuppressions.cs
- DataX.Utilities.KeyVault.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- KeyVault.cs
- KeyVaultManager.cs
- KeyVaultUtility.cs
- DataX.Utilities.Telemetry.csproj
- FinalPublicKey.snk
- OperationParentIdTelemetryInitializer.cs
- StartUpUtil.cs
- DataX.Utilities.Tests.csproj
- UtilityTests.cs
- DataX.Utilities.Web.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- RolesCheck.cs
- BaseTableEntity.cs
- BlobUtility.cs
- DataX.Utility.Blob.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- IsCriticalException.cs
- StorageTableBase.cs
- StorageUtils.cs
- TableExtensions.cs
- TaskExtensions.cs
- CosmosDBUtility.cs
- DataX.Utility.CosmosDB.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- DataX.Utility.KeyVault.csproj
- FinalPublicKey.snk
- GlobalSuppressions.cs
- KeyVaultUtility.cs
- SecretUriParser.cs
- DataX.Utility.Nuget.csproj
- FinalPublicKey.snk
- VerifySignedFiles.txt
- DataX.Utilities.sln
- ConnectedService.json
- DataXDeployJob.cs
- DataXSchemaAndQueryJob.cs
- IJob.cs
- TestJob.cs
- ScheduledJobEntity.cs
- ScheduledJobTable.cs
- launchSettings.json
- AppConfig.cs
- appsettings.json
- JobQueueMessage.cs
- JobRunner.cs
- JobRunner.csproj
- JobRunner.sln
- JobRunnerException.cs
- MefContainer.cs
- Program.cs
- Startup.cs
- StartupHelper.cs
- TableFactory.cs
- launchSettings.json
- appsettings.Development.json
- appsettings.json
- JobRunnerWebJob.csproj
- Program.cs
- Readme.md
- run.cmd
- Settings.job
- .editorconfig
- .gitignore
- codecoverage.runsettings
- CONTRIBUTING.md
- DataX.sln
- README.md
- Context.cs
- ContextHelper.cs
- DataXScenarios.csproj
- InteractiveQueryAndSchemaGenScenarios.cs
- SaveAndDeploy.cs
- ScenarioUri.cs
- DataXScenarios.sln
- DontTimeAttribute.cs
- FinalPublicKey.snk
- Request.cs
- ScenarioContext.cs
- ScenarioDescription.cs
- ScenarioResult.cs
- ScenarioTester.csproj
- StepAttribute.cs
- StepResult.cs
- ScenarioTesterTests.csproj
- TestDataXScenarios.cs
- TestScenarioTester.cs
- .editorconfig
- README.md
- ScenarioTester.nuspec
- ScenarioTester.sln
- .gitignore
- settings.json
- apiConstants.js
- index.js
- appContent.jsx
- appLogo.jsx
- appRoot.jsx
- centeredMessagePanel.jsx
- errorMessagePanel.jsx
- icon.jsx
- iFramePage.jsx
- index.js
- loadingPanel.jsx
- pageHeader.jsx
- panel.jsx
- panelBody.jsx
- panelHeader.jsx
- panelHeaderButtons.jsx
- scrollableContentPane.jsx
- shell.jsx
- statementBox.jsx
- topNav.jsx
- topNavAppName.jsx
- topNavButton.jsx
- topNavIdentity.jsx
- topNavIdentityMenu.jsx
- topNavIdentityPhoto.jsx
- topNavPageLink.jsx
- topNavSpacer.jsx
- verticalTabItem.jsx
- verticalTabs.jsx
- actions.js
- api.js
- reducer.js
- selectors.js
- index.js
- colors.js
- iconButtonStyles.js
- index.js
- styles.css
- helpers.js
- index.js
- nodeServiceApi.js
- serviceApi.js
- utilities.js
- index.js
- .gitignore
- .prettierrc
- localdevpatch.bat
- package-lock.json
- package.json
- README.md
- webpack.config.js
- settings.json
- prop-accumulator.svg
- prop-aggalert.svg
- prop-aggtag.svg
- prop-alert.svg
- prop-armcustom.svg
- prop-debug.svg
- prop-debugtelemetry.svg
- prop-firstflow.svg
- prop-functions.svg
- prop-github.svg
- prop-livequery.svg
- prop-metrics.svg
- prop-output-cloud.svg
- prop-output-cosmosdb.svg
- prop-output-local.svg
- prop-race-car-data.svg
- prop-reference.svg
- prop-role.svg
- prop-sample-home-automation.svg
- prop-sample-telemetry.svg
- prop-scale.svg
- prop-schema.svg
- prop-spark.svg
- prop-sql.svg
- prop-tag.svg
- prop-wiki.svg
- prop-window.svg
- card.jsx
- footerItem.jsx
- homePage.jsx
- section.jsx
- welcomeCard.jsx
- wideCard.jsx
- composition.js
- models.js
- styles.css
- index.js
- .gitignore
- .prettierrc
- localdevpatch.bat
- package-lock.json
- package.json
- README.md
- webpack.config.js
- settings.json
- sparkJobs.jsx
- sparkJobsList.jsx
- api.js
- constants.js
- styles.css
- index.js
- .gitignore
- .prettierrc
- localdevpatch.bat
- package-lock.json
- package.json
- README.md
- webpack.config.js
- settings.json
- d3.colorBox.js
- d3.gauge.js
- metricAllProducts.jsx
- metricDashboard.jsx
- metricExplorer.jsx
- metricWidgetDetailsList.jsx
- metricWidgetGauge.jsx
- metricWidgetGeneric.jsx
- metricWidgetLineChart.jsx
- metricWidgetMultiLineChart.jsx
- metricWidgetNumberBox.jsx
- metricWidgetPercentageBox.jsx
- metricWidgetSimpleBox.jsx
- metricWidgetSimpleTable.jsx
- metricWidgetStackedAreaChart.jsx
- navigationItem.jsx
- navigationPanel.jsx
- actions.js
- api.js
- apiConstants.js
- metrics.aggregator.js
- metrics.buffer.accumulate.js
- metrics.buffer.latest.js
- metrics.datasource.js
- metrics.polling.js
- reducer.js
- selectors.js
- serviceGroup.js
- styles.css
- index.js
- .gitignore
- .prettierrc
- localdevpatch.bat
- package-lock.json
- package.json
- README.md
- webpack.config.js
- settings.json
- api.js
- styles.js
- azureFunctionSettings.jsx
- functionSettingsContent.jsx
- udfSettings.jsx
- infoSettingsContent.jsx
- inputSettingsContent.jsx
- blobSinkerSettings.jsx
- cosmosdbSinkerSettings.jsx
- eventHubSinkerSettings.jsx
- localSinkerSettings.jsx
- metricSinkerSettings.jsx
- outputSettingsContent.jsx
- sqlSinkerSettings.jsx
- csvReferenceDataSettings.jsx
- referenceDataSettingsContent.jsx
- conditionsPreview.jsx
- queryBuilder.jsx
- ruleAggregateColumnSettings.jsx
- ruleAlertSettings.jsx
- ruleConditionsSettings.jsx
- ruleGeneralSettings.jsx
- rulePivotSettings.jsx
- rulesSettingsContent.jsx
- tagRuleSettings.jsx
- scaleSettingsContent.jsx
- oneTimeScheduleSettings.jsx
- recurringScheduleSettings.jsx
- scheduleSettingsContent.jsx
- flowDefinitionPanel.jsx
- api.js
- flowActions.js
- flowHelpers.js
- flowModels.js
- flowReducer.js
- flowSelectors.js
- flowListPanel.jsx
- actions.js
- api.js
- reducer.js
- selectors.js
- styles.css
- index.js
- .gitignore
- .prettierrc
- localdevpatch.bat
- package-lock.json
- package.json
- README.md
- webpack.config.js
- settings.json
- index.js
- monacoeditorcontrol.jsx
- querySettingsContent.jsx
- sideToolBar.jsx
- api.js
- kernelActions.js
- kernelReducer.js
- kernelSelectors.js
- layoutActions.js
- layoutReducer.js
- layoutSelectors.js
- queryActions.js
- queryModels.js
- queryReducer.js
- querySelectors.js
- index.js
- styles.css
- index.js
- .gitignore
- .prettierrc
- localdevpatch.bat
- package-lock.json
- package.json
- README.md
- webpack.config.js
- README.md
- launch.json
- settings.json
- global.css
- main.js
- favicon.ico
- index.html
- app.jsx
- layout.jsx
- loadingPage.jsx
- api.js
- storeManager.js
- db.js
- keyvaultClient.js
- mongoclient.js
- DataX.Utility.CodeSign.csproj
- FinalPublicKey.snk
- DataX.Utilities.sln
- VerifySignedFiles.txt
- deploy.cmd
- zipsite.js
- redisProxy.js
- metricService.js
- redisconsole.js
- schemaHandlers.js
- cache.js
- common.js
- consolelogger.js
- dist.js
- fs.js
- localCache.js
- redisclient.js
- transaction.js
- .deployment
- .gitignore
- .prettierrc
- appinsights.js
- auth.js
- config.js
- host.js
- iisnode.yml
- LICENSE
- logger.js
- package-lock.json
- package.json
- package.loader.js
- README.md
- securedSettings.js
- server.js
- web.composition.json
- web.config
- webpack.config.js
- .gitignore
- README.md
- web.nuspec
- .gitignore
- CODE_OF_CONDUCT.md
- CONTRIBUTING.md
- LICENSE
- README.md
- SECURITY.md
- ThirdPartyNotices.txt
// repository documentation
Was this content helpful?
(0 ratings)