我正在node.js中读取一个文件(300,000行)。我想以5,000行为一组将行发送到另一个应用程序(Elasticsearch)以存储它们。因此，每当我读完5,000行时，我想通过API将它们批量发送到Elasticsearch以存储它们，然后继续读取文件的其余部分并批量发送每5,000行。如果我想使用java(或任何其他阻塞语言，如C、C++、python等)来完成此任务，我将执行如下操作:intcountLines=0;StringbulkString="";BufferedReaderbr=newBufferedReader(newInputStreamReader(new

我正在尝试使用我在thispage底部找到的一些代码.这是我为其创建的类中的代码:importjava.io.LineNumberReader;importjava.io.FileReader;importjava.io.IOException;publicclassLineCounter{publicstaticintcountLines(Stringfilename)throwsIOException{LineNumberReaderreader=newLineNumberReader(newFileReader(filename));intcnt=0;StringlineRead