smile.io

Class Avro

java.lang.Object

smile.io.Avro

public class Avro
extends java.lang.Object

Apache Avro is a data serialization system.

Avro provides rich data structures, a compact, fast, binary data format, a container file, to store persistent data, and remote procedure call (RPC).

Avro relies on schemas. When Avro data is stored in a file, its schema is stored with it. Avro schemas are defined with JSON.

Constructor Summary

Constructors

Constructor and Description
Avro(java.io.InputStream schema) Constructor.
Avro(java.nio.file.Path schema) Constructor.
Avro(org.apache.avro.Schema schema) Constructor.

Method Summary

Modifier and Type	Method and Description
smile.data.DataFrame	read(java.io.InputStream input, int limit) Reads a limited number of records from an avro file.
smile.data.DataFrame	read(java.nio.file.Path path) Reads an avro file.
smile.data.DataFrame	read(java.lang.String path) Reads an avro file.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

Avro

public Avro(org.apache.avro.Schema schema)

Constructor.

Avro

public Avro(java.io.InputStream schema)
     throws java.io.IOException

Constructor.

Parameters:

schema - the input stream of schema.

Throws:

java.io.IOException

Avro

public Avro(java.nio.file.Path schema)
     throws java.io.IOException

Constructor.

Parameters:

schema - Avro schema file path.

Throws:

java.io.IOException

Method Detail

read

public smile.data.DataFrame read(java.nio.file.Path path)
                          throws java.io.IOException

Reads an avro file.

Parameters:

path - an Apache Avro file path.

Throws:

java.io.IOException

read

public smile.data.DataFrame read(java.lang.String path)
                          throws java.io.IOException,
                                 java.net.URISyntaxException

Reads an avro file.

Parameters:

path - an Apache Avro file path or URI.

Throws:

java.io.IOException

java.net.URISyntaxException

read

public smile.data.DataFrame read(java.io.InputStream input,
                                 int limit)
                          throws java.io.IOException

Reads a limited number of records from an avro file.

Parameters:

input - an Apache Avro file input stream.

limit - reads a limited number of records.

Throws:

java.io.IOException