Package 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	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 Details

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>>).