Uses of Class
com.hazelcast.jet.avro.AvroSourceBuilder
Package | Description |
---|---|
com.hazelcast.jet.avro |
Apache Avro file read/write support for Hazelcast Jet.
|
-
Uses of AvroSourceBuilder in com.hazelcast.jet.avro
Methods in com.hazelcast.jet.avro that return AvroSourceBuilder Modifier and Type Method Description static <D> AvroSourceBuilder<D>
AvroSources. filesBuilder(String directory, SupplierEx<? extends org.apache.avro.io.DatumReader<D>> datumReaderSupplier)
Returns a builder object that offers a step-by-step fluent API to build a custom Avro file source for the Pipeline API.static <D> AvroSourceBuilder<D>
AvroSources. filesBuilder(String directory, Class<D> recordClass)
Returns a builder object that offers a step-by-step fluent API to build a custom Avro file source for the Pipeline API.AvroSourceBuilder<D>
AvroSourceBuilder. glob(String glob)
Sets the globbing mask, seegetPathMatcher()
.AvroSourceBuilder<D>
AvroSourceBuilder. sharedFileSystem(boolean sharedFileSystem)
Sets whether files are in a shared storage visible to all members.