Index (Flink : Connectors : Hadoop compatibility 2.1.1-cp1 API)

A C D E F G H I J K M N O P R S T V W
All Classes All Packages

A

apply(KEYIN, GlobalWindow, Iterable<Tuple2<KEYIN, VALUEIN>>, Collector<Tuple2<KEYOUT, VALUEOUT>>) - Method in class org.apache.flink.hadoopcompatibility.mapred.HadoopReducerWrappedFunction
apply(GlobalWindow, Iterable<Tuple2<KEYIN, VALUEIN>>, Collector<Tuple2<KEYOUT, VALUEOUT>>) - Method in class org.apache.flink.hadoopcompatibility.mapred.HadoopReducerWrappedFunction

C

canEqual(Object) - Method in class org.apache.flink.api.java.typeutils.WritableTypeInfo
close() - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
close() - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase: commit the task by moving the output file out from the temporary directory.
close() - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase
close() - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase: commit the task by moving the output file out from the temporary directory.
CLOSE_MUTEX - Static variable in class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase
CLOSE_MUTEX - Static variable in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase
collect(KEY, VALUE) - Method in class org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopOutputCollector: Use the wrapped Flink collector to collect a key-value pair for Flink.
compare(T, T) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator
compareSerialized(DataInputView, DataInputView) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator
compareToReference(TypeComparator<T>) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator
configuration - Variable in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase
configure(Configuration) - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
configure(Configuration) - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase
configure(Configuration) - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase
configure(Configuration) - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase
CONFIGURE_MUTEX - Static variable in class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase
CONFIGURE_MUTEX - Static variable in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase
context - Variable in class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase
context - Variable in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase
copy(DataInputView, DataOutputView) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer
copy(T) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer
copy(T, T) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer
createComparator(boolean, ExecutionConfig) - Method in class org.apache.flink.api.java.typeutils.WritableTypeInfo
createHadoopInput(InputFormat<K, V>, Class<K>, Class<V>, JobConf) - Static method in class org.apache.flink.hadoopcompatibility.HadoopInputs: Creates a Flink InputFormat that wraps the given Hadoop InputFormat.
createHadoopInput(InputFormat<K, V>, Class<K>, Class<V>, Job) - Static method in class org.apache.flink.hadoopcompatibility.HadoopInputs: Creates a Flink InputFormat that wraps the given Hadoop InputFormat.
createInputSplits(int) - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
createInputSplits(int) - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase
createInstance() - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer
createSerializer(Class<T>) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer.WritableSerializerSnapshot
createSerializer(SerializerConfig) - Method in class org.apache.flink.api.java.typeutils.WritableTypeInfo
credentials - Variable in class org.apache.flink.api.java.hadoop.common.HadoopInputFormatCommonBase
credentials - Variable in class org.apache.flink.api.java.hadoop.common.HadoopOutputFormatCommonBase

D

deserialize(DataInputView) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer
deserialize(T, DataInputView) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer
duplicate() - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator
duplicate() - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer

E

equals(Object) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer
equals(Object) - Method in class org.apache.flink.api.java.typeutils.WritableTypeInfo
equalToReference(T) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator
extractKeys(Object, Object[], int) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator

F

fetched - Variable in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
fetched - Variable in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase
fetchNext() - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
fetchNext() - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase
finalizeGlobal(FinalizeOnMaster.FinalizationContext) - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase
finalizeGlobal(FinalizeOnMaster.FinalizationContext) - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase
flatMap(Tuple2<KEYIN, VALUEIN>, Collector<Tuple2<KEYOUT, VALUEOUT>>) - Method in class org.apache.flink.hadoopcompatibility.mapred.HadoopMapFunction

G

