org.apache.beam.sdk.extensions.avro.io

Interface AvroSource.DatumReaderFactory<T>

All Superinterfaces:

java.io.Serializable

Enclosing class:

AvroSource<T>

Functional Interface:

This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.

@FunctionalInterface
public static interface AvroSource.DatumReaderFactory<T>
extends java.io.Serializable

Method Summary

Modifier and Type	Method and Description
DatumReader<T>	apply(Schema writer, Schema reader)

Method Detail

apply

DatumReader<T> apply(Schema writer,
                     Schema reader)