Package | Description |
---|---|
com.hazelcast.jet.avro |
Apache Avro file read/write support for Hazelcast Jet.
|
Modifier and Type | Method and Description |
---|---|
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.
|
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.
|
AvroSourceBuilder<D> |
AvroSourceBuilder.glob(String glob)
Sets the globbing mask, see
getPathMatcher() . |
AvroSourceBuilder<D> |
AvroSourceBuilder.sharedFileSystem(boolean sharedFileSystem)
Sets whether files are in a shared storage visible to all members.
|
Copyright © 2021 Hazelcast, Inc.. All rights reserved.