Path Lines of Code src/CRA.ClientLibrary/AzureProvider/AzureBlobProvider.cs 34 src/CRA.ClientLibrary/AzureProvider/AzureDataProvider.cs 58 src/CRA.ClientLibrary/AzureProvider/AzureEndpointInfoProvider.cs 80 src/CRA.ClientLibrary/AzureProvider/AzureShardedVertexInfoProvider.cs 56 src/CRA.ClientLibrary/AzureProvider/AzureVertexConnectionInfoProvider.cs 68 src/CRA.ClientLibrary/AzureProvider/AzureVertexInfoProvider.cs 131 src/CRA.ClientLibrary/AzureProvider/ConnectionTable.cs 75 src/CRA.ClientLibrary/AzureProvider/EndpointTable.cs 56 src/CRA.ClientLibrary/AzureProvider/ShardedVertexTable.cs 108 src/CRA.ClientLibrary/AzureProvider/VertexTable.cs 206 src/CRA.ClientLibrary/DataProcessing/Datasets/ClientSideShardedDataset.cs 151 src/CRA.ClientLibrary/DataProcessing/Datasets/DatasetBase.cs 38 src/CRA.ClientLibrary/DataProcessing/Datasets/DeployableShardedDataset.cs 275 src/CRA.ClientLibrary/DataProcessing/Datasets/IDataset.cs 16 src/CRA.ClientLibrary/DataProcessing/Datasets/IDeployable.cs 7 src/CRA.ClientLibrary/DataProcessing/Datasets/IShardedDataset.cs 28 src/CRA.ClientLibrary/DataProcessing/Datasets/ShardedDatasetBase.cs 100 src/CRA.ClientLibrary/DataProcessing/Definitions/Operator/OperatorInformation.cs 238 src/CRA.ClientLibrary/DataProcessing/Definitions/Operator/OperatorTransforms.cs 33 src/CRA.ClientLibrary/DataProcessing/Definitions/Operator/OperatorType.cs 15 src/CRA.ClientLibrary/DataProcessing/Definitions/Operator/OperatorsToplogy.cs 296 src/CRA.ClientLibrary/DataProcessing/Definitions/Tasks/ClientTerminalTask.cs 9 src/CRA.ClientLibrary/DataProcessing/Definitions/Tasks/ProduceTask.cs 15 src/CRA.ClientLibrary/DataProcessing/Definitions/Tasks/ShuffleTask.cs 51 src/CRA.ClientLibrary/DataProcessing/Definitions/Tasks/SubscribeTask.cs 9 src/CRA.ClientLibrary/DataProcessing/Definitions/Tasks/TaskBase.cs 114 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedEndpoints/ShardedOperatorInputBase.cs 75 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedEndpoints/ShardedOperatorOutputBase.cs 66 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedEndpoints/ShardedProducerOutput.cs 100 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedEndpoints/ShardedProducerSecondaryInput.cs 44 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedEndpoints/ShardedProducerSecondaryOutput.cs 60 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedEndpoints/ShardedShuffleInput.cs 156 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedEndpoints/ShardedShuffleOutput.cs 68 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedEndpoints/ShardedShuffleSecondaryInput.cs 44 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedEndpoints/ShardedShuffleSecondaryOutput.cs 44 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedEndpoints/ShardedSubscribeClientInput.cs 41 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedEndpoints/ShardedSubscribeClientOutput.cs 57 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedEndpoints/ShardedSubscribeInput.cs 42 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedEndpoints/ShardedSubscribeOutput.cs 38 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedOperatorBase.cs 80 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedProducerOperator.cs 209 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedShuffleOperator.cs 92 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedSubscribeClientOperator.cs 48 src/CRA.ClientLibrary/DataProcessing/ShardedOperators/ShardedSubscribeOperator.cs 46 src/CRA.ClientLibrary/DataProcessing/Utilities/DatasetUtils.cs 108 src/CRA.ClientLibrary/DataProcessing/Utilities/DeploymentUtils.cs 348 src/CRA.ClientLibrary/DataProcessing/Utilities/MoveUtils.cs 205 src/CRA.ClientLibrary/DataProcessing/Utilities/OperatorUtils.cs 50 src/CRA.ClientLibrary/DataProcessing/Utilities/ParallelismUtils.cs 15 src/CRA.ClientLibrary/DataProcessing/Utilities/TransformUtils.cs 136 src/CRA.ClientLibrary/DataProvider/DataProviderExtensions.cs 34 src/CRA.ClientLibrary/DataProvider/EndpointInfo.cs 52 src/CRA.ClientLibrary/DataProvider/IBlobStorageProvider.cs 13 src/CRA.ClientLibrary/DataProvider/IDataProvider.cs 13 src/CRA.ClientLibrary/DataProvider/IEndpointInfoProvider.cs 18 src/CRA.ClientLibrary/DataProvider/IShardedVertexInfoProvider.cs 16 src/CRA.ClientLibrary/DataProvider/IVertexConnectionInfoProvider.cs 18 src/CRA.ClientLibrary/DataProvider/IVertexInfoProvider.cs 32 src/CRA.ClientLibrary/DataProvider/ShardedVertexInfo.cs 83 src/CRA.ClientLibrary/DataProvider/VertexConnectionInfo.cs 69 src/CRA.ClientLibrary/DataProvider/VertexInfo.cs 158 src/CRA.ClientLibrary/Definitions/ConnectionInfo.cs 55 src/CRA.ClientLibrary/Definitions/ConnectionInitiator.cs 8 src/CRA.ClientLibrary/Definitions/CoralTaskMessageType.cs 14 src/CRA.ClientLibrary/Definitions/ErrorCodes.cs 17 src/CRA.ClientLibrary/Definitions/ObjectWrapper.cs 8 src/CRA.ClientLibrary/Definitions/ShardingInfo.cs 14 src/CRA.ClientLibrary/Definitions/StreamConnection.cs 52 src/CRA.ClientLibrary/Definitions/StreamConnectionPool.cs 62 src/CRA.ClientLibrary/Main/CRAClientLibrary.cs 558 src/CRA.ClientLibrary/Main/CRAWorker.cs 1028 src/CRA.ClientLibrary/Main/ShardedCRAClientLibrary.cs 433 src/CRA.ClientLibrary/Properties/AssemblyInfo.cs 11 src/CRA.ClientLibrary/Security/DummySecureStreamConnectionDescriptor.cs 25 src/CRA.ClientLibrary/Security/ISecureStreamConnectionDescriptor.cs 12 src/CRA.ClientLibrary/Security/SampleSecureStreamConnectionDescriptor.cs 77 src/CRA.ClientLibrary/Tables/ConnectionTableManager.cs 33 src/CRA.ClientLibrary/Tables/EndpointTableManager.cs 69 src/CRA.ClientLibrary/Tables/ShardedVertexTableManager.cs 73 src/CRA.ClientLibrary/Tables/VertexTableManager.cs 111 src/CRA.ClientLibrary/Utilities/AssemblyResolver.cs 71 src/CRA.ClientLibrary/Utilities/AssemblyResolverClient.cs 33 src/CRA.ClientLibrary/Utilities/AssemblyUtils.cs 730 src/CRA.ClientLibrary/Utilities/ClientStreamUtils.cs 84 src/CRA.ClientLibrary/Utilities/ExpressionUtils.cs 43 src/CRA.ClientLibrary/Utilities/NetworkUtils.cs 43 src/CRA.ClientLibrary/Utilities/SerializationHelper.cs 47 src/CRA.ClientLibrary/Utilities/StreamCommunicator.cs 128 src/CRA.ClientLibrary/Vertices/DetachedVertex.cs 240 src/CRA.ClientLibrary/Vertices/IAsyncVertexInputEndpoint.cs 16 src/CRA.ClientLibrary/Vertices/IAsyncVertexOutputEndpoint.cs 21 src/CRA.ClientLibrary/Vertices/IVertex.cs 25 src/CRA.ClientLibrary/Vertices/IVertexInputEndpoint.cs 10 src/CRA.ClientLibrary/Vertices/IVertexOutputEndpoint.cs 15 src/CRA.ClientLibrary/Vertices/VertexBase.cs 219 src/CRA.ClientLibrary/Vertices/VertexInputEndpointBase.cs 23 src/CRA.ClientLibrary/Vertices/VertexOutputEndpointBase.cs 23 src/CRA.DataProvider.File/FileBlobProvider.cs 27 src/CRA.DataProvider.File/FileDataProvider.cs 38 src/CRA.DataProvider.File/FileEndpointProvider.cs 87 src/CRA.DataProvider.File/FileShardedVertexProvider.cs 76 src/CRA.DataProvider.File/FileUtils.cs 184 src/CRA.DataProvider.File/FileVertexConnectionProvider.cs 76 src/CRA.DataProvider.File/FileVertexProvider.cs 138 src/CRA.Worker/Program.cs 110 src/CRA.Worker/Properties/AssemblyInfo.cs 9 src/CRA.Worker/cra-two-instances-debug.yml 55 src/CRA.Worker/cra-two-instances-release.yml 55