Path	Lines of Code
appveyor.yml	72
build/Build.cmd	207
build/copyjar.ps1	42
build/localmode/RunSamples.cmd	88
build/localmode/downloadtools.ps1	539
build/localmode/dumpsoftware.ps1	10
build/localmode/nugetpack.ps1	22
build/localmode/patchpom.ps1	42
build/localmode/precheck.cmd	40
build/localmode/zipdir.ps1	84
cpp/Build.cmd	64
cpp/Clean.cmd	8
cpp/Riosock/Locks.h	81
cpp/Riosock/Riosock.cpp	510
cpp/Riosock/Riosock.h	67
cpp/Riosock/Riosock.vcxproj	91
csharp/Adapter/Microsoft.Spark.CSharp/Configuration/ConfigurationService.cs	185
csharp/Adapter/Microsoft.Spark.CSharp/Configuration/IConfigurationService.cs	9
csharp/Adapter/Microsoft.Spark.CSharp/Core/Accumulator.cs	163
csharp/Adapter/Microsoft.Spark.CSharp/Core/Broadcast.cs	87
csharp/Adapter/Microsoft.Spark.CSharp/Core/CSharpWorkerFunc.cs	58
csharp/Adapter/Microsoft.Spark.CSharp/Core/DoubleRDDFunctions.cs	44
csharp/Adapter/Microsoft.Spark.CSharp/Core/HadoopConfiguration.cs	21
csharp/Adapter/Microsoft.Spark.CSharp/Core/IRDDCollector.cs	11
csharp/Adapter/Microsoft.Spark.CSharp/Core/Option.cs	24
csharp/Adapter/Microsoft.Spark.CSharp/Core/OrderedRDDFunctions.cs	118
csharp/Adapter/Microsoft.Spark.CSharp/Core/PairRDDFunctions.cs	407
csharp/Adapter/Microsoft.Spark.CSharp/Core/Partitioner.cs	31
csharp/Adapter/Microsoft.Spark.CSharp/Core/PipelinedRDD.cs	74
csharp/Adapter/Microsoft.Spark.CSharp/Core/PriorityQueue.cs	102
csharp/Adapter/Microsoft.Spark.CSharp/Core/Profiler.cs	12
csharp/Adapter/Microsoft.Spark.CSharp/Core/RDD.cs	782
csharp/Adapter/Microsoft.Spark.CSharp/Core/RDDCollector.cs	72
csharp/Adapter/Microsoft.Spark.CSharp/Core/SparkConf.cs	85
csharp/Adapter/Microsoft.Spark.CSharp/Core/SparkContext.cs	257
csharp/Adapter/Microsoft.Spark.CSharp/Core/StatCounter.cs	102
csharp/Adapter/Microsoft.Spark.CSharp/Core/StatusTracker.cs	90
csharp/Adapter/Microsoft.Spark.CSharp/Core/StorageLevel.cs	64
csharp/Adapter/Microsoft.Spark.CSharp/Interop/Ipc/IJvmBridge.cs	18
csharp/Adapter/Microsoft.Spark.CSharp/Interop/Ipc/ISparkCLRSocket.cs	28
csharp/Adapter/Microsoft.Spark.CSharp/Interop/Ipc/JsonSerDe.cs	50
csharp/Adapter/Microsoft.Spark.CSharp/Interop/Ipc/JvmBridge.cs	247
csharp/Adapter/Microsoft.Spark.CSharp/Interop/Ipc/JvmBridgeUtils.cs	68
csharp/Adapter/Microsoft.Spark.CSharp/Interop/Ipc/JvmObjectReference.cs	49
csharp/Adapter/Microsoft.Spark.CSharp/Interop/Ipc/PayloadHelper.cs	212
csharp/Adapter/Microsoft.Spark.CSharp/Interop/Ipc/SerDe.cs	180
csharp/Adapter/Microsoft.Spark.CSharp/Interop/Ipc/SparkCLRSocket.cs	134
csharp/Adapter/Microsoft.Spark.CSharp/Interop/Ipc/WeakObjectManager.cs	172
csharp/Adapter/Microsoft.Spark.CSharp/Interop/SparkCLREnvironment.cs	43
csharp/Adapter/Microsoft.Spark.CSharp/Network/ByteBuf.cs	238
csharp/Adapter/Microsoft.Spark.CSharp/Network/ByteBufChunk.cs	222
csharp/Adapter/Microsoft.Spark.CSharp/Network/ByteBufChunkList.cs	138
csharp/Adapter/Microsoft.Spark.CSharp/Network/ByteBufPool.cs	167
csharp/Adapter/Microsoft.Spark.CSharp/Network/DefaultSocketWrapper.cs	102
csharp/Adapter/Microsoft.Spark.CSharp/Network/ISocketWrapper.cs	22
csharp/Adapter/Microsoft.Spark.CSharp/Network/RioNative.cs	253
csharp/Adapter/Microsoft.Spark.CSharp/Network/RioSocketWrapper.cs	455
csharp/Adapter/Microsoft.Spark.CSharp/Network/SaeaSocketWrapper.cs	317
csharp/Adapter/Microsoft.Spark.CSharp/Network/SockDataToken.cs	26
csharp/Adapter/Microsoft.Spark.CSharp/Network/SocketFactory.cs	78
csharp/Adapter/Microsoft.Spark.CSharp/Network/SocketInfo.cs	25
csharp/Adapter/Microsoft.Spark.CSharp/Network/SocketStream.cs	158
csharp/Adapter/Microsoft.Spark.CSharp/Properties/AssemblyInfo.cs	16
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/ICatalogProxy.cs	33
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/IDStreamProxy.cs	21
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/IDataFrameNaFunctionsProxy.cs	18
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/IDataFrameProxy.cs	81
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/IDataFrameReaderProxy.cs	23
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/IDataFrameWriterProxy.cs	16
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/IDatasetProxy.cs	13
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/IHadoopConfigurationProxy.cs	9
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/IRDDProxy.cs	44
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/ISparkCLRProxy.cs	15
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/ISparkConfProxy.cs	19
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/ISparkContextProxy.cs	60
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/ISparkSessionProxy.cs	26
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/ISqlContextProxy.cs	38
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/IStatusTrackerProxy.cs	18
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/IStreamingContextProxy.cs	30
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/IStructProxy.cs	25
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/CatalogIpcProxy.cs	133
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/DStreamIpcProxy.cs	72
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/DataFrameIpcProxy.cs	550
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/DataFrameNaFunctionsIpcProxy.cs	55
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/DataFrameReaderIpcProxy.cs	101
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/DataFrameWriterIpcProxy.cs	65
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/DatasetIpcProxy.cs	30
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/HadoopConfigurationIpcProxy.cs	23
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/RDDIpcProxy.cs	198
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/SparkCLRIpcProxy.cs	77
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/SparkConfIpcProxy.cs	53
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/SparkContextIpcProxy.cs	359
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/SparkSessionIpcProxy.cs	95
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/SqlContextIpcProxy.cs	171
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/StatusTrackerIpcProxy.cs	60
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/StreamingContextIpcProxy.cs	341
csharp/Adapter/Microsoft.Spark.CSharp/Proxy/Ipc/StructIpcProxy.cs	71
csharp/Adapter/Microsoft.Spark.CSharp/Services/DefaultLoggerService.cs	66
csharp/Adapter/Microsoft.Spark.CSharp/Services/ILoggerService.cs	20
csharp/Adapter/Microsoft.Spark.CSharp/Services/Log4NetLoggerService.cs	105
csharp/Adapter/Microsoft.Spark.CSharp/Services/LoggerServiceFactory.cs	31
csharp/Adapter/Microsoft.Spark.CSharp/Sql/Builder.cs	67
csharp/Adapter/Microsoft.Spark.CSharp/Sql/Catalog.cs	113
csharp/Adapter/Microsoft.Spark.CSharp/Sql/Column.cs	135
csharp/Adapter/Microsoft.Spark.CSharp/Sql/DataFrame.cs	816
csharp/Adapter/Microsoft.Spark.CSharp/Sql/DataFrameNaFunctions.cs	85
csharp/Adapter/Microsoft.Spark.CSharp/Sql/DataFrameReader.cs	82
csharp/Adapter/Microsoft.Spark.CSharp/Sql/DataFrameWriter.cs	83
csharp/Adapter/Microsoft.Spark.CSharp/Sql/Dataset.cs	57
csharp/Adapter/Microsoft.Spark.CSharp/Sql/Functions.cs	556
csharp/Adapter/Microsoft.Spark.CSharp/Sql/HiveContext.cs	23
csharp/Adapter/Microsoft.Spark.CSharp/Sql/PythonSerDe.cs	22
csharp/Adapter/Microsoft.Spark.CSharp/Sql/Row.cs	151
csharp/Adapter/Microsoft.Spark.CSharp/Sql/RowConstructor.cs	55
csharp/Adapter/Microsoft.Spark.CSharp/Sql/SaveMode.cs	24
csharp/Adapter/Microsoft.Spark.CSharp/Sql/SparkSession.cs	85
csharp/Adapter/Microsoft.Spark.CSharp/Sql/SqlContext.cs	226
csharp/Adapter/Microsoft.Spark.CSharp/Sql/Types.cs	452
csharp/Adapter/Microsoft.Spark.CSharp/Sql/UdfRegistration.cs	101
csharp/Adapter/Microsoft.Spark.CSharp/Sql/UserDefinedFunction.cs	76
csharp/Adapter/Microsoft.Spark.CSharp/Streaming/CSharpInputDStreamUtils.cs	75
csharp/Adapter/Microsoft.Spark.CSharp/Streaming/ConstantInputDStream.cs	21
csharp/Adapter/Microsoft.Spark.CSharp/Streaming/DStream.cs	315
csharp/Adapter/Microsoft.Spark.CSharp/Streaming/EventHubsUtils.cs	14
csharp/Adapter/Microsoft.Spark.CSharp/Streaming/Kafka.cs	120
csharp/Adapter/Microsoft.Spark.CSharp/Streaming/MapWithStateDStream.cs	292
csharp/Adapter/Microsoft.Spark.CSharp/Streaming/PairDStreamFunctions.cs	449
csharp/Adapter/Microsoft.Spark.CSharp/Streaming/StreamingContext.cs	100
csharp/Adapter/Microsoft.Spark.CSharp/Streaming/TransformedDStream.cs	70
csharp/AdapterTest/AccumulatorTest.cs	96
csharp/AdapterTest/BroadcastTest.cs	78
csharp/AdapterTest/BuilderTest.cs	54
csharp/AdapterTest/ByteBufChunkListTest.cs	55
csharp/AdapterTest/ByteBufChunkTest.cs	71
csharp/AdapterTest/ByteBufPoolTest.cs	116
csharp/AdapterTest/ByteBufTest.cs	131
csharp/AdapterTest/CatalogTest.cs	189
csharp/AdapterTest/ColumnTest.cs	263
csharp/AdapterTest/ComparableRDDTest.cs	53
csharp/AdapterTest/ConfigurationServiceTest.cs	99
csharp/AdapterTest/DStreamTest.cs	394
csharp/AdapterTest/DataFrameNaFunctionsTest.cs	187
csharp/AdapterTest/DataFrameReaderTest.cs	246
csharp/AdapterTest/DataFrameTest.cs	1363
csharp/AdapterTest/DataFrameWriterTest.cs	189
csharp/AdapterTest/DatasetTest.cs	130
csharp/AdapterTest/DoubleRDDTest.cs	47
csharp/AdapterTest/EventHubsUtilsTest.cs	34
csharp/AdapterTest/FunctionsTest.cs	560
csharp/AdapterTest/HadoopConfigurationTest.cs	32
csharp/AdapterTest/HiveContextTest.cs	57
csharp/AdapterTest/JsonSerDeTest.cs	35
csharp/AdapterTest/PairRDDTest.cs	199
csharp/AdapterTest/PayloadHelperTest.cs	329
csharp/AdapterTest/PriorityQueueTest.cs	60
csharp/AdapterTest/Properties/AssemblyInfo.cs	16
csharp/AdapterTest/RDDTest.cs	250
csharp/AdapterTest/RowTest.cs	55
csharp/AdapterTest/SerDeTest.cs	110
csharp/AdapterTest/SocketStreamTest.cs	35
csharp/AdapterTest/SocketWrapperTest.cs	170
csharp/AdapterTest/SparkCLRTestEnvironment.cs	24
csharp/AdapterTest/SparkConfTest.cs	28
csharp/AdapterTest/SparkContextTest.cs	483
csharp/AdapterTest/SparkSessionTest.cs	28
csharp/AdapterTest/SqlContextTest.cs	315
csharp/AdapterTest/StatusTrackerTest.cs	84
csharp/AdapterTest/StreamingContextTest.cs	91
csharp/AdapterTest/TestWithMoqDemo.cs	153
csharp/AdapterTest/UdfRegistrationTest.cs	42
csharp/AdapterTest/UserDefinedFunctionTest.cs	170
csharp/AdapterTest/WeakObjectManagerTest.cs	62
csharp/Build.cmd	65
csharp/Clean.cmd	7
csharp/Perf/Microsoft.Spark.CSharp/FreebaseDeletionsBenchmark.cs	80
csharp/Perf/Microsoft.Spark.CSharp/Program.cs	90
csharp/Perf/Microsoft.Spark.CSharp/Properties/AssemblyInfo.cs	15
csharp/Repl/IScriptEngine.cs	10
csharp/Repl/Properties/AssemblyInfo.cs	16
csharp/Repl/Repl.cs	176
csharp/Repl/RoslynScriptEngine.cs	161
csharp/Repl/ScriptResult.cs	34
csharp/ReplTest/Properties/AssemblyInfo.cs	16
csharp/ReplTest/ReplTest.cs	102
csharp/ReplTest/SparkCLRTestEnvironment.cs	25
csharp/Test.cmd	30
csharp/Tests.Common/Picklers.cs	70
csharp/Tests.Common/Properties/AssemblyInfo.cs	17
csharp/Tests.Common/RowHelper.cs	86
csharp/Utils/Microsoft.Spark.CSharp/FileSystem/FileSystemHelper.cs	18
csharp/Utils/Microsoft.Spark.CSharp/FileSystem/HdfsFileStatus.cs	47
csharp/Utils/Microsoft.Spark.CSharp/FileSystem/HdfsFileSystemHelper.cs	95
csharp/Utils/Microsoft.Spark.CSharp/FileSystem/LocalFileSystemHelper.cs	54
csharp/Utils/Microsoft.Spark.CSharp/Properties/AssemblyInfo.cs	15
csharp/Worker/Microsoft.Spark.CSharp/MultiThreadWorker.cs	149
csharp/Worker/Microsoft.Spark.CSharp/Properties/AssemblyInfo.cs	16
csharp/Worker/Microsoft.Spark.CSharp/TaskRunner.cs	110
csharp/Worker/Microsoft.Spark.CSharp/UDFCommand.cs	328
csharp/Worker/Microsoft.Spark.CSharp/Worker.cs	396
csharp/Worker/Microsoft.Spark.CSharp/WorkerFunc.cs	19
csharp/WorkerTest/MultiThreadWorkerTest.cs	249
csharp/WorkerTest/Properties/AssemblyInfo.cs	15
csharp/WorkerTest/WorkerTest.cs	686
dev/scripts/SetSparkClrJarVersion.ps1	85
dev/scripts/SetSparkClrNugetPackageVersion.ps1	26
dev/scripts/SetSparkClrPackageVersion.ps1	111
dev/scripts/SetVersion.cmd	41
notes/mobius-init.fsx	29
python/perf/FreebaseDeletionsBenchmark.py	57
python/perf/PerfBenchmark.py	46
python/perf/spark-python-perf.py	21
scala/perf/src/main/com/microsoft/spark/csharp/FreebaseDeletionsBenchmark.scala	75
scala/perf/src/main/com/microsoft/spark/csharp/PerfBenchmark.scala	75
scala/perf/src/main/com/microsoft/spark/csharp/PerfSuite.java	2
scala/src/main/javadocstub/JavaDocStub.java	6
scala/src/main/org/apache/spark/api/csharp/CSharpBackend.scala	76
scala/src/main/org/apache/spark/api/csharp/CSharpBackendHandler.scala	225
scala/src/main/org/apache/spark/api/csharp/CSharpRDD.scala	190
scala/src/main/org/apache/spark/api/csharp/SerDe.scala	266
scala/src/main/org/apache/spark/deploy/csharp/CSharpRunner.scala	144
scala/src/main/org/apache/spark/launcher/SparkCLRSubmitArguments.scala	425
scala/src/main/org/apache/spark/sql/api/csharp/JvmBridgeUtils.scala	23
scala/src/main/org/apache/spark/sql/api/csharp/SQLUtils.scala	208
scala/src/main/org/apache/spark/streaming/api/csharp/CSharpDStream.scala	397
scala/src/main/org/apache/spark/streaming/api/csharp/EventHubsUtils.scala	20
scala/src/main/org/apache/spark/streaming/api/kafka/DynamicPartitionKafkaCluster.scala	157
scala/src/main/org/apache/spark/streaming/api/kafka/DynamicPartitionKafkaInputDStream.scala	513
scala/src/main/org/apache/spark/streaming/api/kafka/DynamicPartitionKafkaRDD.scala	184
scala/src/main/org/apache/spark/streaming/api/kafka/KafkaUtilsCSharpHelper.scala	65
scala/src/main/org/apache/spark/util/csharp/Utils.scala	124
scripts/sparkclr-shell.cmd	8
scripts/sparkclr-submit.cmd	83