Package com.hazelcast.jet.hadoop
Class HadoopProcessors
java.lang.Object
com.hazelcast.jet.hadoop.HadoopProcessors
public final class HadoopProcessors extends Object
Static utility class with factories of Apache Hadoop Hadoop source and sink
processors.
- Since:
- 3.0
-
Method Summary
Modifier and Type Method Description static <K, V, R> ProcessorMetaSupplier
readHadoopP(org.apache.hadoop.conf.Configuration configuration, BiFunctionEx<K,V,R> projectionFn)
Returns a supplier of processors forHadoopSources.inputFormat(Configuration, BiFunctionEx)
.static <E, K, V> ProcessorMetaSupplier
writeHadoopP(org.apache.hadoop.conf.Configuration configuration, FunctionEx<? super E,K> extractKeyFn, FunctionEx<? super E,V> extractValueFn)
Returns a supplier of processors forHadoopSinks.outputFormat(Configuration, FunctionEx, FunctionEx)
.
-
Method Details
-
readHadoopP
@Nonnull public static <K, V, R> ProcessorMetaSupplier readHadoopP(@Nonnull org.apache.hadoop.conf.Configuration configuration, @Nonnull BiFunctionEx<K,V,R> projectionFn)Returns a supplier of processors forHadoopSources.inputFormat(Configuration, BiFunctionEx)
. -
writeHadoopP
@Nonnull public static <E, K, V> ProcessorMetaSupplier writeHadoopP(@Nonnull org.apache.hadoop.conf.Configuration configuration, @Nonnull FunctionEx<? super E,K> extractKeyFn, @Nonnull FunctionEx<? super E,V> extractValueFn)Returns a supplier of processors forHadoopSinks.outputFormat(Configuration, FunctionEx, FunctionEx)
.
-