public final class AvroProcessors extends Object
Modifier and Type | Method and Description |
---|---|
static <D,T> ProcessorMetaSupplier |
readFilesP(String directory,
String glob,
boolean sharedFileSystem,
DistributedSupplier<? extends org.apache.avro.io.DatumReader<D>> datumReaderSupplier,
DistributedBiFunction<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,
DistributedSupplier<org.apache.avro.Schema> schemaSupplier,
DistributedSupplier<org.apache.avro.io.DatumWriter<D>> datumWriterSupplier)
|
@Nonnull public static <D,T> ProcessorMetaSupplier readFilesP(@Nonnull String directory, @Nonnull String glob, boolean sharedFileSystem, @Nonnull DistributedSupplier<? extends org.apache.avro.io.DatumReader<D>> datumReaderSupplier, @Nonnull DistributedBiFunction<String,? super D,T> mapOutputFn)
AvroSources.filesBuilder(java.lang.String, java.lang.Class<D>)
.@Nonnull public static <D> ProcessorMetaSupplier writeFilesP(@Nonnull String directoryName, @Nonnull DistributedSupplier<org.apache.avro.Schema> schemaSupplier, @Nonnull DistributedSupplier<org.apache.avro.io.DatumWriter<D>> datumWriterSupplier)
Copyright © 2018 Hazelcast, Inc.. All rights reserved.