hlivy alternatives and similar packages
Based on the "Distributed Computing" category.
Alternatively, view hlivy alternatives based on common mentions on social networks and blogs.
Cloud Haskell Task Execution Framework
Testing Tools and Capabilities for Cloud Haskell
4.5 0.0 hlivy VS task-distributionA framework for distributing Haskell tasks running on HDFS data using Cloud Haskell. The goal is speedup through distribution on clusters using regular hardware. This framework provides different, simple workarounds to transport new code to other cluster nodes.
Do you think we are missing an alternative of hlivy or a related project?
hlivy is a Haskell library that provides bindings to the Apache Livy REST API, which enables one to easily launch Spark applications -- either in an interactive or batch fashion -- via HTTP requests to the Livy server running on the master node of a Spark cluster.
which brings all functionality into scope. In particular, this exposes a monad
Livy that has all the capabilites required to run Livy actions with
runLivy. Generally, the format of a Livy action follows the pattern
send $ basicRequestObject requiredArg1 requiredArg2 & requestLens1 ?~ optionalArg1 & requestLens2 ?~ optionalArg2
This action is ran simply:
let req = basicRequestObject requiredArg1 requiredArg2 & requestLens1 ?~ optionalArg1 & requestLens2 ?~ optionalArg2 resp <- runLivy env $ send req
env is a suitable environment. Concretely, if one wanted to create an interactive session, one would do something like this:
λ => import Network.Livy λ => -- Create a default environment λ => env <- newEnv "localhost" 8998 λ => resp <- runLivy env $ send createSession
The response body, in this case a
CreateSessionResponse, should contain the the
Session just created.
Session at hand, one can run "statements" -- snippets of Spark Scala, PySpark, SparkR, or SparkSQL -- in the given session.
λ => req = runStatement (SessionId 0) "val x = 1 + 1; println(x)" SparkSession λ => resp <- runLivy env $ send req
This response object, in this case a
RunStatementResponse, contains the information needed to check on the status of the statement or retrieve results if available.
Batch actions are organized in the
Network.Livy.Client.Batch module, and are used similarly:
λ => import Control.Lens λ => -- Application JAR in HDFS λ => req = createBatch "/user/hadoop/my-app.jar" λ => resp <- runLivy env (send req & cbClassName ?~ "com.company.my_app" & cbExecutorCores ?~ 4)
See examples for more example use.