Merge branch 'S2GRAPH-185' of https://github.com/elric-k/incubator-s2graph into elric-k-S2GRAPH-185
Project: http://git-wip-us.apache.org/repos/asf/incubator-s2graph/repo Commit: http://git-wip-us.apache.org/repos/asf/incubator-s2graph/commit/36e68969 Tree: http://git-wip-us.apache.org/repos/asf/incubator-s2graph/tree/36e68969 Diff: http://git-wip-us.apache.org/repos/asf/incubator-s2graph/diff/36e68969 Branch: refs/heads/master Commit: 36e6896939cd420a4f79051bb411f7c3e4ec5081 Parents: 653deee 14c50ea Author: DO YUNG YOON <[email protected]> Authored: Thu Mar 29 14:31:32 2018 +0900 Committer: DO YUNG YOON <[email protected]> Committed: Thu Mar 29 14:31:32 2018 +0900 ---------------------------------------------------------------------- project/Common.scala | 2 +- s2jobs/build.sbt | 12 +- .../scala/org/apache/s2graph/s2jobs/Job.scala | 51 ++++++ .../apache/s2graph/s2jobs/JobDescription.scala | 69 ++++++++ .../org/apache/s2graph/s2jobs/JobLauncher.scala | 69 ++++++++ .../org/apache/s2graph/s2jobs/Logger.scala | 7 + .../org/apache/s2graph/s2jobs/Schema.scala | 16 ++ .../apache/s2graph/s2jobs/task/Process.scala | 34 ++++ .../org/apache/s2graph/s2jobs/task/Sink.scala | 176 +++++++++++++++++++ .../org/apache/s2graph/s2jobs/task/Source.scala | 85 +++++++++ .../org/apache/s2graph/s2jobs/task/Task.scala | 19 ++ .../s2graph/spark/sql/streaming/Logger.scala | 7 + .../spark/sql/streaming/S2CommitProtocol.scala | 48 +++++ .../spark/sql/streaming/S2SinkConfigs.scala | 28 +++ .../spark/sql/streaming/S2SinkContext.scala | 25 +++ .../spark/sql/streaming/S2SinkMetadataLog.scala | 25 +++ .../spark/sql/streaming/S2SinkProvider.scala | 26 +++ .../spark/sql/streaming/S2SinkStatus.scala | 9 + .../sql/streaming/S2SparkSqlStreamingSink.scala | 70 ++++++++ .../sql/streaming/S2StreamQueryWriter.scala | 114 ++++++++++++ .../s2graph/s2jobs/task/ProcessTest.scala | 29 +++ 21 files changed, 917 insertions(+), 4 deletions(-) ----------------------------------------------------------------------
