Added snapshotToHdfs to the IvoryRetire api

raronson · raronson · commit a7ad89d6f254 · 2014-06-27T18:29:30.000+10:00
diff --git a/ivory-api/src/main/scala/com/ambiata/ivory/api/IvoryRetire.scala b/ivory-api/src/main/scala/com/ambiata/ivory/api/IvoryRetire.scala
@@ -34,6 +34,7 @@ object IvoryRetire {
   val dictionaryToIvory = com.ambiata.ivory.storage.legacy.IvoryStorage.dictionaryToIvory _
 
   val snapshotFromHdfs = com.ambiata.ivory.storage.legacy.SnapshotStorageV1.snapshotFromHdfs _
+  val snapshotToHdfs = com.ambiata.ivory.storage.legacy.SnapshotStorageV1.snapshotToHdfs _
 
   val createRepository = com.ambiata.ivory.storage.legacy.CreateRepository.onHdfs _
 
diff --git a/ivory-storage/src/main/scala/com/ambiata/ivory/storage/legacy/SnapshotStorage.scala b/ivory-storage/src/main/scala/com/ambiata/ivory/storage/legacy/SnapshotStorage.scala
@@ -31,4 +31,7 @@ object SnapshotStorageV1 {
     ScoobiAction.scoobiJob({ implicit sc: ScoobiConfiguration =>
       SnapshotLoader(path).loadScoobi
     })
+
+  def snapshotToHdfs(dlist: DList[Fact], path: Path, codec: Option[CompressionCodec]): ScoobiAction[DList[Fact]] =
+  ScoobiAction.scoobiJob({ implicit sc: ScoobiConfiguration => SnapshotStorer(path, codec).storeScoobi(dlist) })
 }

Original file line number	Diff line number	Diff line change
`@@ -31,4 +31,7 @@ object SnapshotStorageV1 {`
`31`	`31`	`ScoobiAction.scoobiJob({ implicit sc: ScoobiConfiguration =>`
`32`	`32`	`SnapshotLoader(path).loadScoobi`
`33`	`33`	`})`
	`34`	`+`
	`35`	`+ def snapshotToHdfs(dlist: DList[Fact], path: Path, codec: Option[CompressionCodec]): ScoobiAction[DList[Fact]] =`
	`36`	`+ ScoobiAction.scoobiJob({ implicit sc: ScoobiConfiguration => SnapshotStorer(path, codec).storeScoobi(dlist) })`
`34`	`37`	`}`