getArity() - Method in class org.apache.flink.api.java.typeutils.WritableTypeInfo
getConfiguration() - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase
getConfiguration() - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase
getCounter(Enum<?>) - Method in class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopDummyReporter
getCounter(String, String) - Method in class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopDummyReporter
getCredentialsFromUGI(UserGroupInformation) - Static method in class org.apache.flink.api.java.hadoop.common.HadoopInputFormatCommonBase
getCurrentKey() - Method in class org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopTupleUnwrappingIterator
getFlatComparators() - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator
getHadoopConfiguration(Configuration) - Static method in class org.apache.flink.api.java.hadoop.mapred.utils.HadoopUtils: Returns a new Hadoop Configuration object using the path to the hadoop conf configured in the main configuration (config.yaml).
getHadoopInputSplit() - Method in class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit
getHadoopInputSplit() - Method in class org.apache.flink.api.java.hadoop.mapreduce.wrapper.HadoopInputSplit
getHostnames() - Method in class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit
getHostnames() - Method in class org.apache.flink.api.java.hadoop.mapreduce.wrapper.HadoopInputSplit
getInputSplit() - Method in class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopDummyReporter
getInputSplitAssigner(HadoopInputSplit[]) - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
getInputSplitAssigner(HadoopInputSplit[]) - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase
getJobConf() - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
getJobConf() - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase
getJobConf() - Method in class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit
getLength() - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer
getNormalizeKeyLen() - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator
getProducedType() - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormat
getProducedType() - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat
getProducedType() - Method in class org.apache.flink.hadoopcompatibility.mapred.HadoopMapFunction
getProducedType() - Method in class org.apache.flink.hadoopcompatibility.mapred.HadoopReducerWrappedFunction
getProgress() - Method in class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopDummyReporter
getStatistics(BaseStatistics) - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
getStatistics(BaseStatistics) - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase
getTotalFields() - Method in class org.apache.flink.api.java.typeutils.WritableTypeInfo
getTypeClass() - Method in class org.apache.flink.api.java.typeutils.WritableTypeInfo
getTypeClass(WritableSerializer) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer.WritableSerializerSnapshot

H

