rename class.
Project: http://git-wip-us.apache.org/repos/asf/incubator-s2graph/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-s2graph/commit/30137d49 Tree: http://git-wip-us.apache.org/repos/asf/incubator-s2graph/tree/30137d49 Diff: http://git-wip-us.apache.org/repos/asf/incubator-s2graph/diff/30137d49 Branch: refs/heads/master Commit: 30137d497e49e33a4d6009e074d78765196f852e Parents: ef72257 Author: DO YUNG YOON <[email protected]> Authored: Wed Apr 4 13:50:03 2018 +0900 Committer: DO YUNG YOON <[email protected]> Committed: Wed Apr 4 13:50:03 2018 +0900 ---------------------------------------------------------------------- .../main/scala/org/apache/s2graph/s2jobs/JobDescription.scala | 2 +- s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/Sink.scala | 2 +- .../src/main/scala/org/apache/s2graph/s2jobs/task/Source.scala | 2 +- .../src/test/scala/org/apache/s2graph/s2jobs/task/SinkTest.scala | 4 ++-- .../test/scala/org/apache/s2graph/s2jobs/task/SourceTest.scala | 2 +- 5 files changed, 6 insertions(+), 6 deletions(-) ---------------------------------------------------------------------- http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/30137d49/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/JobDescription.scala ---------------------------------------------------------------------- diff --git a/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/JobDescription.scala b/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/JobDescription.scala index 2eaf6aa..3be318d 100644 --- a/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/JobDescription.scala +++ b/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/JobDescription.scala @@ -80,7 +80,7 @@ object JobDescription extends Logger { case "kafka" => new KafkaSink(jobName, conf) case "file" => new FileSink(jobName, conf) case "es" => new ESSink(jobName, conf) - case "s2graph" => new S2graphSink(jobName, conf) + case "s2graph" => new S2GraphSink(jobName, conf) case _ => throw new IllegalArgumentException(s"unsupported sink type : ${conf.`type`}") } http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/30137d49/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/Sink.scala ---------------------------------------------------------------------- diff --git a/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/Sink.scala b/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/Sink.scala index 866aa47..07a626d 100644 --- a/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/Sink.scala +++ b/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/Sink.scala @@ -209,7 +209,7 @@ class ESSink(queryName: String, conf: TaskConf) extends Sink(queryName, conf) { * @param queryName * @param conf */ -class S2graphSink(queryName: String, conf: TaskConf) extends Sink(queryName, conf) { +class S2GraphSink(queryName: String, conf: TaskConf) extends Sink(queryName, conf) { override def mandatoryOptions: Set[String] = Set() override val FORMAT: String = "org.apache.s2graph.spark.sql.streaming.S2SinkProvider" http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/30137d49/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/Source.scala ---------------------------------------------------------------------- diff --git a/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/Source.scala b/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/Source.scala index 9ac9296..3d0aefb 100644 --- a/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/Source.scala +++ b/s2jobs/src/main/scala/org/apache/s2graph/s2jobs/task/Source.scala @@ -106,7 +106,7 @@ class HiveSource(conf:TaskConf) extends Source(conf) { } } -class HBaseTableSnapshotSource(conf: TaskConf) extends Source(conf) { +class S2GraphSource(conf: TaskConf) extends Source(conf) { override def mandatoryOptions: Set[String] = Set("hbase.rootdir", "restore.path", "hbase.table.names") http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/30137d49/s2jobs/src/test/scala/org/apache/s2graph/s2jobs/task/SinkTest.scala ---------------------------------------------------------------------- diff --git a/s2jobs/src/test/scala/org/apache/s2graph/s2jobs/task/SinkTest.scala b/s2jobs/src/test/scala/org/apache/s2graph/s2jobs/task/SinkTest.scala index 02b724e..628c5de 100644 --- a/s2jobs/src/test/scala/org/apache/s2graph/s2jobs/task/SinkTest.scala +++ b/s2jobs/src/test/scala/org/apache/s2graph/s2jobs/task/SinkTest.scala @@ -56,7 +56,7 @@ class SinkTest extends BaseSparkTest { val conf = TaskConf("test", "sql", Seq("input"), args) - val sink = new S2graphSink("testQuery", conf) + val sink = new S2GraphSink("testQuery", conf) sink.write(df) val s2Edges = s2.edges().asScala.toSeq.map(_.asInstanceOf[S2EdgeLike]) @@ -79,7 +79,7 @@ class SinkTest extends BaseSparkTest { val conf = TaskConf("test", "sql", Seq("input"), args) - val sink = new S2graphSink("testQuery", conf) + val sink = new S2GraphSink("testQuery", conf) sink.write(df) val s2Edges = s2.edges().asScala.toSeq.map(_.asInstanceOf[S2EdgeLike]) http://git-wip-us.apache.org/repos/asf/incubator-s2graph/blob/30137d49/s2jobs/src/test/scala/org/apache/s2graph/s2jobs/task/SourceTest.scala ---------------------------------------------------------------------- diff --git a/s2jobs/src/test/scala/org/apache/s2graph/s2jobs/task/SourceTest.scala b/s2jobs/src/test/scala/org/apache/s2graph/s2jobs/task/SourceTest.scala index 86cdf2b..d2788c2 100644 --- a/s2jobs/src/test/scala/org/apache/s2graph/s2jobs/task/SourceTest.scala +++ b/s2jobs/src/test/scala/org/apache/s2graph/s2jobs/task/SourceTest.scala @@ -53,7 +53,7 @@ class SourceTest extends BaseSparkTest { val conf = TaskConf("test", "sql", Seq("input"), args) - val sink = new S2graphSink("testQuery", conf) + val sink = new S2GraphSink("testQuery", conf) sink.write(df) val dumpArgs = Map(
