hydra-0.15.0: src/main/haskell/Hydra/Demos/AvroToPropertyGraphs.hs

module Hydra.Demos.AvroToPropertyGraphs where

import Hydra.Kernel
import Hydra.Workflow
import Hydra.Tools.AvroWorkflows

import qualified System.FilePath as FP
import System.Directory


-- | Last mile which transforms a graph into JSON. See the README for usage.
transformAvroJsonToPg :: LastMile x -> FilePath -> FilePath -> FilePath -> IO ()
transformAvroJsonToPg lastMile schemaFile dataDir outDir = do
  pwd <- getCurrentDirectory
  executeAvroTransformWorkflow lastMile $ TransformWorkflow "airplane info"
    (SchemaSpecFile $ FP.combine pwd schemaFile) (FP.combine pwd dataDir) outDir