Tag: spark java

使用HttpURLConnection在Request body中发送数据: 我正在使用HttpURLConnection向使用JAVA Spark创建的本地部署的本地服务发出POST请求。当我使用HttpURLConnection进行POST调用时，我想在请求体中发送一些数据，但每次JAVA Spark中的请求体都为null 。以下是我正在使用的代码 Java Spark POST服务处理程序 post(“/”, (req, res) -> { System.out.println(“Request Body: ” + req.body()); return “Hello!!!!”; }); HTTPClass进行发布呼叫 `public class HTTPClassExample{ public static void main(String[] args) { try{ URL url = new URL(“http://localhost:4567/”); HttpURLConnection httpCon = (HttpURLConnection) url.openConnection(); httpCon.setDoOutput(true); httpCon.setRequestMethod(“POST”); httpCon.connect(); OutputStream os = httpCon.getOutputStream(); OutputStreamWriter osw = new OutputStreamWriter(os, […]

重新加载Spark / Jetty-server中的静态文件: 我有一个类似的问题在这里描述：刷新SparkJava提供的静态文件在我的应用程序中，用户可以将内容上传到一个也提供给用户的文件夹 Spark.staticFileLocation(“/public”); 特征。我知道SparkJava只是在启动时从该文件夹中读取“静态”内容，并且不知道那里的变化。是否有可能通过Spark请求Spark（或Jetty）重新加载静态文件夹中的更改？

如何使用Spark Java返回静态html页面？: 一个带火花的问候世界： get(new Route(“/hello”) { @Override public Object handle(Request request, Response response) { response.type(“text/html”); return “Hello Spark MVC Framework!”; } }); 如何返回静态文件index.html？笔记：我需要这个index.html在jar中本着简单的spark java的精神，我想尽可能避免通过模板，这对于静态页面来说是过度的。

在哪里放置Spark Web Framework的静态文件？: 尝试使用Spark Web框架提供静态文件时，我在哪里放置文件？我无法在网上找到任何东西 – 我开始怀疑我对Eclipse和Java项目的类路径，相对路径等一无所知。关于Spark中静态文件的这一段是指/public ，但我不知道它会在哪里。使用Windows，Eclipse Luna和我的项目转换为使用Maven。我已经尝试过在GitHub上查看代码了，但是我有点想要找到它。

如何部署一个火花Java Web应用程序？: 我使用spark web框架来创建webapp，但我不知道如何部署这个webapp。我很抱歉，如果这是非常基本的，但我是新的引发框架，我找不到任何文件，指导我如何部署一个火花webapp：如何独立部署spark webapp 如何构建spark webapp（war文件或此类文件）并使用Web服务器（jetty或Tomcat）进行部署。

java.lang.ClassCastException使用远程服务器上的spark作业中的lambda表达式: 我正在尝试使用sparkjava.com框架为我的apache spark作业构建一个web api。我的代码是： @Override public void init() { get(“/hello”, (req, res) -> { String sourcePath = “hdfs://spark:54310/input/*”; SparkConf conf = new SparkConf().setAppName(“LineCount”); conf.setJars(new String[] { “/home/sam/resin-4.0.42/webapps/test.war” }); File configFile = new File(“config.properties”); String sparkURI = “spark://hamrah:7077”; conf.setMaster(sparkURI); conf.set(“spark.driver.allowMultipleContexts”, “true”); JavaSparkContext sc = new JavaSparkContext(conf); @SuppressWarnings(“resource”) JavaRDD log = sc.textFile(sourcePath); JavaRDD lines = log.filter(x -> […]