Package com.hazelcast.jet.avro

Class AvroProcessors

java.lang.Object

com.hazelcast.jet.avro.AvroProcessors

public final class AvroProcessors
extends java.lang.Object

Static utility class with factories of Apache Avro source and sink processors.

Since:

Jet 3.0

Method Summary

Modifier and Type	Method	Description
static <D,T> ProcessorMetaSupplier	readFilesP(java.lang.String directory, java.lang.String glob, boolean sharedFileSystem, SupplierEx<? extends org.apache.avro.io.DatumReader<D>> datumReaderSupplier, BiFunctionEx<java.lang.String,? super D,T> mapOutputFn)	Returns a supplier of processors for AvroSources.filesBuilder(java.lang.String, java.lang.Class<D>).
static <D> ProcessorMetaSupplier	writeFilesP(java.lang.String directoryName, org.apache.avro.Schema schema, SupplierEx<org.apache.avro.io.DatumWriter<D>> datumWriterSupplier)	Returns a supplier of processors for AvroSinks.files(java.lang.String, org.apache.avro.Schema, com.hazelcast.function.SupplierEx<org.apache.avro.io.DatumWriter<R>>).

Methods inherited from class java.lang.Object

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

Method Detail

readFilesP

@Nonnull
public static <D,T> ProcessorMetaSupplier readFilesP(@Nonnull
                                                           java.lang.String directory,
                                                           @Nonnull
                                                           java.lang.String glob,
                                                           boolean sharedFileSystem,
                                                           @Nonnull
                                                           SupplierEx<? extends org.apache.avro.io.DatumReader<D>> datumReaderSupplier,
                                                           @Nonnull
                                                           BiFunctionEx<java.lang.String,? super D,T> mapOutputFn)

Returns a supplier of processors for AvroSources.filesBuilder(java.lang.String, java.lang.Class<D>).

writeFilesP

@Nonnull
public static <D> ProcessorMetaSupplier writeFilesP(@Nonnull
                                                    java.lang.String directoryName,
                                                    @Nonnull
                                                    org.apache.avro.Schema schema,
                                                    @Nonnull
                                                    SupplierEx<org.apache.avro.io.DatumWriter<D>> datumWriterSupplier)

Returns a supplier of processors for AvroSinks.files(java.lang.String, org.apache.avro.Schema, com.hazelcast.function.SupplierEx<org.apache.avro.io.DatumWriter<R>>).