HadoopDummyProgressable - Class in org.apache.flink.api.java.hadoop.mapred.wrapper: This is a dummy progress.
HadoopDummyProgressable() - Constructor for class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopDummyProgressable
HadoopDummyReporter - Class in org.apache.flink.api.java.hadoop.mapred.wrapper: This is a dummy progress monitor / reporter.
HadoopDummyReporter() - Constructor for class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopDummyReporter
HadoopInputFormat<K,V> - Class in org.apache.flink.api.java.hadoop.mapred: Wrapper for using HadoopInputFormats (mapred-variant) with Flink.
HadoopInputFormat<K,V> - Class in org.apache.flink.api.java.hadoop.mapreduce: InputFormat implementation allowing to use Hadoop (mapreduce) InputFormats with Flink.
HadoopInputFormat(InputFormat<K, V>, Class<K>, Class<V>) - Constructor for class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormat
HadoopInputFormat(InputFormat<K, V>, Class<K>, Class<V>, JobConf) - Constructor for class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormat
HadoopInputFormat(InputFormat<K, V>, Class<K>, Class<V>) - Constructor for class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat
HadoopInputFormat(InputFormat<K, V>, Class<K>, Class<V>, Job) - Constructor for class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat
HadoopInputFormatBase<K,V,T> - Class in org.apache.flink.api.java.hadoop.mapred: Common base for Java and Scala API for using Hadoop input formats with Flink.
HadoopInputFormatBase<K,V,T> - Class in org.apache.flink.api.java.hadoop.mapreduce: Base class shared between the Java and Scala API of Flink.
HadoopInputFormatBase(InputFormat<K, V>, Class<K>, Class<V>, JobConf) - Constructor for class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
HadoopInputFormatBase(InputFormat<K, V>, Class<K>, Class<V>, Job) - Constructor for class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase
HadoopInputFormatCommonBase<T,SPITTYPE extends org.apache.flink.core.io.InputSplit> - Class in org.apache.flink.api.java.hadoop.common: A common base for both "mapred" and "mapreduce" Hadoop input formats.
HadoopInputFormatCommonBase(Credentials) - Constructor for class org.apache.flink.api.java.hadoop.common.HadoopInputFormatCommonBase
HadoopInputs - Class in org.apache.flink.hadoopcompatibility: HadoopInputs is a utility class to use Apache Hadoop InputFormats with Apache Flink.
HadoopInputs() - Constructor for class org.apache.flink.hadoopcompatibility.HadoopInputs
HadoopInputSplit - Class in org.apache.flink.api.java.hadoop.mapred.wrapper: A wrapper that represents an input split from the Hadoop mapred API as a Flink InputSplit.
HadoopInputSplit - Class in org.apache.flink.api.java.hadoop.mapreduce.wrapper: A wrapper that represents an input split from the Hadoop mapreduce API as a Flink InputSplit.
HadoopInputSplit(int, InputSplit, JobConf) - Constructor for class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopInputSplit
HadoopInputSplit(int, InputSplit, JobContext) - Constructor for class org.apache.flink.api.java.hadoop.mapreduce.wrapper.HadoopInputSplit
HadoopMapFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT> - Class in org.apache.flink.hadoopcompatibility.mapred: This wrapper maps a Hadoop Mapper (mapred API) to a Flink FlatMapFunction.
HadoopMapFunction(Mapper<KEYIN, VALUEIN, KEYOUT, VALUEOUT>) - Constructor for class org.apache.flink.hadoopcompatibility.mapred.HadoopMapFunction: Maps a Hadoop Mapper (mapred API) to a Flink FlatMapFunction.
HadoopMapFunction(Mapper<KEYIN, VALUEIN, KEYOUT, VALUEOUT>, JobConf) - Constructor for class org.apache.flink.hadoopcompatibility.mapred.HadoopMapFunction: Maps a Hadoop Mapper (mapred API) to a Flink FlatMapFunction.
HadoopOutputCollector<KEY,VALUE> - Class in org.apache.flink.hadoopcompatibility.mapred.wrapper: A Hadoop OutputCollector that wraps a Flink OutputCollector.
HadoopOutputCollector() - Constructor for class org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopOutputCollector
HadoopOutputFormat<K,V> - Class in org.apache.flink.api.java.hadoop.mapred: Wrapper for using HadoopOutputFormats (mapred-variant) with Flink.
HadoopOutputFormat<K,V> - Class in org.apache.flink.api.java.hadoop.mapreduce: OutputFormat implementation allowing to use Hadoop (mapreduce) OutputFormats with Flink.
HadoopOutputFormat(OutputFormat<K, V>, Class<OutputCommitter>, JobConf) - Constructor for class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormat
HadoopOutputFormat(OutputFormat<K, V>, JobConf) - Constructor for class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormat
HadoopOutputFormat(OutputFormat<K, V>, Job) - Constructor for class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormat
HadoopOutputFormatBase<K,V,T> - Class in org.apache.flink.api.java.hadoop.mapred: Common base for the mapred HadoopOutputFormat wrappers.
HadoopOutputFormatBase<K,V,T> - Class in org.apache.flink.api.java.hadoop.mapreduce: Base class shared between the Java and Scala API of Flink.
HadoopOutputFormatBase(OutputFormat<K, V>, JobConf) - Constructor for class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase
HadoopOutputFormatBase(OutputFormat<K, V>, Job) - Constructor for class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase
HadoopOutputFormatCommonBase<T> - Class in org.apache.flink.api.java.hadoop.common: A common base for both "mapred" and "mapreduce" Hadoop output formats.
HadoopOutputFormatCommonBase(Credentials) - Constructor for class org.apache.flink.api.java.hadoop.common.HadoopOutputFormatCommonBase
HadoopReducerWrappedFunction<KEYIN,VALUEIN,KEYOUT,VALUEOUT> - Class in org.apache.flink.hadoopcompatibility.mapred: This wrapper maps a Hadoop Reducer (mapred API) to a Flink window function.
HadoopReducerWrappedFunction(Reducer<KEYIN, VALUEIN, KEYOUT, VALUEOUT>) - Constructor for class org.apache.flink.hadoopcompatibility.mapred.HadoopReducerWrappedFunction: Maps a Hadoop Reducer (mapred API) to a non-combinable Flink GroupReduceFunction.
HadoopReducerWrappedFunction(Reducer<KEYIN, VALUEIN, KEYOUT, VALUEOUT>, JobConf) - Constructor for class org.apache.flink.hadoopcompatibility.mapred.HadoopReducerWrappedFunction: Maps a Hadoop Reducer (mapred API) to a non-combinable Flink GroupReduceFunction.
HadoopTupleUnwrappingIterator<KEY,VALUE> - Class in org.apache.flink.hadoopcompatibility.mapred.wrapper: Wraps a Flink Tuple2 (key-value-pair) iterator into an iterator over the second (value) field.
HadoopTupleUnwrappingIterator(TypeSerializer<KEY>) - Constructor for class org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopTupleUnwrappingIterator
HadoopUtils - Class in org.apache.flink.api.java.hadoop.mapred.utils: Utility class to work with Apache Hadoop MapRed classes.
HadoopUtils - Class in org.apache.flink.api.java.hadoop.mapreduce.utils: Utility class to work with next generation of Apache Hadoop MapReduce classes.
HadoopUtils - Class in org.apache.flink.hadoopcompatibility: Utility class to work with Apache Hadoop libraries.
HadoopUtils() - Constructor for class org.apache.flink.hadoopcompatibility.HadoopUtils
hash(T) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator
hashCode() - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer
hashCode() - Method in class org.apache.flink.api.java.typeutils.WritableTypeInfo
hasNext - Variable in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
hasNext - Variable in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase
hasNext() - Method in class org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopTupleUnwrappingIterator

