草庐IT

apache-kafka-streams

全部标签

java - 使用 apache 公共(public)配置 XMLConfiguration 格式化 XML 输出

我正在使用apache公共(public)配置XMLConfiguration来构建和保存XML文件。保存时没有格式。我得到类似的东西:我知道有很多方法可以使用其他一些库来获取该输出并对其进行格式化,但肯定有一种方法可以设置像从公共(public)配置缩进一样简单的东西? 最佳答案 遇到了同样的问题。虽然很久以前就有人问过这个问题,但还是想分享一个解决方案:XMLConfiguration类有一个名为createTransformed的protected方法。它应该由rightconfiguration扩展和设置用于缩进。publi

java - 如何在 HttpClient 中自动重定向(java,apache)

我创建httpClient并设置设置HttpClientclient=newHttpClient();client.getParams().setCookiePolicy(CookiePolicy.BROWSER_COMPATIBILITY);client.getParams().setContentCharset("UTF-8");第一次请求(获取)GetMethodfirst=newGetMethod("http://vk.com");intreturnCode=client.executeMethod(first);BufferedReaderbr=null;Stringline

java - Apache CXF + Spring : Generating a Simple Client

我已经开始使用Spring学习ApacheCXF。首先,我尝试创建一个简单的客户端/服务器模型。服务器端是:service.HelloWorld.java@WebServicepublicinterfaceHelloWorld{StringsayHi(Stringtext);}service.HelloWorldImpl.java@WebService(endpointInterface="service.HelloWorld")publicclassHelloWorldImplimplementsHelloWorld{publicStringsayHi(Stringtext){ret

java - 使用 Apache PDFBox 添加文本时如何移动到下一行

我刚刚开始使用ApachePDFBox,并一直在试验我发现的各种示例。但是,我一直没能找到在添加文本时移动到下一行的简单方法。例如PDPageContentStreamcontent=newPDPageContentStream(document,page);PDFontfont=PDType1Font.HELVETICA;content.beginText();content.setFont(font,12);content.moveTextPositionByAmount(x,y);content.drawString("Sometext.");content.endText();

java - Apache POI : API to identify tables in the excel sheet and read them

是否有任何方法可以返回工作表中存在的表格列表?我的要求是从工作表上存在的多个表中获取数据。 最佳答案 假设您正在为.xlsxexcel文件使用XSSFAPI。如果表格是由Insert->Table创建的,那么您可以使用以下命令读取它们:XSSFWorkbookworkbook=newXSSFWorkbook(newFile("test.xlsx"));intnumberOfSheets=workbook.getNumberOfSheets();for(intsheetIdx=0;sheetIdxtables=sheet.getTab

java - 如何在 Apache Spark 中为两个具有不同结构的 DataFrame 实现 NOT IN

我在我的Java应用程序中使用ApacheSpark。我有两个DataFrame小号:df1和df2.df1包含Row与email,firstName和lastName.df2包含Row与email.我想创建一个DataFrame:df3包含df1中的所有行,df2中不存在哪个电子邮件.有没有办法用ApacheSpark做到这一点?我试图创建JavaRDD来自df1和df2通过类型转换它们toJavaRDD()和过滤df1包含所有电子邮件,然后使用subtract,但我不知道如何映射新的JavaRDD至ds1得到DataFrame.基本上我需要df1中的所有行谁的邮箱不在df2.Dat

java - 在 Java 8 中,如何在不使用 forEach 的情况下从 Stream<int[]> 获取 int 数组

如何转换Stream进入int[]不使用forEach?finalStreamstream=foos.stream().map(foos->insertQuery(contact,create)).map(create::batch).map(Batch::execute);//Batch::executewillreturntheint[] 最佳答案 使用flatMapToIntint[]result=stream.flatMapToInt(Arrays::stream).toArray();

java - 如何使用 Streams 将二维列表转换为一维列表?

我试过这段代码(list是ArrayList>):list.stream().flatMap(Stream::of).collect(Collectors.toList());但它什么也没做;该列表仍然是一个二维列表。如何将此二维列表转换为一维列表? 最佳答案 您仍然收到列表的原因是因为当您申请Stream::of它正在返回现有流的新流。那是你执行Stream::of的时候这就像有{{{1,2}},{{3,4}},{{5,6}}}然后当你执行flatMap就像这样做:{{{1,2}},{{3,4}},{{5,6}}}->flatMa

Java 8 Stream distinct 不起作用

这就是我正在做的:Listscores=Stream.concat(oldEntries.stream(),newEntries.stream()).sorted().distinct().limit(maxSize).collect(Collectors.toList());我期待一个没有任何重复项的排序列表,但有时列表中有重复项。我重写了hashCode和equals方法,我还观察到这些方法每次都返回正确的值。任何人都可以看到我的流有什么问题吗?这是我的equals()和hashCode()它们是由IDEA自动生成的:..privateintuserId;privateintlev

java - 是否可以创建在单个操作中计算其元素的 Stream 实现

问:是否可以创建Stream实现,在单个操作中对它们的元素进行计数,而不是对流中的每个元素进行计数?当我试图比较列表中的两种方法时,我想到了这个:大小()count()Stream::count终端操作计算流中元素的数量。操作的复杂度通常为O(N),这意味着子操作的数量与Stream中的元素数量成正比。List::size方法的复杂度为O(1),这意味着无论List中的元素数量如何,size()方法将在常数时间内返回。Listlist=IntStream.range(0,100).boxed().collect(toList());System.out.println(list.siz