org.apache.beam.it.gcp.artifacts.utils

Class AvroTestUtil

java.lang.Object

org.apache.beam.it.gcp.artifacts.utils.AvroTestUtil

public class AvroTestUtil
extends java.lang.Object

The AvroTestUtil class provides common utilities used for executing tests that involve Avro.

Constructor Summary

Constructors

Constructor and Description
AvroTestUtil()

Method Summary

Modifier and Type	Method and Description
static byte[]	createAvroFile(Schema schema, java.util.List<GenericRecord> records) Create Avro file for the given schema and records list.
static java.util.List<GenericRecord>	readRecords(Schema schema, byte[] contents) Read Avro records to a list of GenericRecord.

Methods inherited from class java.lang.Object

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

Constructor Detail

AvroTestUtil

public AvroTestUtil()

Method Detail

createAvroFile

public static byte[] createAvroFile(Schema schema,
                                    java.util.List<GenericRecord> records)
                             throws java.io.IOException

Create Avro file for the given schema and records list.

Parameters:

schema - Schema to use.

records - Records to write on the sink.

Returns:

Byte array that represents the content.

Throws:

java.io.IOException

readRecords

public static java.util.List<GenericRecord> readRecords(Schema schema,
                                                        byte[] contents)
                                                 throws java.io.IOException

Read Avro records to a list of GenericRecord.

Parameters:

schema - Schema to use for reading.

contents - Byte array with contents to read.

Returns:

A list with all records.

Throws:

java.io.IOException