com.hazelcast.jet.avro

Class AvroProcessors

java.lang.Object

com.hazelcast.jet.avro.AvroProcessors

public final class AvroProcessors
extends Object

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

Since:

Jet 3.0

Method Summary

Modifier and Type	Method and Description
static <D,T> ProcessorMetaSupplier	readFilesP(String directory, String glob, boolean sharedFileSystem, SupplierEx<? extends org.apache.avro.io.DatumReader<D>> datumReaderSupplier, BiFunctionEx<String,? super D,T> mapOutputFn) Returns a supplier of processors for AvroSources.filesBuilder(java.lang.String, java.lang.Class<D>).
static <D> ProcessorMetaSupplier	writeFilesP(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
                                                              String directory,
                                                              @Nonnull
                                                              String glob,
                                                              boolean sharedFileSystem,
                                                              @Nonnull
                                                              SupplierEx<? extends org.apache.avro.io.DatumReader<D>> datumReaderSupplier,
                                                              @Nonnull
                                                              BiFunctionEx<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
                                                             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>>).