本文整理了Java中com.opencsv.CSVReader.readNext()
方法的一些代码示例,展示了CSVReader.readNext()
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。CSVReader.readNext()
方法的具体详情如下:
包路径:com.opencsv.CSVReader
类名称:CSVReader
方法名:readNext
[英]Reads the next line from the buffer and converts to a string array.
[中]从缓冲区读取下一行并转换为字符串数组。
代码示例来源:origin: apache/incubator-gobblin
valueList = Lists.newArrayList(csvr.readNext());
} catch (IOException ioe) {
throw new RuntimeException(ioe);
代码示例来源:origin: neo4j-contrib/neo4j-apoc-procedures
public CSVSpliterator(CSVReader csv, String[] header, String url, long skip, long limit, boolean ignore, Map<String, Mapping> mapping, List<String> nullValues, EnumSet<Results> results) throws IOException {
super(Long.MAX_VALUE, Spliterator.ORDERED);
this.csv = csv;
this.header = header;
this.url = url;
this.ignore = ignore;
this.mapping = mapping;
this.nullValues = nullValues;
this.results = results;
this.limit = skip + limit;
lineNo = skip;
while (skip-- > 0) {
csv.readNext();
}
}
代码示例来源:origin: neo4j-contrib/neo4j-apoc-procedures
private String[] getHeader(boolean hasHeader, CSVReader csv, List<String> ignore, Map<String, Mapping> mapping) throws IOException {
if (!hasHeader) return null;
String[] header = csv.readNext();
if (ignore.isEmpty()) return header;
for (int i = 0; i < header.length; i++) {
if (ignore.contains(header[i]) || mapping.getOrDefault(header[i], Mapping.EMPTY).ignore) {
header[i] = null;
}
}
return header;
}
代码示例来源:origin: neo4j-contrib/neo4j-apoc-procedures
@Override
public boolean tryAdvance(Consumer<? super CSVResult> action) {
try {
String[] row = csv.readNext();
if (row != null && lineNo < limit) {
action.accept(new CSVResult(header, row, lineNo++, ignore,mapping, nullValues,results));
return true;
}
return false;
} catch (IOException e) {
throw new RuntimeException("Error reading CSV from URL " + cleanUrl(url) + " at " + lineNo, e);
}
}
}
代码示例来源:origin: com.opencsv/opencsv
/**
* Skip a given number of lines.
* @param numberOfLinesToSkip The number of lines to skip
* @since 4.2
* @throws IOException If anything bad happens when reading the file
*/
public void skip(int numberOfLinesToSkip) throws IOException {
for (int j = 0; j < numberOfLinesToSkip; j++) {
readNext();
}
}
代码示例来源:origin: com.opencsv/opencsv
/**
* @param reader Reader for the CSV data.
* @throws IOException If unable to read data from the reader.
*/
public CSVIterator(CSVReader reader) throws IOException {
this.reader = reader;
nextLine = reader.readNext();
}
代码示例来源:origin: com.opencsv/opencsv
/**
* Returns the next line from the input without removing it from the
* CSVReader.
* Subsequent calls to this method will continue to return the same line
* until a call is made to {@link #readNext()} or any other method that
* advances the cursor position in the input. The first call to
* {@link #readNext()} after calling this method will return the same line
* this method does.
*
* @return The next line from the input, or null if there are no more lines
* @throws IOException If bad things happen during the read operation
* @since 4.2
*/
public String[] peek() throws IOException {
if(peekedLine == null) {
peekedLine = readNext();
}
return peekedLine;
}
}
代码示例来源:origin: com.opencsv/opencsv
private void initializeHeader() throws IOException {
String[] headers = super.readNext();
for (int i = 0; i < headers.length; i++) {
headerIndex.put(headers[i], i);
}
}
代码示例来源:origin: org.eclipse.rdf4j/rdf4j-client
@Override
public void captureHeader(CSVReader reader) throws IOException {
// header is mandatory in SPARQL CSV
bindingNames = Arrays.asList(reader.readNext());
}
代码示例来源:origin: eclipse/rdf4j
@Override
public void captureHeader(CSVReader reader) throws IOException {
// header is mandatory in SPARQL CSV
bindingNames = Arrays.asList(reader.readNext());
}
代码示例来源:origin: eclipse/rdf4j
@Override
public void captureHeader(CSVReader reader) throws IOException {
// header is mandatory in SPARQL TSV
bindingNames = Stream.of(reader.readNext())
.map(s -> StringUtils.removeStart(s, "?"))
.collect(Collectors.toList());
}
代码示例来源:origin: md-5/SpecialSource
private void readIntoMap(File file, Map<String, String> map) throws IOException {
try (FileReader fileReader = new FileReader(file);
CSVReader csvReader = new CSVReader(fileReader)) {
String[] line;
while ((line = csvReader.readNext()) != null) {
if (line.length == 0) {
continue;
}
Preconditions.checkArgument(line.length >= 2, "Invalid csv line: %s", (Object) line);
map.put(line[0], line[1]);
}
}
}
代码示例来源:origin: kakao/hbase-tools
private void readHeader(CSVReader reader, List<LoadEntry> savedLoadEntryList) throws IOException {
String[] nextLine;
nextLine = reader.readNext();
for (String string : nextLine) {
try {
savedLoadEntryList.add(LoadEntry.valueOf(string));
} catch (Exception ignored) {
}
}
}
代码示例来源:origin: com.opencsv/opencsv
/**
*
* Returns the next element in the iterator.
*
* @return The next element of the iterator.
*/
@Override
public String[] next() {
String[] temp = nextLine;
try {
nextLine = reader.readNext();
} catch (IOException e) {
NoSuchElementException nse = new NoSuchElementException(e.getLocalizedMessage());
nse.initCause(e);
throw nse;
}
return temp;
}
代码示例来源:origin: io.github.therealmone/TranslatorAPI
public static void loadAnalyzeTable(InputStream is) {
analyzeTable = new HashMap<>();
try {
CSVReader csvReader = new CSVReader(new InputStreamReader(is));
String[] description = csvReader.readNext();
String[] nextLine;
while ((nextLine = csvReader.readNext()) != null) {
Map<String, Integer> tmp = new HashMap<>();
for (int i = 1; i < nextLine.length; i++) {
tmp.put(description[i], Integer.parseInt(nextLine[i]));
}
analyzeTable.put(nextLine[0], tmp);
}
csvReader.close();
} catch (Exception e) {
throw new RuntimeException(e);
}
}
代码示例来源:origin: io.github.therealmone/TranslatorAPI
public static void loadLangRules(InputStream is) {
langRules = new HashMap<>();
try {
CSVReader csvReader = new CSVReader(new InputStreamReader(is));
String[] nextLine;
csvReader.readNext();
while ((nextLine = csvReader.readNext()) != null) {
try {
langRules.put(Integer.parseInt(nextLine[0].trim()), nextLine[2].split("\\s\\+\\s"));
} catch (NumberFormatException e) {
e.printStackTrace();
}
}
csvReader.close();
} catch (Exception e) {
throw new RuntimeException(e);
}
}
代码示例来源:origin: io.mindmaps/migration-csv
/**
* Convert native data format (CSVReader) to stream of templates
* @param template parametrized graql insert query
* @param reader CSV reader of data file
* @return Stream of data migrated into templates
* @throws IOException
*/
private Stream<String> resolve(String template, CSVReader reader) throws IOException {
String[] header = reader.readNext();
return partitionedStream(reader.iterator())
.map(batch -> batchParse(header, batch))
.map(data -> template(template, data));
}
代码示例来源:origin: tarql/tarql
@Override
public Binding next() {
Binding current = binding;
binding = null;
String[] row;
try {
while ((row = csv.readNext()) != null) {
// Skip rows without data
if (isEmpty(row))
continue;
binding = toBinding(row);
rownum++;
break;
}
} catch (IOException e) {
throw new TarqlException(e);
}
return current;
}
代码示例来源:origin: org.apache.metamodel/MetaModel-csv
private List<Column> buildColumns() {
CSVReader reader = null;
try {
reader = _schema.getDataContext().createCsvReader(0);
final int columnNameLineNumber = _schema.getDataContext().getConfiguration().getColumnNameLineNumber();
for (int i = 1; i < columnNameLineNumber; i++) {
reader.readNext();
}
final List<String> columnHeaders = Arrays.asList(Optional.ofNullable(reader.readNext()).orElse(new String[0]));
reader.close();
return buildColumns(columnHeaders);
} catch (IOException e) {
throw new IllegalStateException("Exception reading from resource: "
+ _schema.getDataContext().getResource().getName(), e);
} finally {
FileHelper.safeClose(reader);
}
}
代码示例来源:origin: apache/metamodel
private List<Column> buildColumns() {
CSVReader reader = null;
try {
reader = _schema.getDataContext().createCsvReader(0);
final int columnNameLineNumber = _schema.getDataContext().getConfiguration().getColumnNameLineNumber();
for (int i = 1; i < columnNameLineNumber; i++) {
reader.readNext();
}
final List<String> columnHeaders = Arrays.asList(Optional.ofNullable(reader.readNext()).orElse(new String[0]));
reader.close();
return buildColumns(columnHeaders);
} catch (IOException e) {
throw new IllegalStateException("Exception reading from resource: "
+ _schema.getDataContext().getResource().getName(), e);
} finally {
FileHelper.safeClose(reader);
}
}
内容来源于网络,如有侵权,请联系作者删除!