Uses of Interface
com.hazelcast.function.BiFunctionEx
Package | Description |
---|---|
com.hazelcast.function |
Serializable and exception-declaring variants of functional interfaces from
java.util.function . |
com.hazelcast.jet.avro |
Apache Avro file read/write support for Hazelcast Jet.
|
com.hazelcast.jet.hadoop |
Apache Hadoop read/write support for Hazelcast Jet.
|
com.hazelcast.jet.s3 |
AWS S3 read/write support for Hazelcast Jet.
|
-
Uses of BiFunctionEx in com.hazelcast.function
Methods in com.hazelcast.function that return BiFunctionEx Modifier and Type Method Description default <V> BiFunctionEx<T,U,V>
BiFunctionEx. andThen(FunctionEx<? super R,? extends V> after)
Serializable
variant ofjava.util.function.BiFunction#andThen(Function)
. -
Uses of BiFunctionEx in com.hazelcast.jet.avro
Methods in com.hazelcast.jet.avro with parameters of type BiFunctionEx Modifier and Type Method Description <T> BatchSource<T>
AvroSourceBuilder. build(BiFunctionEx<String,? super D,T> mapOutputFn)
Builds a custom Avro fileBatchSource
with supplied components and the output functionmapOutputFn
.static <D> BatchSource<D>
AvroSources. files(String directory, BiFunctionEx<String,org.apache.avro.generic.GenericRecord,D> mapOutputFn)
Convenience forAvroSources.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.static <D, T> ProcessorMetaSupplier
AvroProcessors. readFilesP(String directory, String glob, boolean sharedFileSystem, SupplierEx<? extends org.apache.avro.io.DatumReader<D>> datumReaderSupplier, BiFunctionEx<String,? super D,T> mapOutputFn)
Returns a supplier of processors forAvroSources.filesBuilder(java.lang.String, java.lang.Class<D>)
. -
Uses of BiFunctionEx in com.hazelcast.jet.hadoop
Methods in com.hazelcast.jet.hadoop with parameters of type BiFunctionEx Modifier and Type Method Description static <K, V, E> BatchSource<E>
HadoopSources. inputFormat(org.apache.hadoop.conf.Configuration configuration, BiFunctionEx<K,V,E> projectionFn)
Returns a source that reads records from Apache Hadoop HDFS and emits the results of transforming each record (a key-value pair) with the supplied projection function.static <K, V, R> ProcessorMetaSupplier
HadoopProcessors. readHadoopP(org.apache.hadoop.conf.Configuration configuration, BiFunctionEx<K,V,R> projectionFn)
Returns a supplier of processors forHadoopSources.inputFormat(Configuration, BiFunctionEx)
. -
Uses of BiFunctionEx in com.hazelcast.jet.s3
Methods in com.hazelcast.jet.s3 with parameters of type BiFunctionEx Modifier and Type Method Description static <I, T> BatchSource<T>
S3Sources. s3(List<String> bucketNames, String prefix, SupplierEx<? extends software.amazon.awssdk.services.s3.S3Client> clientSupplier, FunctionEx<? super InputStream,? extends Stream<I>> readFileFn, BiFunctionEx<String,? super I,? extends T> mapFn)
Creates an AWS S3BatchSource
which lists all the objects in the bucket-list using givenprefix
, reads them using providedreadFileFn
, transforms each read item to the desired output object using givenmapFn
and emits them to downstream.static <T> BatchSource<T>
S3Sources. s3(List<String> bucketNames, String prefix, Charset charset, SupplierEx<? extends software.amazon.awssdk.services.s3.S3Client> clientSupplier, BiFunctionEx<String,String,? extends T> mapFn)
Creates an AWS S3BatchSource
which lists all the objects in the bucket-list using givenprefix
, reads them line by line, transforms each line to the desired output object using givenmapFn
and emits them to downstream.