public final class AvroProcessors extends Object
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>>) . |
@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)
AvroSources.filesBuilder(java.lang.String, java.lang.Class<D>)
.@Nonnull public static <D> ProcessorMetaSupplier writeFilesP(@Nonnull String directoryName, @Nonnull org.apache.avro.Schema schema, @Nonnull SupplierEx<org.apache.avro.io.DatumWriter<D>> datumWriterSupplier)
AvroSinks.files(java.lang.String, org.apache.avro.Schema, com.hazelcast.function.SupplierEx<org.apache.avro.io.DatumWriter<R>>)
.Copyright © 2023 Hazelcast, Inc.. All rights reserved.