Index

A B C F G R S W
All Classes and Interfaces|All Packages

A

AvroProcessors - Class in com.hazelcast.jet.avro

Static utility class with factories of Apache Avro source and sink processors.

AvroSinks - Class in com.hazelcast.jet.avro

Contains factory methods for Apache Avro sinks.

AvroSourceBuilder<D> - Class in com.hazelcast.jet.avro

Builder for an Avro file source that reads records from Avro files in a directory (but not its subdirectories) and emits objects returned by mapOutputFn.

AvroSources - Class in com.hazelcast.jet.avro

Contains factory methods for Apache Avro sources.

B

build() - Method in class com.hazelcast.jet.avro.AvroSourceBuilder

Convenience for build(BiFunctionEx).

build(BiFunctionEx<String, ? super D, T>) - Method in class com.hazelcast.jet.avro.AvroSourceBuilder

Builds a custom Avro file BatchSource with supplied components and the output function mapOutputFn.

C

com.hazelcast.jet.avro - package com.hazelcast.jet.avro

Apache Avro file read/write support for Hazelcast Jet.

F

files(String, BiFunctionEx<String, GenericRecord, D>) - Static method in class com.hazelcast.jet.avro.AvroSources

Convenience for AvroSources.filesBuilder(String, SupplierEx) which reads all the files in the supplied directory as generic records and emits the results of transforming each generic record with the supplied mapping function.

files(String, Class<D>) - Static method in class com.hazelcast.jet.avro.AvroSources

Convenience for AvroSources.filesBuilder(String, Class) which reads all the files in the supplied directory as specific records using supplied datumClass.

files(String, Class<R>, Schema) - Static method in class com.hazelcast.jet.avro.AvroSinks

Convenience for AvroSinks.files(String, Schema, SupplierEx) which uses either SpecificDatumWriter or ReflectDatumWriter depending on the supplied recordClass.

files(String, Schema) - Static method in class com.hazelcast.jet.avro.AvroSinks

Convenience for AvroSinks.files(String, Schema, SupplierEx) which uses GenericDatumWriter.

files(String, Schema, SupplierEx<DatumWriter<R>>) - Static method in class com.hazelcast.jet.avro.AvroSinks

Returns a sink that that writes the items it receives to Apache Avro files.

filesBuilder(String, SupplierEx<? extends DatumReader<D>>) - Static method in class com.hazelcast.jet.avro.AvroSources

Returns a builder object that offers a step-by-step fluent API to build a custom Avro file source for the Pipeline API.

filesBuilder(String, Class<D>) - Static method in class com.hazelcast.jet.avro.AvroSources

Returns a builder object that offers a step-by-step fluent API to build a custom Avro file source for the Pipeline API.

G

glob(String) - Method in class com.hazelcast.jet.avro.AvroSourceBuilder

Sets the globbing mask, see getPathMatcher().

R

readFilesP(String, String, boolean, SupplierEx<? extends DatumReader<D>>, BiFunctionEx<String, ? super D, T>) - Static method in class com.hazelcast.jet.avro.AvroProcessors

Returns a supplier of processors for AvroSources.filesBuilder(java.lang.String, java.lang.Class<D>).

S

sharedFileSystem(boolean) - Method in class com.hazelcast.jet.avro.AvroSourceBuilder

Sets whether files are in a shared storage visible to all members.

W

writeFilesP(String, Schema, SupplierEx<DatumWriter<D>>) - Static method in class com.hazelcast.jet.avro.AvroProcessors

Returns a supplier of processors for AvroSinks.files(java.lang.String, org.apache.avro.Schema, com.hazelcast.function.SupplierEx<org.apache.avro.io.DatumWriter<R>>).

A B C F G R S W
All Classes and Interfaces|All Packages