I

incrCounter(Enum<?>, long) - Method in class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopDummyReporter
incrCounter(String, String, long) - Method in class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopDummyReporter
invertNormalizedKey() - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator
isBasicType() - Method in class org.apache.flink.api.java.typeutils.WritableTypeInfo
isImmutableType() - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer
isKeyType() - Method in class org.apache.flink.api.java.typeutils.WritableTypeInfo
isNormalizedKeyPrefixOnly(int) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator
isTupleType() - Method in class org.apache.flink.api.java.typeutils.WritableTypeInfo

J

jobConf - Variable in class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase

K

key - Variable in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
keyClass - Variable in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
keyClass - Variable in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase

M

mapredOutputFormat - Variable in class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase
mapreduceOutputFormat - Variable in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase
mergeHadoopConf(Configuration) - Static method in class org.apache.flink.api.java.hadoop.mapreduce.utils.HadoopUtils: Merge HadoopConfiguration into Configuration.
mergeHadoopConf(JobConf) - Static method in class org.apache.flink.api.java.hadoop.mapred.utils.HadoopUtils: Merge HadoopConfiguration into JobConf.

N

next() - Method in class org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopTupleUnwrappingIterator
nextRecord(Tuple2<K, V>) - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormat
nextRecord(Tuple2<K, V>) - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormat

O

open(OpenContext) - Method in class org.apache.flink.hadoopcompatibility.mapred.HadoopMapFunction
open(OpenContext) - Method in class org.apache.flink.hadoopcompatibility.mapred.HadoopReducerWrappedFunction
open(OutputFormat.InitializationContext) - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase: create the temporary output file for hadoop RecordWriter.
open(OutputFormat.InitializationContext) - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase: create the temporary output file for hadoop RecordWriter.
open(HadoopInputSplit) - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
open(HadoopInputSplit) - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase
OPEN_MUTEX - Static variable in class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase
OPEN_MUTEX - Static variable in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase
org.apache.flink.api.java.hadoop.common - package org.apache.flink.api.java.hadoop.common
org.apache.flink.api.java.hadoop.mapred - package org.apache.flink.api.java.hadoop.mapred
org.apache.flink.api.java.hadoop.mapred.utils - package org.apache.flink.api.java.hadoop.mapred.utils
org.apache.flink.api.java.hadoop.mapred.wrapper - package org.apache.flink.api.java.hadoop.mapred.wrapper
org.apache.flink.api.java.hadoop.mapreduce - package org.apache.flink.api.java.hadoop.mapreduce
org.apache.flink.api.java.hadoop.mapreduce.utils - package org.apache.flink.api.java.hadoop.mapreduce.utils
org.apache.flink.api.java.hadoop.mapreduce.wrapper - package org.apache.flink.api.java.hadoop.mapreduce.wrapper
org.apache.flink.api.java.typeutils - package org.apache.flink.api.java.typeutils
org.apache.flink.api.java.typeutils.runtime - package org.apache.flink.api.java.typeutils.runtime
org.apache.flink.hadoopcompatibility - package org.apache.flink.hadoopcompatibility
org.apache.flink.hadoopcompatibility.mapred - package org.apache.flink.hadoopcompatibility.mapred
org.apache.flink.hadoopcompatibility.mapred.wrapper - package org.apache.flink.hadoopcompatibility.mapred.wrapper
outputCommitter - Variable in class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase
outputCommitter - Variable in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase

P

paramsFromGenericOptionsParser(String[]) - Static method in class org.apache.flink.hadoopcompatibility.HadoopUtils: Returns ParameterTool for the arguments parsed by GenericOptionsParser.
possibleHadoopConfPaths(Configuration) - Static method in class org.apache.flink.api.java.hadoop.mapred.utils.HadoopUtils: Get possible Hadoop conf dir paths, based on environment variables and flink configuration.
progress() - Method in class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopDummyProgressable
progress() - Method in class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopDummyReporter
putNormalizedKey(T, MemorySegment, int, int) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator

R

