Path	Lines of Code
s2jobs/build.sbt	38
s2jobs/loader.py	85
s2jobs/src/main/java/org/apache/hadoop/hbase/mapreduce/GraphHFileOutputFormat.java	122
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/DegreeKey.scala	52
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/Job.scala	40
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/JobDescription.scala	73
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/JobLauncher.scala	61
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/Logger.scala	5
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/S2GraphHelper.scala	99
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/Schema.scala	38
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/loader/GraphFileGenerator.scala	18
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/loader/GraphFileOptions.scala	111
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/loader/HFileGenerator.scala	140
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/loader/HFileMRGenerator.scala	105
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/loader/LocalBulkLoaderTransformer.scala	26
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/loader/RawFileGenerator.scala	10
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/loader/SparkBulkLoaderTransformer.scala	39
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/serde/GraphElementReadable.scala	5
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/serde/GraphElementWritable.scala	7
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/serde/Transformer.scala	10
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/serde/reader/IdentityReader.scala	7
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/serde/reader/RowBulkFormatReader.scala	10
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/serde/reader/S2GraphCellReader.scala	32
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/serde/reader/TsvBulkFormatReader.scala	8
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/serde/writer/IdentityWriter.scala	9
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/serde/writer/KeyValueWriter.scala	26
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/serde/writer/RowDataFrameWriter.scala	14
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/spark/BulkLoadPartitioner.scala	26
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/spark/FamilyHFileWriteOptions.scala	6
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/spark/HBaseContext.scala	421
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/spark/HBaseDStreamFunctions.scala	42
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/spark/HBaseRDDFunctions.scala	60
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/spark/JavaHBaseContext.scala	109
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/spark/KeyFamilyQualifier.scala	17
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/Process.scala	59
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/Sink.scala	200
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/Source.scala	125
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/Task.scala	39
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/custom/process/ALSModelProcess.scala	82
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/custom/sink/AnnoyIndexBuildSink.scala	15
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/udfs/Grok.scala	27
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/udfs/Udf.scala	7
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/utils/GrokHelper.scala	48
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/WalLog.scala	166
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/process/BuildTopFeaturesProcess.scala	96
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/process/FilterTopFeaturesProcess.scala	66
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/process/WalLogAggregateProcess.scala	38
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/process/params/AggregateParam.scala	39
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/process/params/BuildTopFeaturesParam.scala	13
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/process/params/FilterTopFeaturesParam.scala	6
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/transformer/DefaultTransformer.scala	3
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/transformer/ExtractDomain.scala	20
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/transformer/ExtractServiceName.scala	19
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/transformer/Transformer.scala	10
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/udafs/WalLogUDAF.scala	209
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/udfs/WalLogUDF.scala	110
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/utils/BoundedPriorityQueue.scala	35
s2jobs/src/main/scala/org/apache/s2graph/s2jobs/wal/utils/UrlUtils.scala	46
s2jobs/src/main/scala/org/apache/s2graph/spark/sql/streaming/Logger.scala	5
s2jobs/src/main/scala/org/apache/s2graph/spark/sql/streaming/S2CommitProtocol.scala	38
s2jobs/src/main/scala/org/apache/s2graph/spark/sql/streaming/S2SinkConfigs.scala	29
s2jobs/src/main/scala/org/apache/s2graph/spark/sql/streaming/S2SinkContext.scala	22
s2jobs/src/main/scala/org/apache/s2graph/spark/sql/streaming/S2SinkMetadataLog.scala	18
s2jobs/src/main/scala/org/apache/s2graph/spark/sql/streaming/S2SinkProvider.scala	20
s2jobs/src/main/scala/org/apache/s2graph/spark/sql/streaming/S2SinkStatus.scala	8
s2jobs/src/main/scala/org/apache/s2graph/spark/sql/streaming/S2SourceConfigs.scala	12
s2jobs/src/main/scala/org/apache/s2graph/spark/sql/streaming/S2SparkSqlStreamingSink.scala	57
s2jobs/src/main/scala/org/apache/s2graph/spark/sql/streaming/S2StreamQueryWriter.scala	56