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,
SupplierEx<org.apache.avro.Schema> schemaSupplier,
SupplierEx<org.apache.avro.io.DatumWriter<D>> datumWriterSupplier)
|
@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 SupplierEx<org.apache.avro.Schema> schemaSupplier, @Nonnull SupplierEx<org.apache.avro.io.DatumWriter<D>> datumWriterSupplier)
Copyright © 2019 Hazelcast, Inc.. All rights reserved.