草庐IT

apache-spark-1.6

全部标签

java - 资源泄漏 : workbook is never closed warning when using Apache. POI XSSFWorkbook

因此,我使用ApachePOI将Excel文件解析到我的数据库中。为此,我正在初始化一个XSSFWorkbook,如下所示:XSSFWorkbookworkbook=newXSSFWorkbook(fIP);然后我继续我的方法。workbook.close()不可用作之后关闭工作簿的方法。关于任务完成后如何让垃圾回收处理工作簿的任何想法? 最佳答案 我遇到了这个问题,但毫无意义。最后,我将问题追溯到我的IDE(netbeans)正在获取没有“关闭”方法的早期版本的POI库(v3.8)。因此,请检查您的类路径并查找不同版本的POI库的

java - 加入数据框 spark java

Firstofall,thankyouforthetimeinreadingmyquestion.Myquestionisthefollowing:InSparkwithJava,iloadintwodataframethedataoftwocsvfiles.Thesedataframeswillhavethefollowinginformation.DataframeAirportId|Name|City-----------------------1|Barajas|MadridDataframeairport_city_stateCity|state---------------

java - org.apache.xbean.asm5.ClassReader 中的 Spark Java IllegalArgumentException

我正在尝试将Spark2.3.1与Java结合使用。我遵循示例inthedocumentation但在调用.fit(trainingData)时不断收到描述不佳的异常。Exceptioninthread"main"java.lang.IllegalArgumentExceptionatorg.apache.xbean.asm5.ClassReader.(UnknownSource)atorg.apache.xbean.asm5.ClassReader.(UnknownSource)atorg.apache.xbean.asm5.ClassReader.(UnknownSource)at

java - 如何从代码启动和使用 Apache Felix?

我无法从代码中找到有关开始和使用ApacheFelix的信息。我想用ApacheFelix的Shell做我能够(或不能;))的事情。例如,我如何启动一个模块?请帮忙。 最佳答案 因此,在尝试了很多时间之后,这里有一个可能的解决方案。我们将有两个项目:OsgiModuleA,其中包含一个要启动的模块OsgiUsage,它将使用“模块A”OsgiModuleA项目文件模块/a/Activator.javapackagemodule.a;importorg.osgi.framework.*;publicclassActivatorimpl

java - 在 JAVA 中使用 Apache POI 和 iText 从 Word (DOC) 创建 PDF

我正在尝试从*.doc文档生成PDF文档。到现在为止,多亏了stackoverflow,我成功生成了它,但遇到了一些问题。我下面的示例代码生成没有格式和图像的pdf,只有文本。该文档包含PDF中未包含的空白区域和图像。代码如下:in=newFileInputStream(sourceFile.getAbsolutePath());out=newFileOutputStream(outputFile);WordExtractorwd=newWordExtractor(in);Stringtext=wd.getText();Documentpdf=newDocument(PageSize.

java - Apache POI 货币数据格式

我尝试使用ApachePOI将数字转换为欧洲货币样式HSSFDataFormatcf=workbook.createDataFormat();currencyCellStyle=workbook.createCellStyle();currencyCellStyle.setDataFormat(cf.getFormat("#.###,#0"));例如我有数字2400和2.4我想要的是2400,00和2,40。但是POI给了我2400,0和2,40。当我尝试将其更改为currencyCellStyle.setDataFormat(cf.getFormat("#.###,00"));我得到

java - Apache Commons Math 的标准偏差

我正在使用ApacheCommonsMath计算vector的SD。问题:我得到的值与手动得到的值不同DescriptiveStatisticsstats=newDescriptiveStatistics();stats.addValue(value1);...stats.addValue(value8);stats.getStandardDeviation();例如,取值[1699.0,1819.0,1699.0,1719.0,1689.0,1709.0,1819.0,1689.0]。SD应为52.067,但CommonsMath=55.662。我做错了什么?

java - 如果我在 Spark 中两次缓存相同的 RDD 会发生什么

我正在构建一个通用函数,它接收一个RDD并对其进行一些计算。由于我在输入RDD上运行了多个计算,所以我想缓存它。例如:publicJavaRDDfoo(JavaRDDr){r.cache();JavaRDDt1=r...//SomecalculationsJavaRDDt2=r...//Othercalculationsreturnt1.union(t2);}我的问题是,因为r给我它可能已经或可能没有被缓存。如果它被缓存并且我再次对其调用缓存,将创建一个新的缓存层,这意味着t1和t2计算出我将有两个r的实例在缓存中?或者willspark会意识到r被缓存并会忽略它?

java - 如何使用 java 从 Spark 中的列表或数组创建行

在Java中,我使用RowFactory.create()来创建行:Rowrow=RowFactory.create(record.getLong(1),record.getInt(2),record.getString(3));其中“record”是数据库中的一条记录,但我无法预先知道“record”的长度,所以我想使用一个列表或一个数组来创建“行”。在Scala中,我可以使用Row.fromSeq()从列表或数组创建行,但我如何在Java中实现这一点? 最佳答案 我们经常需要在现实世界的应用程序中创建数据集或数据帧。以下是如何在

java - Apache Commons Net FTP 正在上传损坏的文件

我正在尝试使用ApacheCommonsNet进行FTP文件传输。问题是文件间歇性地到达服务器损坏。“损坏”是指WinRAR告诉我一个ZIP文件有一个“意外的存档结束”。有时文件是完全空的。我注意到,对于较大的文件(100kb+),这种情况更常见,但对于小文件(20kb)也会发生这种情况。我知道上传的源zip文件是有效的,而且只有243kb。我没有从代码中得到任何错误/异常。下面是正在执行的代码:intCON_TIMEOUT=(int)TimeUnit.SECONDS.toMillis(20);//failifcan'tconnectwithin20secondsintLIVE_TIM