Path	Lines of Code
build.sbt	98
conf/hbase-site.xml	7
conf/log4j2.xml	19
dev_support/graph_mysql/schema.sql	195
doc/source/_static/css/s2graph_style.css	1
doc/source/conf.py	40
example/movielens/query/recommend_movie.graphql	34
example/movielens/query/search_movie_by_genres_and_title_with_simlar_movies.graphql	32
example/movielens/query/search_movie_by_title.graphql	35
example/movielens/schema/edge.rated.graphql	59
example/movielens/schema/edge.related.graphql	57
example/movielens/schema/edge.similar.movie.graphql	59
example/movielens/schema/edge.tagged.graphql	55
example/movielens/schema/service.graphql	32
example/movielens/schema/vertex.movie.graphql	48
example/movielens/schema/vertex.tag.graphql	34
example/movielens/schema/vertex.user.graphql	34
loader/build.sbt	30
loader/loader.py	75
loader/src/main/scala/org/apache/s2graph/loader/spark/BulkLoadPartitioner.scala	26
loader/src/main/scala/org/apache/s2graph/loader/spark/FamilyHFileWriteOptions.scala	6
loader/src/main/scala/org/apache/s2graph/loader/spark/HBaseContext.scala	442
loader/src/main/scala/org/apache/s2graph/loader/spark/HBaseDStreamFunctions.scala	42
loader/src/main/scala/org/apache/s2graph/loader/spark/HBaseRDDFunctions.scala	62
loader/src/main/scala/org/apache/s2graph/loader/spark/JavaHBaseContext.scala	109
loader/src/main/scala/org/apache/s2graph/loader/spark/KeyFamilyQualifier.scala	17
loader/src/main/scala/org/apache/s2graph/loader/subscriber/GraphSubscriber.scala	111
loader/src/main/scala/org/apache/s2graph/loader/subscriber/TransferToHFile.scala	263
loader/src/main/scala/org/apache/s2graph/loader/subscriber/WalLogStat.scala	68
loader/src/main/scala/org/apache/s2graph/loader/subscriber/WalLogToHDFS.scala	123
project/Common.scala	37
project/Packager.scala	90
project/Publisher.scala	68
project/assembly.sbt	1
project/plugins.sbt	9
s2core/build.sbt	50
s2core/src/main/java/org/apache/s2graph/core/fetcher/tensorflow/LabelImage.java	176
s2core/src/main/java/org/apache/s2graph/core/io/S2GraphSimpleModule.java	98
s2core/src/main/java/org/apache/s2graph/core/io/tinkerpop/optimize/S2GraphStep.java	90
s2core/src/main/java/org/apache/s2graph/core/io/tinkerpop/optimize/S2GraphStepStrategy.java	40
s2core/src/main/resources/create_model.hql	19
s2core/src/main/resources/org/apache/s2graph/core/schema/schema.sql	173
s2core/src/main/resources/org/apache/s2graph/core/schema/setup.sql	5
s2core/src/main/scala/org/apache/s2graph/core/EdgeFetcher.scala	11
s2core/src/main/scala/org/apache/s2graph/core/EdgeMutator.scala	15
s2core/src/main/scala/org/apache/s2graph/core/ExceptionHandler.scala	93
s2core/src/main/scala/org/apache/s2graph/core/GraphElement.scala	9
s2core/src/main/scala/org/apache/s2graph/core/GraphElementBuilder.scala	226
s2core/src/main/scala/org/apache/s2graph/core/GraphExceptions.scala	35
s2core/src/main/scala/org/apache/s2graph/core/GraphUtil.scala	133
s2core/src/main/scala/org/apache/s2graph/core/JSONParser.scala	276
s2core/src/main/scala/org/apache/s2graph/core/Management.scala	484
s2core/src/main/scala/org/apache/s2graph/core/OrderingUtil.scala	98
s2core/src/main/scala/org/apache/s2graph/core/PostProcess.scala	236
s2core/src/main/scala/org/apache/s2graph/core/QueryParam.scala	372
s2core/src/main/scala/org/apache/s2graph/core/QueryResult.scala	235
s2core/src/main/scala/org/apache/s2graph/core/ResourceManager.scala	129
s2core/src/main/scala/org/apache/s2graph/core/S2Edge.scala	653
s2core/src/main/scala/org/apache/s2graph/core/S2EdgeBuilder.scala	75
s2core/src/main/scala/org/apache/s2graph/core/S2EdgeLike.scala	174
s2core/src/main/scala/org/apache/s2graph/core/S2EdgePropertyHelper.scala	58
s2core/src/main/scala/org/apache/s2graph/core/S2Graph.scala	429
s2core/src/main/scala/org/apache/s2graph/core/S2GraphConfigs.scala	136
s2core/src/main/scala/org/apache/s2graph/core/S2GraphFactory.scala	102
s2core/src/main/scala/org/apache/s2graph/core/S2GraphIoRegistry.scala	41
s2core/src/main/scala/org/apache/s2graph/core/S2GraphLike.scala	282
s2core/src/main/scala/org/apache/s2graph/core/S2GraphTp.scala	65
s2core/src/main/scala/org/apache/s2graph/core/S2Property.scala	96
s2core/src/main/scala/org/apache/s2graph/core/S2Vertex.scala	65
s2core/src/main/scala/org/apache/s2graph/core/S2VertexBuilder.scala	29
s2core/src/main/scala/org/apache/s2graph/core/S2VertexLike.scala	148
s2core/src/main/scala/org/apache/s2graph/core/S2VertexProperty.scala	50
s2core/src/main/scala/org/apache/s2graph/core/S2VertexPropertyHelper.scala	36
s2core/src/main/scala/org/apache/s2graph/core/TraversalHelper.scala	494
s2core/src/main/scala/org/apache/s2graph/core/VertexFetcher.scala	10
s2core/src/main/scala/org/apache/s2graph/core/VertexMutator.scala	9
s2core/src/main/scala/org/apache/s2graph/core/features/S2DataTypeFeatures.scala	22
s2core/src/main/scala/org/apache/s2graph/core/features/S2EdgeFeatures.scala	7
s2core/src/main/scala/org/apache/s2graph/core/features/S2EdgePropertyFeatures.scala	4
s2core/src/main/scala/org/apache/s2graph/core/features/S2ElementFeatures.scala	13
s2core/src/main/scala/org/apache/s2graph/core/features/S2Features.scala	13
s2core/src/main/scala/org/apache/s2graph/core/features/S2GraphFeatures.scala	11
s2core/src/main/scala/org/apache/s2graph/core/features/S2GraphVariables.scala	32
s2core/src/main/scala/org/apache/s2graph/core/features/S2PropertyFeatures.scala	5
s2core/src/main/scala/org/apache/s2graph/core/features/S2VariableFeatures.scala	5
s2core/src/main/scala/org/apache/s2graph/core/features/S2Variables.scala	3
s2core/src/main/scala/org/apache/s2graph/core/features/S2VertexFeatures.scala	11
s2core/src/main/scala/org/apache/s2graph/core/features/S2VertexPropertyFeatures.scala	13
s2core/src/main/scala/org/apache/s2graph/core/fetcher/MemoryModelEdgeFetcher.scala	29
s2core/src/main/scala/org/apache/s2graph/core/fetcher/annoy/AnnoyModelFetcher.scala	47
s2core/src/main/scala/org/apache/s2graph/core/fetcher/fasttext/CopyModel.scala	103
s2core/src/main/scala/org/apache/s2graph/core/fetcher/fasttext/FastText.scala	157
s2core/src/main/scala/org/apache/s2graph/core/fetcher/fasttext/FastTextArgs.scala	102
s2core/src/main/scala/org/apache/s2graph/core/fetcher/fasttext/FastTextFetcher.scala	44
s2core/src/main/scala/org/apache/s2graph/core/fetcher/tensorflow/InceptionFetcher.scala	65
s2core/src/main/scala/org/apache/s2graph/core/index/ESIndexProvider.scala	162
s2core/src/main/scala/org/apache/s2graph/core/index/IndexProvider.scala	103
s2core/src/main/scala/org/apache/s2graph/core/index/LuceneIndexProvider.scala	191
s2core/src/main/scala/org/apache/s2graph/core/io/Conversions.scala	112
s2core/src/main/scala/org/apache/s2graph/core/parsers/WhereParser.scala	191
s2core/src/main/scala/org/apache/s2graph/core/rest/RequestParser.scala	630
s2core/src/main/scala/org/apache/s2graph/core/rest/RestHandler.scala	187
s2core/src/main/scala/org/apache/s2graph/core/schema/Bucket.scala	99
s2core/src/main/scala/org/apache/s2graph/core/schema/ColumnMeta.scala	123
s2core/src/main/scala/org/apache/s2graph/core/schema/Experiment.scala	77
s2core/src/main/scala/org/apache/s2graph/core/schema/Label.scala	391
s2core/src/main/scala/org/apache/s2graph/core/schema/LabelIndex.scala	166
s2core/src/main/scala/org/apache/s2graph/core/schema/LabelMeta.scala	154
s2core/src/main/scala/org/apache/s2graph/core/schema/Schema.scala	158
s2core/src/main/scala/org/apache/s2graph/core/schema/Service.scala	98
s2core/src/main/scala/org/apache/s2graph/core/schema/ServiceColumn.scala	141
s2core/src/main/scala/org/apache/s2graph/core/step/IStep.scala	44
s2core/src/main/scala/org/apache/s2graph/core/storage/DefaultOptimisticEdgeMutator.scala	123
s2core/src/main/scala/org/apache/s2graph/core/storage/DefaultOptimisticVertexMutator.scala	21
s2core/src/main/scala/org/apache/s2graph/core/storage/MutateResponse.scala	9
s2core/src/main/scala/org/apache/s2graph/core/storage/OptimisticEdgeFetcher.scala	32
s2core/src/main/scala/org/apache/s2graph/core/storage/OptimisticMutator.scala	6
s2core/src/main/scala/org/apache/s2graph/core/storage/SKeyValue.scala	43
s2core/src/main/scala/org/apache/s2graph/core/storage/Storage.scala	23
s2core/src/main/scala/org/apache/s2graph/core/storage/StorageIO.scala	167
s2core/src/main/scala/org/apache/s2graph/core/storage/StorageManagement.scala	9
s2core/src/main/scala/org/apache/s2graph/core/storage/StorageSerDe.scala	12
s2core/src/main/scala/org/apache/s2graph/core/storage/WriteWriteConflictResolver.scala	290
s2core/src/main/scala/org/apache/s2graph/core/storage/hbase/AsynchbaseEdgeFetcher.scala	94
s2core/src/main/scala/org/apache/s2graph/core/storage/hbase/AsynchbaseOptimisticEdgeFetcher.scala	13
s2core/src/main/scala/org/apache/s2graph/core/storage/hbase/AsynchbaseOptimisticMutator.scala	76
s2core/src/main/scala/org/apache/s2graph/core/storage/hbase/AsynchbasePatcher.scala	79
s2core/src/main/scala/org/apache/s2graph/core/storage/hbase/AsynchbaseStorage.scala	240
s2core/src/main/scala/org/apache/s2graph/core/storage/hbase/AsynchbaseStorageManagement.scala	189
s2core/src/main/scala/org/apache/s2graph/core/storage/hbase/AsynchbaseStorageSerDe.scala	28
s2core/src/main/scala/org/apache/s2graph/core/storage/hbase/AsynchbaseVertexFetcher.scala	59
s2core/src/main/scala/org/apache/s2graph/core/storage/jdbc/JdbcEdgeFetcher.scala	61
s2core/src/main/scala/org/apache/s2graph/core/storage/jdbc/JdbcEdgeMutator.scala	76
s2core/src/main/scala/org/apache/s2graph/core/storage/jdbc/JdbcStorage.scala	124
s2core/src/main/scala/org/apache/s2graph/core/storage/rocks/RocksEdgeFetcher.scala	59
s2core/src/main/scala/org/apache/s2graph/core/storage/rocks/RocksHelper.scala	36
s2core/src/main/scala/org/apache/s2graph/core/storage/rocks/RocksOptimisticEdgeFetcher.scala	17
s2core/src/main/scala/org/apache/s2graph/core/storage/rocks/RocksOptimisticMutator.scala	100
s2core/src/main/scala/org/apache/s2graph/core/storage/rocks/RocksStorage.scala	192
s2core/src/main/scala/org/apache/s2graph/core/storage/rocks/RocksStorageManagement.scala	18
s2core/src/main/scala/org/apache/s2graph/core/storage/rocks/RocksStorageSerDe.scala	21
s2core/src/main/scala/org/apache/s2graph/core/storage/rocks/RocksVertexFetcher.scala	80
s2core/src/main/scala/org/apache/s2graph/core/storage/serde/Deserializable.scala	5
s2core/src/main/scala/org/apache/s2graph/core/storage/serde/Serializable.scala	6
s2core/src/main/scala/org/apache/s2graph/core/storage/serde/StorageDeserializable.scala	99
s2core/src/main/scala/org/apache/s2graph/core/storage/serde/StorageSerializable.scala	57
s2core/src/main/scala/org/apache/s2graph/core/storage/serde/indexedge/tall/IndexEdgeDeserializable.scala	119
s2core/src/main/scala/org/apache/s2graph/core/storage/serde/indexedge/tall/IndexEdgeSerializable.scala	35
s2core/src/main/scala/org/apache/s2graph/core/storage/serde/indexedge/wide/IndexEdgeDeserializable.scala	98
s2core/src/main/scala/org/apache/s2graph/core/storage/serde/indexedge/wide/IndexEdgeSerializable.scala	39
s2core/src/main/scala/org/apache/s2graph/core/storage/serde/snapshotedge/tall/SnapshotEdgeDeserializable.scala	80
s2core/src/main/scala/org/apache/s2graph/core/storage/serde/snapshotedge/tall/SnapshotEdgeSerializable.scala	33
s2core/src/main/scala/org/apache/s2graph/core/storage/serde/snapshotedge/wide/SnapshotEdgeDeserializable.scala	72
s2core/src/main/scala/org/apache/s2graph/core/storage/serde/snapshotedge/wide/SnapshotEdgeSerializable.scala	34
s2core/src/main/scala/org/apache/s2graph/core/storage/serde/vertex/tall/VertexDeserializable.scala	34
s2core/src/main/scala/org/apache/s2graph/core/storage/serde/vertex/tall/VertexSerializable.scala	28
s2core/src/main/scala/org/apache/s2graph/core/storage/serde/vertex/wide/VertexDeserializable.scala	47
s2core/src/main/scala/org/apache/s2graph/core/storage/serde/vertex/wide/VertexSerializable.scala	25
s2core/src/main/scala/org/apache/s2graph/core/types/HBaseType.scala	129
s2core/src/main/scala/org/apache/s2graph/core/types/InnerValLike.scala	246
s2core/src/main/scala/org/apache/s2graph/core/types/LabelWithDirection.scala	42
s2core/src/main/scala/org/apache/s2graph/core/types/VertexId.scala	130
s2core/src/main/scala/org/apache/s2graph/core/types/v1/InnerVal.scala	176
s2core/src/main/scala/org/apache/s2graph/core/types/v2/InnerVal.scala	131
s2core/src/main/scala/org/apache/s2graph/core/utils/DeferCache.scala	127
s2core/src/main/scala/org/apache/s2graph/core/utils/Extentions.scala	82
s2core/src/main/scala/org/apache/s2graph/core/utils/ImportStatus.scala	25
s2core/src/main/scala/org/apache/s2graph/core/utils/Importer.scala	73
s2core/src/main/scala/org/apache/s2graph/core/utils/Logger.scala	41
s2core/src/main/scala/org/apache/s2graph/core/utils/SafeUpdateCache.scala	150
s2counter_core/build.sbt	12
s2counter_core/src/main/scala/org/apache/s2graph/counter/TrxLog.scala	14
s2counter_core/src/main/scala/org/apache/s2graph/counter/config/ConfigFunctions.scala	26
s2counter_core/src/main/scala/org/apache/s2graph/counter/config/S2CounterConfig.scala	31
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/BytesUtil.scala	9
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/ExactCounter.scala	207
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/ExactKey.scala	22
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/ExactQualifier.scala	63
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/ExactStorage.scala	25
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/RankingCounter.scala	80
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/RankingKey.scala	2
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/RankingResult.scala	2
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/RankingStorage.scala	13
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/RankingValue.scala	7
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/RateRankingValue.scala	11
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/TimedQualifier.scala	194
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/v1/BytesUtilV1.scala	46
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/v1/ExactStorageAsyncHBase.scala	277
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/v1/ExactStorageHBase.scala	281
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/v1/RankingStorageRedis.scala	154
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/v2/BytesUtilV2.scala	71
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/v2/ExactStorageGraph.scala	296
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/v2/GraphOperation.scala	44
s2counter_core/src/main/scala/org/apache/s2graph/counter/core/v2/RankingStorageGraph.scala	342
s2counter_core/src/main/scala/org/apache/s2graph/counter/decay/DecayFormula.scala	5
s2counter_core/src/main/scala/org/apache/s2graph/counter/decay/ExpDecayFormula.scala	20
s2counter_core/src/main/scala/org/apache/s2graph/counter/helper/CounterAdmin.scala	97
s2counter_core/src/main/scala/org/apache/s2graph/counter/helper/DistributedScanner.scala	59
s2counter_core/src/main/scala/org/apache/s2graph/counter/helper/HashShardingJedis.scala	109
s2counter_core/src/main/scala/org/apache/s2graph/counter/helper/Management.scala	119
s2counter_core/src/main/scala/org/apache/s2graph/counter/helper/WithHBase.scala	61
s2counter_core/src/main/scala/org/apache/s2graph/counter/helper/WithRedis.scala	46
s2counter_core/src/main/scala/org/apache/s2graph/counter/models/CachedDBModel.scala	8
s2counter_core/src/main/scala/org/apache/s2graph/counter/models/Counter.scala	185
s2counter_core/src/main/scala/org/apache/s2graph/counter/models/DBModel.scala	20
s2counter_core/src/main/scala/org/apache/s2graph/counter/package.scala	5
s2counter_core/src/main/scala/org/apache/s2graph/counter/util/CartesianProduct.scala	7
s2counter_core/src/main/scala/org/apache/s2graph/counter/util/CollectionCache.scala	51
s2counter_core/src/main/scala/org/apache/s2graph/counter/util/FunctionParser.scala	19
s2counter_core/src/main/scala/org/apache/s2graph/counter/util/Hashes.scala	16
s2counter_core/src/main/scala/org/apache/s2graph/counter/util/ReduceMapValue.scala	8
s2counter_core/src/main/scala/org/apache/s2graph/counter/util/Retry.scala	36
s2counter_core/src/main/scala/org/apache/s2graph/counter/util/SplitBytes.scala	19
s2counter_core/src/main/scala/org/apache/s2graph/counter/util/UnitConverter.scala	20
s2counter_loader/build.sbt	22
s2counter_loader/src/main/scala/org/apache/s2graph/counter/loader/CounterBulkLoader.scala	64
s2counter_loader/src/main/scala/org/apache/s2graph/counter/loader/EraseDailyCounter.scala	109
s2counter_loader/src/main/scala/org/apache/s2graph/counter/loader/config/StreamingConfig.scala	17
s2counter_loader/src/main/scala/org/apache/s2graph/counter/loader/core/CounterEtlFunctions.scala	74
s2counter_loader/src/main/scala/org/apache/s2graph/counter/loader/core/CounterEtlItem.scala	34
s2counter_loader/src/main/scala/org/apache/s2graph/counter/loader/core/CounterFunctions.scala	385
s2counter_loader/src/main/scala/org/apache/s2graph/counter/loader/core/DimensionProps.scala	132
s2counter_loader/src/main/scala/org/apache/s2graph/counter/loader/models/DefaultCounterModel.scala	4
s2counter_loader/src/main/scala/org/apache/s2graph/counter/loader/stream/EtlStreaming.scala	90
s2counter_loader/src/main/scala/org/apache/s2graph/counter/loader/stream/ExactCounterStreaming.scala	51
s2counter_loader/src/main/scala/org/apache/s2graph/counter/loader/stream/GraphToETLStreaming.scala	62
s2counter_loader/src/main/scala/org/apache/s2graph/counter/loader/stream/RankingCounterStreaming.scala	50
s2graph_gremlin/build.sbt	43
s2graph_gremlin/src/main/scala/org/apache/s2graph/core/tinkerpop/groovy/plugin/S2GraphGremlinPlugin.scala	31
s2graphql/build.sbt	13
s2graphql/src/main/resources/assets/graphiql.html	111
s2graphql/src/main/scala/org/apache/s2graph/graphql/GraphQLServer.scala	81
s2graphql/src/main/scala/org/apache/s2graph/graphql/bind/AstHelper.scala	8
s2graphql/src/main/scala/org/apache/s2graph/graphql/bind/Unmarshaller.scala	83
s2graphql/src/main/scala/org/apache/s2graph/graphql/middleware/GraphFormatWriter.scala	70
s2graphql/src/main/scala/org/apache/s2graph/graphql/middleware/Transform.scala	23
s2graphql/src/main/scala/org/apache/s2graph/graphql/repository/GraphRepository.scala	251
s2graphql/src/main/scala/org/apache/s2graph/graphql/types/FieldResolver.scala	78
s2graphql/src/main/scala/org/apache/s2graph/graphql/types/ManagementType.scala	254
s2graphql/src/main/scala/org/apache/s2graph/graphql/types/PlayJsonScalarType.scala	81
s2graphql/src/main/scala/org/apache/s2graph/graphql/types/S2Directive.scala	35
s2graphql/src/main/scala/org/apache/s2graph/graphql/types/S2Type.scala	299
s2graphql/src/main/scala/org/apache/s2graph/graphql/types/SchemaDef.scala	31
s2graphql/src/main/scala/org/apache/s2graph/graphql/types/StaticType.scala	114
s2graphql/src/main/scala/org/apache/s2graph/graphql/types/package.scala	30
s2http/build.sbt	15
s2http/src/main/scala/org/apache/s2graph/http/PlayJsonSupport.scala	60
s2http/src/main/scala/org/apache/s2graph/http/S2GraphAdminRoute.scala	202
s2http/src/main/scala/org/apache/s2graph/http/S2GraphMutateRoute.scala	73
s2http/src/main/scala/org/apache/s2graph/http/S2GraphQLRoute.scala	88
s2http/src/main/scala/org/apache/s2graph/http/S2GraphTraversalRoute.scala	45
s2http/src/main/scala/org/apache/s2graph/http/SangriaGraphQLSupport.scala	32
s2http/src/main/scala/org/apache/s2graph/http/Server.scala	51
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
s2rest_netty/build.sbt	6
s2rest_netty/conf/logger.xml	70
s2rest_netty/src/main/scala/org/apache/s2graph/rest/netty/Server.scala	204
s2rest_play/app/org/apache/s2graph/rest/play/Bootstrap.scala	62
s2rest_play/app/org/apache/s2graph/rest/play/actors/QueueActor.scala	62
s2rest_play/app/org/apache/s2graph/rest/play/config/Config.scala	25
s2rest_play/app/org/apache/s2graph/rest/play/config/CounterConfig.scala	5
s2rest_play/app/org/apache/s2graph/rest/play/controllers/AdminController.scala	227
s2rest_play/app/org/apache/s2graph/rest/play/controllers/ApplicationController.scala	95
s2rest_play/app/org/apache/s2graph/rest/play/controllers/CounterController.scala	645
s2rest_play/app/org/apache/s2graph/rest/play/controllers/EdgeController.scala	240
s2rest_play/app/org/apache/s2graph/rest/play/controllers/ExperimentController.scala	17
s2rest_play/app/org/apache/s2graph/rest/play/controllers/JsonBodyParser.scala	67
s2rest_play/app/org/apache/s2graph/rest/play/controllers/PublishController.scala	25
s2rest_play/app/org/apache/s2graph/rest/play/controllers/QueryController.scala	32
s2rest_play/app/org/apache/s2graph/rest/play/controllers/VertexController.scala	70
s2rest_play/app/org/apache/s2graph/rest/play/models/ExactCounterItem.scala	26
s2rest_play/app/org/apache/s2graph/rest/play/models/RankCounterItem.scala	28
s2rest_play/app/org/apache/s2graph/rest/play/models/package.scala	5
s2rest_play/app/org/apache/s2graph/rest/play/package.scala	7
s2rest_play/build.sbt	8
s2rest_play/conf/log4j2.xml	19
spark/build.sbt	12
spark/src/main/scala/kafka/KafkaHelper.scala	93
spark/src/main/scala/org/apache/s2graph/spark/config/S2ConfigFactory.scala	14
spark/src/main/scala/org/apache/s2graph/spark/spark/HashMapParam.scala	30
spark/src/main/scala/org/apache/s2graph/spark/spark/RDDUtil.scala	10
spark/src/main/scala/org/apache/s2graph/spark/spark/SparkApp.scala	92
spark/src/main/scala/org/apache/s2graph/spark/spark/SubscriberListener.scala	16
spark/src/main/scala/org/apache/s2graph/spark/spark/WithKafka.scala	51
spark/src/main/scala/org/apache/spark/streaming/kafka/KafkaRDDFunctions.scala	30
spark/src/main/scala/org/apache/spark/streaming/kafka/StreamHelper.scala	79
version.sbt	1