Module datarush.library

Package com.pervasive.datarush.operators.testutils

Class AvroTestUtils

java.lang.Object

com.pervasive.datarush.operators.testutils.AvroTestUtils

public class AvroTestUtils
extends Object

Field Summary

Fields

Modifier and Type	Field	Description
static RecordTokenType	ALL_TYPES

Constructor Summary

Constructors

Constructor	Description
AvroTestUtils()

Method Summary

Modifier and Type	Method	Description
static Object	avroBytes(byte[] value)
static Object	avroDate(int year, int monthOfYear, int dayOfMonth)
static Object	avroEnum(org.apache.avro.Schema schema, String value)
static Object	avroFixed(org.apache.avro.Schema schema, byte[] value)
static Object	avroString(String value)
static Object	avroTime(int hourOfDay, int minuteOfHour, int secondOfMinute)
static Object	avroTimestamp(long secs, int nanos, int offset)
static RecordTokenList	constructData(List<? extends ScalarToken> values)
static List<org.apache.avro.generic.GenericRecord>	constructData(org.apache.avro.Schema schema, String field, List<?> values)
static org.apache.avro.Schema	makeNullable(org.apache.avro.Schema schema)
static RecordTokenList	readAvroData(String path, String... fields)
static List<org.apache.avro.generic.GenericRecord>	readAvroFile(String path)
static void	writeAvroData(String path, RecordTokenList data, org.apache.avro.Schema targetSchema)
static void	writeAvroData(String path, RecordTokenList data, org.apache.avro.Schema targetSchema, WriteMode mode)
static <T> void	writeAvroFile(String outputPath, List<T> data, org.apache.avro.Schema targetSchema)

Methods inherited from class java.lang.Object

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

Field Detail

ALL_TYPES

public static final RecordTokenType ALL_TYPES

Constructor Detail

AvroTestUtils

public AvroTestUtils()

Method Detail

makeNullable

public static org.apache.avro.Schema makeNullable(org.apache.avro.Schema schema)

readAvroData

public static RecordTokenList readAvroData(String path,
                                           String... fields)

writeAvroData

public static void writeAvroData(String path,
                                 RecordTokenList data,
                                 org.apache.avro.Schema targetSchema)

writeAvroData

public static void writeAvroData(String path,
                                 RecordTokenList data,
                                 org.apache.avro.Schema targetSchema,
                                 WriteMode mode)

readAvroFile

public static List<org.apache.avro.generic.GenericRecord> readAvroFile(String path)
                                                                throws IOException

Throws:

IOException

writeAvroFile

public static <T> void writeAvroFile(String outputPath,
                                     List<T> data,
                                     org.apache.avro.Schema targetSchema)
                              throws IOException

Throws:

IOException

constructData

public static RecordTokenList constructData(List<? extends ScalarToken> values)

constructData

public static List<org.apache.avro.generic.GenericRecord> constructData(org.apache.avro.Schema schema,
                                                                        String field,
                                                                        List<?> values)

avroBytes

public static Object avroBytes(byte[] value)

avroFixed

public static Object avroFixed(org.apache.avro.Schema schema,
                               byte[] value)

avroString

public static Object avroString(String value)

avroEnum

public static Object avroEnum(org.apache.avro.Schema schema,
                              String value)

avroDate

public static Object avroDate(int year,
                              int monthOfYear,
                              int dayOfMonth)

avroTime

public static Object avroTime(int hourOfDay,
                              int minuteOfHour,
                              int secondOfMinute)

avroTimestamp

public static Object avroTimestamp(long secs,
                                   int nanos,
                                   int offset)