Path Lines of Code 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