Index (hazelcast-jet-hadoop-core 5.4.5 API)

C

com.hazelcast.jet.hadoop - package com.hazelcast.jet.hadoop: Apache Hadoop read/write support for Hazelcast Jet.
COPY_ON_READ - Static variable in class com.hazelcast.jet.hadoop.HadoopSources: With the new HDFS API, some of the RecordReaders return the same key/value instances for each record, for example LineRecordReader.

HadoopProcessors - Class in com.hazelcast.jet.hadoop: Static utility class with factories of Apache Hadoop Hadoop source and sink processors.
HadoopSinks - Class in com.hazelcast.jet.hadoop: Factories of Apache Hadoop sinks.
HadoopSources - Class in com.hazelcast.jet.hadoop: Contains factory methods for Apache Hadoop sources.

IGNORE_FILE_NOT_FOUND - Static variable in class com.hazelcast.jet.hadoop.HadoopSources
inputFormat(ConsumerEx<Configuration>, BiFunctionEx<K, V, E>) - Static method in class com.hazelcast.jet.hadoop.HadoopSources: 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.
inputFormat(Configuration) - Static method in class com.hazelcast.jet.hadoop.HadoopSources: Convenience for inputFormat(Configuration, BiFunctionEx) with Map.Entry as its output type.
inputFormat(Configuration, BiFunctionEx<K, V, E>) - Static method in class com.hazelcast.jet.hadoop.HadoopSources: 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.

outputFormat(Configuration) - Static method in class com.hazelcast.jet.hadoop.HadoopSinks: Convenience for HadoopSinks.outputFormat(Configuration, FunctionEx, FunctionEx) which expects Map.Entry<K, V> as input and extracts its key and value parts to be written to HDFS.
outputFormat(Configuration, FunctionEx<? super E, K>, FunctionEx<? super E, V>) - Static method in class com.hazelcast.jet.hadoop.HadoopSinks: Returns a sink that writes to Apache Hadoop HDFS.

readHadoopP(Permission, ConsumerEx<Configuration>, BiFunctionEx<K, V, R>) - Static method in class com.hazelcast.jet.hadoop.HadoopProcessors: Returns a supplier of processors for FileSources.files(String).
readHadoopP(Configuration, BiFunctionEx<K, V, R>) - Static method in class com.hazelcast.jet.hadoop.HadoopProcessors: Returns a supplier of processors for inputFormat(Configuration, BiFunctionEx).

SHARED_LOCAL_FS - Static variable in class com.hazelcast.jet.hadoop.HadoopSources: When reading files from local file system using Hadoop, each processor reads files from its own local file system.

writeHadoopP(Configuration, FunctionEx<? super E, K>, FunctionEx<? super E, V>) - Static method in class com.hazelcast.jet.hadoop.HadoopProcessors: Returns a supplier of processors for HadoopSinks.outputFormat(Configuration, FunctionEx, FunctionEx).