reachedEnd() - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
reachedEnd() - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase
read(ObjectInputStream) - Method in class org.apache.flink.api.java.hadoop.common.HadoopInputFormatCommonBase
read(ObjectInputStream) - Method in class org.apache.flink.api.java.hadoop.common.HadoopOutputFormatCommonBase
readHadoopFile(FileInputFormat<K, V>, Class<K>, Class<V>, String) - Static method in class org.apache.flink.hadoopcompatibility.HadoopInputs: Creates a Flink InputFormat that wraps the given Hadoop FileInputFormat.
readHadoopFile(FileInputFormat<K, V>, Class<K>, Class<V>, String, JobConf) - Static method in class org.apache.flink.hadoopcompatibility.HadoopInputs: Creates a Flink InputFormat that wraps the given Hadoop FileInputFormat.
readHadoopFile(FileInputFormat<K, V>, Class<K>, Class<V>, String) - Static method in class org.apache.flink.hadoopcompatibility.HadoopInputs: Creates a Flink InputFormat that wraps the given Hadoop FileInputFormat.
readHadoopFile(FileInputFormat<K, V>, Class<K>, Class<V>, String, Job) - Static method in class org.apache.flink.hadoopcompatibility.HadoopInputs: Creates a Flink InputFormat that wraps the given Hadoop FileInputFormat.
readSequenceFile(Class<K>, Class<V>, String) - Static method in class org.apache.flink.hadoopcompatibility.HadoopInputs: Creates a Flink InputFormat to read a Hadoop sequence file for the given key and value classes.
readWithKeyDenormalization(T, DataInputView) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator
recordReader - Variable in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase
recordWriter - Variable in class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormatBase
recordWriter - Variable in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase
remove() - Method in class org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopTupleUnwrappingIterator

S

serialize(T, DataOutputView) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer
serializerClass() - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer.WritableSerializerSnapshot
set(Iterator<Tuple2<KEY, VALUE>>) - Method in class org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopTupleUnwrappingIterator: Set the Flink iterator to wrap.
setFlinkCollector(Collector<Tuple2<KEY, VALUE>>) - Method in class org.apache.flink.hadoopcompatibility.mapred.wrapper.HadoopOutputCollector: Set the wrapped Flink collector.
setReference(T) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator
setStatus(String) - Method in class org.apache.flink.api.java.hadoop.mapred.wrapper.HadoopDummyReporter
snapshotConfiguration() - Method in class org.apache.flink.api.java.typeutils.runtime.WritableSerializer
supportsNormalizedKey() - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator
supportsSerializationWithKeyNormalization() - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator

T

taskNumber - Variable in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormatBase
toString() - Method in class org.apache.flink.api.java.typeutils.WritableTypeInfo

V

value - Variable in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
valueClass - Variable in class org.apache.flink.api.java.hadoop.mapred.HadoopInputFormatBase
valueClass - Variable in class org.apache.flink.api.java.hadoop.mapreduce.HadoopInputFormatBase

W

WritableComparator<T extends org.apache.hadoop.io.Writable & Comparable<T>> - Class in org.apache.flink.api.java.typeutils.runtime: A TypeComparator for Writable.
WritableComparator(boolean, Class<T>) - Constructor for class org.apache.flink.api.java.typeutils.runtime.WritableComparator
WritableSerializer<T extends org.apache.hadoop.io.Writable> - Class in org.apache.flink.api.java.typeutils.runtime: A TypeSerializer for Writable.
WritableSerializer(Class<T>) - Constructor for class org.apache.flink.api.java.typeutils.runtime.WritableSerializer
WritableSerializer.WritableSerializerSnapshot<T extends org.apache.hadoop.io.Writable> - Class in org.apache.flink.api.java.typeutils.runtime: WritableSerializer snapshot class.
WritableSerializerSnapshot() - Constructor for class org.apache.flink.api.java.typeutils.runtime.WritableSerializer.WritableSerializerSnapshot
WritableTypeInfo<T extends org.apache.hadoop.io.Writable> - Class in org.apache.flink.api.java.typeutils: Type information for data types that extend Hadoop's Writable interface.
WritableTypeInfo(Class<T>) - Constructor for class org.apache.flink.api.java.typeutils.WritableTypeInfo
write(ObjectOutputStream) - Method in class org.apache.flink.api.java.hadoop.common.HadoopInputFormatCommonBase
write(ObjectOutputStream) - Method in class org.apache.flink.api.java.hadoop.common.HadoopOutputFormatCommonBase
writeRecord(Tuple2<K, V>) - Method in class org.apache.flink.api.java.hadoop.mapred.HadoopOutputFormat
writeRecord(Tuple2<K, V>) - Method in class org.apache.flink.api.java.hadoop.mapreduce.HadoopOutputFormat
writeWithKeyNormalization(T, DataOutputView) - Method in class org.apache.flink.api.java.typeutils.runtime.WritableComparator

A C D E F G H I J K M N O P R S T V W
All Classes All Packages