D- the type of the datum read by
public final class AvroSourceBuilder<D> extends Object
|Modifier and Type||Method and Description|
Builds a custom Avro file
Sets the globbing mask, see
Sets if files are in a shared storage visible to all members.
public AvroSourceBuilder<D> glob(@Nonnull String glob)
getPathMatcher(). Default value is
"*"which means all files.
public AvroSourceBuilder<D> sharedFileSystem(boolean sharedFileSystem)
true, Jet will assume all members
see the same files. They will split the work so that each member will
read a part of the files. If
each member will read all files in the directory, assuming the are
public <T> BatchSource<T> build(@Nonnull com.hazelcast.function.BiFunctionEx<String,? super D,T> mapOutputFn)
BatchSourcewith supplied components and the output function
The source does not save any state to snapshot. If the job is restarted, it will re-emit all entries.
IOException will cause the job to fail. The files must not
change while being read; if they do, the behavior is unspecified.
The default local parallelism for this processor is 2 (or 1 if just 1 CPU is available).
T- the type of the items the source emits
mapOutputFn- the function which creates output object from each record. Gets the filename and record read by
Copyright © 2020 Hazelcast, Inc.. All rights reserved.