public class JacksonCSVSplitter extends java.lang.Object implements Splitter<JacksonHandle>
Constructor and Description |
---|
JacksonCSVSplitter() |
Modifier and Type | Method and Description |
---|---|
long |
getCount()
The number of JsonNodes found so far.
|
com.fasterxml.jackson.dataformat.csv.CsvMapper |
getCsvMapper()
The CsvMapper configured for the current instance.
|
com.fasterxml.jackson.dataformat.csv.CsvSchema |
getCsvSchema()
The CsvSchema configured for the current instance.
|
com.fasterxml.jackson.databind.node.ArrayNode |
getHeaders()
The headers of the csv file.
|
java.util.stream.Stream<JacksonHandle> |
split(java.io.InputStream input)
Takes the input stream and converts it into a stream of JacksonHandle by setting the schema
and wrapping the JsonNode into JacksonHandle.
|
java.util.stream.Stream<JacksonHandle> |
split(java.io.Reader input)
Takes the input stream and converts it into a stream of JacksonHandle by setting the schema
and wrapping the JsonNode into JacksonHandle.
|
JacksonCSVSplitter |
withCsvMapper(com.fasterxml.jackson.dataformat.csv.CsvMapper mapper)
Used to set the CsvMapper for the current instance.
|
JacksonCSVSplitter |
withCsvSchema(com.fasterxml.jackson.dataformat.csv.CsvSchema schema)
Used to set the CsvSchema for the current instance.
|
public com.fasterxml.jackson.dataformat.csv.CsvMapper getCsvMapper()
public JacksonCSVSplitter withCsvSchema(com.fasterxml.jackson.dataformat.csv.CsvSchema schema)
schema
- is the CsvSchema passed in.public JacksonCSVSplitter withCsvMapper(com.fasterxml.jackson.dataformat.csv.CsvMapper mapper)
mapper
- is the CsvMapper passed in.public com.fasterxml.jackson.dataformat.csv.CsvSchema getCsvSchema()
public java.util.stream.Stream<JacksonHandle> split(java.io.InputStream input) throws java.lang.Exception
split
in interface Splitter<JacksonHandle>
input
- the input stream passed in.java.lang.Exception
public java.util.stream.Stream<JacksonHandle> split(java.io.Reader input) throws java.lang.Exception
input
- the Reader stream passed in.java.lang.Exception
public long getCount()
getCount
in interface Splitter<JacksonHandle>
public com.fasterxml.jackson.databind.node.ArrayNode getHeaders()
Copyright © 2013-2018 MarkLogic Corporation.