Index (Ignite 2.5.1-p166)

A B C D E F G H I J K L M N O P R S T U V W

A

abort() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1OutputCollector: Abort task.
abort(OutputFormat) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Task: Abort task.
acquire() - Method in class org.apache.ignite.internal.processors.hadoop.mapreduce.MapReduceClient: Increments usage count.
active() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopExecutorService
add(ClusterNode) - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanGroup: Add node to the group.
add(HadoopMultimap.Value) - Method in interface org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimap.Key
AdderBase(HadoopTaskContext) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.AdderBase
addEventListener(HadoopIgfsStreamDelegate, HadoopIgfsStreamEventListener) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsEx: Adds event listener that will be invoked when connection with server is lost or remote error has occurred.
addEventListener(HadoopIgfsStreamDelegate, HadoopIgfsStreamEventListener) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Adds event listener that will be invoked when connection with server is lost or remote error has occurred.
addEventListener(HadoopIgfsIpcIoListener) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIo: Adds event listener that will be invoked when connection with server is lost or remote error has occurred.
addEventListener(HadoopIgfsIpcIoListener) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIpcIo: Adds event listener that will be invoked when connection with server is lost or remote error has occurred.
addEventListener(HadoopIgfsStreamDelegate, HadoopIgfsStreamEventListener) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Adds event listener that will be invoked when connection with server is lost or remote error has occurred.
addGroup(CounterGroup) - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters
addGroup(String, String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters
addKey(DataInput, HadoopMultimap.Key) - Method in interface org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimap.Adder
addKey(DataInput, HadoopMultimap.Key) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.AdderBase
address() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessDescriptor: Gets host address.
address(String) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessDescriptor: Sets host address.
addShutdownHook(Runnable, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopShutdownHookManager: Adds a shutdownHook with a priority, the higher the priority the earlier will run.
affinity(IgfsPath, long, long, long) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
affinity(IgfsPath, long, long, long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
affinity(IgfsPath, long, long) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Command to get affinity for given path, offset and length.
affinity(IgfsPath, long, long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Command to get affinity for given path, offset and length.
affinity(IgfsPath, long, long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Command to get affinity for given path, offset and length.
affinity(IgfsPath, long, long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Command to get affinity for given path, offset and length.
all() - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCountersImpl
allocate(int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.AdderBase
append(IgfsPath, int, boolean, Map<String, String>) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
append(Path, int, Progressable) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
append(IgfsPath, int, boolean, Map<String, String>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
append(Path, int, Progressable) - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
append(IgfsPath, boolean, Map<String, String>) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Open file for output appending data to the end of a file.
append(IgfsPath, boolean, Map<String, String>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Open file for output appending data to the end of a file.
append(IgfsPath, boolean, Map<String, String>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Open file for output appending data to the end of a file.
append(IgfsPath, boolean, Map<String, String>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Open file for output appending data to the end of a file.
attemptId() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext: Creates Hadoop attempt ID.
available() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream
available() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyInputStream

B

BasicHadoopFileSystemFactory - Class in org.apache.ignite.hadoop.fs: Simple Hadoop file system factory which delegates to FileSystem.get() on each call.
BasicHadoopFileSystemFactory() - Constructor for class org.apache.ignite.hadoop.fs.BasicHadoopFileSystemFactory: Constructor.
BasicUserNameMapper - Class in org.apache.ignite.hadoop.util: Name mapper which maps one user name to another based on predefined dictionary.
BasicUserNameMapper() - Constructor for class org.apache.ignite.hadoop.util.BasicUserNameMapper
begin() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopOffheapBuffer
buffer() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
buffer() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutputState
buffer() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
buffer() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
bufferLength() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
bufferLength() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutputState
bytes() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopSplitWrapper
BytesWritablePartiallyRawComparator - Class in org.apache.ignite.hadoop.io: Partial raw comparator for BytesWritable data type.
BytesWritablePartiallyRawComparator() - Constructor for class org.apache.ignite.hadoop.io.BytesWritablePartiallyRawComparator

C

CachingHadoopFileSystemFactory - Class in org.apache.ignite.hadoop.fs: Caching Hadoop file system factory.
CachingHadoopFileSystemFactory() - Constructor for class org.apache.ignite.hadoop.fs.CachingHadoopFileSystemFactory: Constructor.
call() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopRunnableTask
cancel() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Task
cancel() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context: Cancels the task by stop the IO.
cancel() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Task
cancel() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext
cancel() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopRunnableTask: Cancel the executed task.
cancelDelegationToken(Token<DelegationTokenIdentifier>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
cancelTasks(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskExecutor: Cancels all currently running tasks for given job ID and cancels scheduled execution of tasks for this job ID.
cancelTasks(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopEmbeddedTaskExecutor: Cancels all currently running tasks for given job ID and cancels scheduled execution of tasks for this job ID.
cancelTasks(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskExecutorAdapter: Cancels all currently running tasks for given job ID and cancels scheduled execution of tasks for this job ID.
capacity() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopConcurrentHashMultimap
capacity() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimap
capacity() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase
capacity() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopOffheapBuffer
cast(String, IOException) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl: Cast IO exception to IGFS exception.
cast(IgniteCheckedException) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsUtils: Cast Ignite exception to appropriate IO exception.
cast(IgniteCheckedException, String) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsUtils: Cast Ignite exception to appropriate IO exception.
cfg - Variable in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopBasicFileSystemFactoryDelegate: Configuration of the secondary filesystem, never null.
ChainedUserNameMapper - Class in org.apache.ignite.hadoop.util: Chained user name mapper.
ChainedUserNameMapper() - Constructor for class org.apache.ignite.hadoop.util.ChainedUserNameMapper
checkPath(Path) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
checkPath(Path) - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
className() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopSplitWrapper
classpath() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskMetadata
classpath(Collection<String>) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskMetadata
cleanupStagingDirectory() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Job
cleanupTaskEnvironment(HadoopTaskInfo) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Job
cleanupTaskEnvironment() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext
clear(FileSystem) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsUtils: Deletes all files from the given file system.
clear(AbstractFileSystem) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsUtils: Deletes all files from the given file system.
clearFileSystemCache() - Static method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopFileSystemsUtils: Clears Hadoop FileSystem cache.
clearMapperIndex() - Static method in class org.apache.ignite.internal.processors.hadoop.HadoopMapperUtils: Clear mapper index.
client() - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol: Gets the GridClient data.
client() - Method in class org.apache.ignite.internal.processors.hadoop.mapreduce.MapReduceClient: Gets the client.
clientSubmissionEvents(HadoopJobInfo) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopPerformanceCounter: Adds client submission events from job info.
close() - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
close() - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
close(ClientProtocol) - Method in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopClientProtocolProvider
close() - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopLazyConcurrentMap: Clears the map and closes all the values.
close(boolean) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Close connection.
close(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Close connection.
close() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream
close(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Close connection.
close() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutputStream
close() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyInputStream
close() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyOutputStream
close() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsSecondaryFileSystemPositionedReadable: Close wrapped input stream in case it was previously opened.
close(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Close connection.
close() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopSerializationWrapper
close() - Static method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext: This method is called with reflection upon Job finish with class loader of each task.
close() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopWritableSerialization
close() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopConcurrentHashMultimap
close() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase.Input
close() - Method in interface org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimap
close() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.AdderBase
close() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase
close() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.ReaderBase
close() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopSkipList
close() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob
close() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob.PartitionedOutput
close() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopAbstractCommunicationClient
close() - Method in interface org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopCommunicationClient
close() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopTcpNioCommunicationClient
closed() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopAbstractCommunicationClient
closed() - Method in interface org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopCommunicationClient
closeStream(HadoopIgfsStreamDelegate) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsEx: Close server stream.
closeStream(HadoopIgfsStreamDelegate) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Close server stream.
closeStream(HadoopIgfsStreamDelegate) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Close server stream.
closeWriter() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1OutputCollector: Close writer.
closeWriter() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Task: Closes writer.
cluster() - Method in class org.apache.ignite.internal.processors.hadoop.mapreduce.MapReduceClient
collect(Object, Object) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1OutputCollector
collector(JobConf, HadoopV2TaskContext, boolean, String, TaskAttemptID) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Task
collision(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopConcurrentHashMultimap
collision(long, long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopConcurrentHashMultimap
collision(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase
collision(long, long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase
colocateFileWrites(boolean) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem: Public setter that can be used by direct users of FS or Visor.
colocateFileWrites(boolean) - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem: Public setter that can be used by direct users of FS or Visor.
commit() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1OutputCollector: Commit task.
commit(OutputFormat) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Task: Commit task.
commonClassLoader() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopHelperImpl
compare(BytesWritable, RawMemory) - Method in class org.apache.ignite.hadoop.io.BytesWritablePartiallyRawComparator: Do compare.
compare(BytesWritable, long, int) - Method in class org.apache.ignite.hadoop.io.BytesWritablePartiallyRawComparator
compare(T, RawMemory) - Method in interface org.apache.ignite.hadoop.io.PartiallyRawComparator: Do compare.
compare(Text, RawMemory) - Method in class org.apache.ignite.hadoop.io.TextPartiallyRawComparator: Do compare.
compare(Text, long, int) - Method in class org.apache.ignite.hadoop.io.TextPartiallyRawComparator
compare(T, long, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2DelegatingPartiallyOffheapRawComparator
compareBytes(byte[], int, long, int) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopUtils: Internal comparison routine.
components() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopContext: Gets list of managers.
config() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopProcessor
configuration() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopContext: Gets Hadoop configuration.
configuration() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopImpl
configuration() - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopFileSystemCacheUtils.FsCacheKey: The Configuration.
contentEquals(Counters.Counter) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Counter
contentSummary(IgfsPath) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Gets path summary.
contentSummary(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Gets path summary.
contentSummary(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Gets path summary.
contentSummary(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Gets path summary.
context() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopProcessor: Gets Hadoop context.
copyTo(long) - Method in interface org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimap.Value
cores() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopAttributes
count() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutputContext
countCounters() - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters
counter(String, String, Class<T>) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCountersImpl
counter(String, String, Class<T>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext
COUNTER_WRITER_DIR_PROPERTY - Static variable in class org.apache.ignite.hadoop.fs.IgniteHadoopFileSystemCounterWriter
counters(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopImpl
counters(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopProcessor
counters() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext
counters() - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata: Returns job counters.
counters(HadoopCounters) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata: Sets counters.
counters() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskStatus
counterWriterDelegate(ClassLoader, IgniteHadoopFileSystemCounterWriter) - Static method in class org.apache.ignite.internal.processors.hadoop.delegate.HadoopDelegateUtils: Create delegate for Hadoop counter writer.
create(IgfsPath, boolean) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
create(IgfsPath, int, boolean, int, long, Map<String, String>) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
create(Configuration) - Method in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopClientProtocolProvider
create(InetSocketAddress, Configuration) - Method in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopClientProtocolProvider
create(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopBasicFileSystemFactoryDelegate: Internal file system creation routine, invoked in correct class loader context.
create(IgfsPath, boolean) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
create(IgfsPath, int, boolean, int, long, Map<String, String>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
create(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopKerberosFileSystemFactoryDelegate: Internal file system creation routine, invoked in correct class loader context.
create(Path, FsPermission, boolean, int, short, long, Progressable) - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
create(IgfsPath, boolean, boolean, int, long, Map<String, String>) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Command to create file and open it for output.
create(String, Log, String) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Creates instance of the HadoopIgfsInProcWithIgniteRefsCount by IGFS name.
create(String, String, Log, String) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Creates instance of the HadoopIgfsInProcWithIgniteRefsCount by IGFS name, ignite client node is created if necessary.
create(IgfsPath, boolean, boolean, int, long, Map<String, String>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Command to create file and open it for output.
create(IgfsPath, boolean, boolean, int, long, Map<String, String>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Command to create file and open it for output.
create(IgfsPath, boolean, boolean, int, long, Map<String, String>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Command to create file and open it for output.
createHadoopLazyConcurrentMap() - Static method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopFileSystemCacheUtils: A common static factory method.
createInput(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopRunnableTask
createInternal(Path, EnumSet<CreateFlag>, FsPermission, int, short, long, Progressable, Options.ChecksumOpt, boolean) - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
createJobInfo(Configuration, byte[]) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopUtils: Creates JobInfo from hadoop configuration.
createNioClient(HadoopProcessDescriptor) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication
createOutput(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopRunnableTask
createShmemClient(HadoopProcessDescriptor, int) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication
createSymlink(Path, Path, boolean) - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
createTcpClient(HadoopProcessDescriptor) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Establish TCP connection to remote hadoop process and returns client.
createUGI(String, byte[]) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopUtils: Create UserGroupInformation for specified user and credentials.
createValue(K) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopLazyConcurrentMap.ValueFactory: Creates the new value.
ctx - Variable in class org.apache.ignite.internal.processors.hadoop.HadoopComponent: Hadoop context.

D

dataLength() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutputState
debug(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsJclLogger
delete(IgfsPath, boolean) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
delete(Path) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
delete(Path, boolean) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
delete(Path, boolean) - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
delete(IgfsPath, boolean) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
delete(Path, boolean) - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
delete(IgfsPath, boolean) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Command to delete given path.
delete(IgfsPath, boolean) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Command to delete given path.
delete(IgfsPath, boolean) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Command to delete given path.
delete(IgfsPath, boolean) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Command to delete given path.
dequeueAndStopAll() - Static method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopDaemon: Stops all the registered threads.
deserialize(Writable, byte[]) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopUtils: Deserialization of Hadoop Writable object.
DFLT_CONN_TIMEOUT - Static variable in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Default connection timeout (value is 1000ms).
DFLT_LOC_MAPPER_WEIGHT - Static variable in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner: Default local mapper weight.
DFLT_LOC_REDUCER_WEIGHT - Static variable in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner: Default local reducer weight.
DFLT_LOG4J_CONFIG - Static variable in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.child.HadoopExternalProcessStarter: Path to Log4j configuration file.
DFLT_MAX_CONN_TIMEOUT - Static variable in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Default Maximum connection timeout (value is 600,000ms).
DFLT_MSG_QUEUE_LIMIT - Static variable in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Default message queue limit per connection (for incoming and outgoing .
DFLT_PORT - Static variable in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Default port which node sets listener to (value is 47100).
DFLT_PORT_RANGE - Static variable in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Default local port range (value is 100).
DFLT_PREFER_LOCAL_REDUCER_THRESHOLD_WEIGHT - Static variable in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner: Default reducer migration threshold weight.
DFLT_RECONNECT_CNT - Static variable in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Default reconnect attempts count (value is 10).
DFLT_RELOGIN_INTERVAL - Static variable in class org.apache.ignite.hadoop.fs.KerberosHadoopFileSystemFactory: The default interval used to re-login from the key tab, in milliseconds.
DFLT_RMT_MAPPER_WEIGHT - Static variable in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner: Default remote mapper weight.
DFLT_RMT_REDUCER_WEIGHT - Static variable in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner: Default remote reducer weight.
DFLT_SELECTORS_CNT - Static variable in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Default count of selectors for TCP server equals to "Math.min(4, Runtime.getRuntime().availableProcessors())".
DFLT_TCP_NODELAY - Static variable in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Default value for TCP_NODELAY socket option (value is true).
disableFsCachePropertyName(String) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopFileSystemsUtils: Gets the property name to disable file system cache.
dispose(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Job

E

ensureNotSet(Configuration, String, String) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopUtils: Checks the attribute in configuration is not set.
equals(Object) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCounterAdapter
equals(Object) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCountersImpl
equals(Object) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopExternalSplit
equals(Object) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopSplitWrapper
equals(Object) - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopFileSystemCacheUtils.FsCacheKey
equals(Object) - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters
equals(Object) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsStreamDelegate
equals(Object) - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanGroup
equals(Object) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessDescriptor
error(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsJclLogger
error(String, Throwable) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsJclLogger
evts() - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopPerformanceCounter: Gets the events collection.
executionTime() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopRunnableTask
exists(IgfsPath) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
exists(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
externalExecution() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopAttributes

F

failCause(Throwable) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata
failCause() - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata
failCause() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskStatus
fileName() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsJclLogger
fileName() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Task: Gets file name for that task result.
fileSystem(URI, Configuration) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Job: Gets file system for this job.
fileSystemFactoryDelegate(ClassLoader, Object) - Static method in class org.apache.ignite.internal.processors.hadoop.delegate.HadoopDelegateUtils: Create delegate for certain file system factory.
fileSystemForMrUserWithCaching(URI, Configuration, HadoopLazyConcurrentMap<HadoopFileSystemCacheUtils.FsCacheKey, FileSystem>) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopFileSystemCacheUtils: Common method to get the V1 file system in MapRed engine.
finalize() - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
findCounter(String, String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters
findCounter(Enum<?>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters
findCounter(String, FileSystemCounter) - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters
findCounter(String, String, boolean) - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters: Find a counter in the group.
finishFuture(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopImpl
finishFuture(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopProcessor
finishFuture(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker: Gets job finish future.
flush(HadoopIgfsStreamDelegate) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsEx: Flush output stream.
flush(HadoopIgfsStreamDelegate) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Flush output stream.
flush(HadoopIgfsStreamDelegate) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Flush output stream.
flush() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutputStream
flush() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyOutputStream
flush(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffle: Flushes all the outputs for the given job to remote nodes.
flush() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob
forceClose() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIpcIo: Closes this IO instance, removing it from cache.
forceClose() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopAbstractCommunicationClient: Forces client close.
forceClose() - Method in interface org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopCommunicationClient: Forces client close.
forceClose() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopTcpNioCommunicationClient: Forces client close.
forNode(ClusterNode) - Static method in class org.apache.ignite.internal.processors.hadoop.HadoopAttributes: Get attributes for node (if any).
FRAMEWORK_NAME - Static variable in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopClientProtocolProvider: Framework name used in configuration.
FsCacheKey(URI, String, Configuration) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopFileSystemCacheUtils.FsCacheKey: Constructor
fsStatus() - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Performs status request.
fsStatus() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Performs status request.
fsStatus() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Performs status request.
fsStatus() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Performs status request.
fullUri - Variable in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopBasicFileSystemFactoryDelegate: Resulting URI.

G

get(String) - Method in class org.apache.ignite.hadoop.fs.BasicHadoopFileSystemFactory: Gets file system for the given user name.
get(String) - Method in interface org.apache.ignite.hadoop.fs.HadoopFileSystemFactory: Gets file system for the given user name.
get(int) - Method in interface org.apache.ignite.hadoop.io.RawMemory: Get byte value at the given index.
get(String) - Method in interface org.apache.ignite.internal.processors.hadoop.delegate.HadoopFileSystemFactoryDelegate: Gets file system for the given user name.
get(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopBasicFileSystemFactoryDelegate: Gets file system for the given user name.
get(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopDefaultFileSystemFactoryDelegate: Gets file system for the given user name.
get(Log, String) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIpcIo: Returns a started and valid instance of this class for a given endpoint.
get() - Static method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopShutdownHookManager: Return ShutdownHookManager singleton.
get(int) - Method in class org.apache.ignite.internal.processors.hadoop.io.OffheapRawMemory: Get byte value at the given index.
get(int) - Method in class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolTaskArguments
getActiveTrackers() - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getAllJobs() - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getBlacklistedTrackers() - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getChar(int) - Method in interface org.apache.ignite.hadoop.io.RawMemory: Get char value at the given index.
getChar(int) - Method in class org.apache.ignite.internal.processors.hadoop.io.OffheapRawMemory: Get char value at the given index.
getChildQueues(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getClusterMetrics() - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getConfigPaths() - Method in class org.apache.ignite.hadoop.fs.BasicHadoopFileSystemFactory: Gets paths to additional file system configuration files (e.g. core-site.xml).
getConnectTimeout() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication
getContentSummary(Path) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
getCounter(HadoopCounters, UUID) - Static method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopPerformanceCounter: Gets system predefined performance counter from the HadoopCounters object.
getCounter() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Counter
getCounter(Enum<?>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Reporter
getCounter(String, String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Reporter
getCounter(Enum<?>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
getCounter(String, String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
getCurrentKey() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
getCurrentValue() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
getDefaultBlockSize() - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
getDefaultReplication() - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
getDefaultUserName() - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem: Gets default user name.
getDefaultUserName() - Method in class org.apache.ignite.hadoop.util.BasicUserNameMapper: Get default user name (optional).
getDelegationToken(Text) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getDisplayName() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Counter
getDisplayName() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Counter
getDouble(int) - Method in interface org.apache.ignite.hadoop.io.RawMemory: Get double value at the given index.
getDouble(int) - Method in class org.apache.ignite.internal.processors.hadoop.io.OffheapRawMemory: Get double value at the given index.
getFileBlockLocations(FileStatus, long, long) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
getFileBlockLocations(Path, long, long) - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
getFileChecksum(Path) - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
getFileLinkStatus(Path) - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
getFileStatus(Path) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
getFileStatus(Path) - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
getFileStatus(Path) - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
getFileSystemFactory() - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem: Gets secondary file system factory.
getFilesystemName() - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getFloat(int) - Method in interface org.apache.ignite.hadoop.io.RawMemory: Get float value at the given index.
getFloat(int) - Method in class org.apache.ignite.internal.processors.hadoop.io.OffheapRawMemory: Get float value at the given index.
getFsHadoopUser() - Static method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem: Gets non-null user name as per the Hadoop file system viewpoint.
getFsStatus() - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
getGroup(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters
getGroupNames() - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters
getHomeDirectory() - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
getHomeDirectory() - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
getIdleTime() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopAbstractCommunicationClient: Gets idle time of this client.
getIdleTime() - Method in interface org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopCommunicationClient: Gets idle time of this client.
getIdleTime() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopTcpNioCommunicationClient: Gets idle time of this client.
getInitialWorkingDirectory() - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
getInputSplit() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Reporter
getInputSplit() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
getInstance() - Method in class org.apache.ignite.hadoop.util.KerberosUserNameMapper: Get Kerberos instance (optional).
getInt(int) - Method in interface org.apache.ignite.hadoop.io.RawMemory: Get int value at the given index.
getInt(int) - Method in class org.apache.ignite.internal.processors.hadoop.io.OffheapRawMemory: Get int value at the given index.
getJobCounters(JobID) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getJobHistoryDir() - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getJobStatus(JobID) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getJobTrackerStatus() - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getKeyTab() - Method in class org.apache.ignite.hadoop.fs.KerberosHadoopFileSystemFactory: Gets the key tab full file name (e.g.
getKeyTabPrincipal() - Method in class org.apache.ignite.hadoop.fs.KerberosHadoopFileSystemFactory: Gets the key tab principal short name (e.g.
getLinkTarget(Path) - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
getLocalMapperWeight() - Method in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner: Get local mapper weight.
getLocalPort() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Gets local port for socket binding.
getLocalPortRange() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication
getLocalReducerWeight() - Method in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner: Get local reducer weight.
getLogFileParams(JobID, TaskAttemptID) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getLogger(Object) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsJclLogger
getLong(int) - Method in interface org.apache.ignite.hadoop.io.RawMemory: Get long value at the given index.
getLong(int) - Method in class org.apache.ignite.internal.processors.hadoop.io.OffheapRawMemory: Get long value at the given index.
getMappers() - Method in class org.apache.ignite.hadoop.util.ChainedUserNameMapper: Get child mappers.
getMappings() - Method in class org.apache.ignite.hadoop.util.BasicUserNameMapper: Get mappings.
getMaxConnectTimeout() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Gets maximum connection timeout.
getMessageQueueLimit() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication
getModeResolver() - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
getName() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Counter
getName() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Counter
getNativeSplit(HadoopInputSplit) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext
getNewJobID() - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getOrCreate(K) - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopLazyConcurrentMap: Gets cached or creates a new value of V.
getOutboundMessagesQueueSize() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication
getOutputCommitter() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
getOutputFormat(JobContext) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Task: Create and configure an OutputFormat instance.
getPos() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream
getPos() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyInputStream
getPreferLocalReducerThresholdWeight() - Method in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner: Get reducer migration threshold weight.
getProgress() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Reporter
getProgress() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
getProtocolSignature(String, long, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getProtocolVersion(String, long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getQueue(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getQueueAclsForCurrentUser() - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getQueueAdmins(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getQueues() - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getRealm() - Method in class org.apache.ignite.hadoop.util.KerberosUserNameMapper: Get Kerberos realm (optional).
getReconnectCount() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication
getReloginInterval() - Method in class org.apache.ignite.hadoop.fs.KerberosHadoopFileSystemFactory: The interval used to re-login from the key tab, in milliseconds.
getRemoteMapperWeight() - Method in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner: Get remote mapper weight.
getRemoteReducerWeight() - Method in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner: Get remote reducer weight.
getRootQueues() - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getRunnable() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopDaemon: Getter for the runnable.
getSelectorsCount() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication
getServerDefaults() - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
getSharedMemoryPort() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Gets shared memory port to accept incoming connections.
getShort(int) - Method in interface org.apache.ignite.hadoop.io.RawMemory: Get short value at the given index.
getShort(int) - Method in class org.apache.ignite.internal.processors.hadoop.io.OffheapRawMemory: Get short value at the given index.
getSocketReceiveBuffer() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication
getSocketSendBuffer() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication
getStagingAreaDir() - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getStatus() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
getSystemDir() - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getTaskAttemptID() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
getTaskCompletionEvents(JobID, int, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getTaskContext(HadoopTaskInfo) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Job
getTaskDiagnostics(TaskAttemptID) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getTaskReports(JobID, TaskType) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getTaskTrackerExpiryInterval() - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
getUnderlyingCounter() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Counter
getUnderlyingCounter() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Counter
getUri() - Method in class org.apache.ignite.hadoop.fs.BasicHadoopFileSystemFactory: Gets file system URI.
getUri() - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
getUri() - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
getUri() - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
getUriDefaultPort() - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
getUserNameMapper() - Method in class org.apache.ignite.hadoop.fs.BasicHadoopFileSystemFactory: Get optional user name mapper.
getValue() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Counter
getValue() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Counter
getValues() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
getWithMappedName(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopBasicFileSystemFactoryDelegate: Internal file system create routine.
getWithMappedName(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopCachingFileSystemFactoryDelegate: Internal file system create routine.
getWithMappedName(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopKerberosFileSystemFactoryDelegate: Internal file system create routine.
getWorkingDirectory() - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
getWorkingDirectory() - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
getWriteAllCounters() - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters
group() - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCounterAdapter
groupByHost(Collection<ClusterNode>) - Static method in class org.apache.ignite.hadoop.planner.HadoopAbstractMapReducePlanner: Groups nodes by host names.
groupComparator() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext
groupForHost(String) - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanTopology: Get group for host.
groupForId(UUID) - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanTopology: Get group for node ID.
groupName() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProperties: Get group name.
groups() - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanTopology
groupSize(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters: Returns size of a group.

H

hadoop() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopProcessor
hadoop() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsStreamDelegate
HadoopAbstractCommunicationClient - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication: Implements basic lifecycle for communication clients.
HadoopAbstractCommunicationClient() - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopAbstractCommunicationClient
HadoopAbstractMapReducePlanner - Class in org.apache.ignite.hadoop.planner: Base class for map-reduce planners.
HadoopAbstractMapReducePlanner() - Constructor for class org.apache.ignite.hadoop.planner.HadoopAbstractMapReducePlanner
HadoopAttributes - Class in org.apache.ignite.internal.processors.hadoop: Hadoop attributes.
HadoopAttributes() - Constructor for class org.apache.ignite.internal.processors.hadoop.HadoopAttributes: Externalizable support.
HadoopAttributes(HadoopConfiguration) - Constructor for class org.apache.ignite.internal.processors.hadoop.HadoopAttributes: Constructor.
HadoopBasicFileSystemFactoryDelegate - Class in org.apache.ignite.internal.processors.hadoop.impl.delegate: Basic Hadoop file system factory delegate.
HadoopBasicFileSystemFactoryDelegate(BasicHadoopFileSystemFactory) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopBasicFileSystemFactoryDelegate: Constructor.
HadoopCachingFileSystemFactoryDelegate - Class in org.apache.ignite.internal.processors.hadoop.impl.delegate: Caching Hadoop file system factory delegate.
HadoopCachingFileSystemFactoryDelegate(CachingHadoopFileSystemFactory) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopCachingFileSystemFactoryDelegate: Constructor.
HadoopChildProcessRunner - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor.external.child: Hadoop process base.
HadoopChildProcessRunner() - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.child.HadoopChildProcessRunner
HadoopClientProtocol - Class in org.apache.ignite.internal.processors.hadoop.impl.proto: Hadoop client protocol.
HadoopClientProtocol(Configuration, MapReduceClient) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol: Constructor.
HadoopCommonUtils - Class in org.apache.ignite.internal.processors.hadoop: Common Hadoop utility methods which do not depend on Hadoop API.
HadoopCommunicationClient - Interface in org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication
HadoopComponent - Class in org.apache.ignite.internal.processors.hadoop: Abstract class for all hadoop components.
HadoopComponent() - Constructor for class org.apache.ignite.internal.processors.hadoop.HadoopComponent
HadoopConcurrentHashMultimap - Class in org.apache.ignite.internal.processors.hadoop.shuffle.collections: Multimap for map reduce intermediate results.
HadoopConcurrentHashMultimap(HadoopJobInfo, GridUnsafeMemory, int) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopConcurrentHashMultimap
HadoopContext - Class in org.apache.ignite.internal.processors.hadoop: Hadoop accelerator context.
HadoopContext(GridKernalContext, HadoopConfiguration, HadoopJobTracker, HadoopTaskExecutorAdapter, HadoopShuffle) - Constructor for class org.apache.ignite.internal.processors.hadoop.HadoopContext
hadoopContext() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Task
HadoopCounterAdapter - Class in org.apache.ignite.internal.processors.hadoop.counter: Default Hadoop counter implementation.
HadoopCounterAdapter() - Constructor for class org.apache.ignite.internal.processors.hadoop.counter.HadoopCounterAdapter: Default constructor required by Externalizable.
HadoopCounterAdapter(String, String) - Constructor for class org.apache.ignite.internal.processors.hadoop.counter.HadoopCounterAdapter: Creates new counter with given group and name.
HadoopCountersImpl - Class in org.apache.ignite.internal.processors.hadoop.counter: Default in-memory counters store.
HadoopCountersImpl() - Constructor for class org.apache.ignite.internal.processors.hadoop.counter.HadoopCountersImpl: Default constructor.
HadoopCountersImpl(Iterable<HadoopCounter>) - Constructor for class org.apache.ignite.internal.processors.hadoop.counter.HadoopCountersImpl: Creates new instance that contain given counters.
HadoopCountersImpl(HadoopCounters) - Constructor for class org.apache.ignite.internal.processors.hadoop.counter.HadoopCountersImpl: Copy constructor.
HadoopDaemon - Class in org.apache.ignite.internal.processors.hadoop.impl.v2: Replacement for Hadoop org.apache.hadoop.util.Daemon class.
HadoopDaemon() - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopDaemon: Construct a daemon thread.
HadoopDaemon(Runnable) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopDaemon: Construct a daemon thread.
HadoopDaemon(ThreadGroup, Runnable) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopDaemon: Construct a daemon thread to be part of a specified thread group.
HadoopDataInStream - Class in org.apache.ignite.internal.processors.hadoop.shuffle.streams: Data input stream.
HadoopDataInStream(GridUnsafeMemory) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
HadoopDataOutStream - Class in org.apache.ignite.internal.processors.hadoop.shuffle.streams: Data output stream.
HadoopDataOutStream(GridUnsafeMemory) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
HadoopDefaultFileSystemFactoryDelegate - Class in org.apache.ignite.internal.processors.hadoop.impl.delegate: Hadoop file system factory delegate for non-standard factories.
HadoopDefaultFileSystemFactoryDelegate(HadoopFileSystemFactory) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopDefaultFileSystemFactoryDelegate: Constructor.
HadoopDefaultMapReducePlan - Class in org.apache.ignite.internal.processors.hadoop.planner: Map-reduce plan.
HadoopDefaultMapReducePlan(Map<UUID, Collection<HadoopInputSplit>>, Map<UUID, int[]>) - Constructor for class org.apache.ignite.internal.processors.hadoop.planner.HadoopDefaultMapReducePlan
HadoopDelegateUtils - Class in org.apache.ignite.internal.processors.hadoop.delegate: Utility methods for Hadoop delegates.
HadoopDirectDataInput - Class in org.apache.ignite.internal.processors.hadoop.shuffle.direct: Hadoop data input used for direct communication.
HadoopDirectDataInput(byte[]) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput: Constructor.
HadoopDirectDataOutput - Class in org.apache.ignite.internal.processors.hadoop.shuffle.direct: Hadoop data output for direct communication.
HadoopDirectDataOutput(int) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput: Constructor.
HadoopDirectDataOutput(int, int) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput: Constructor.
HadoopDirectDataOutputContext - Class in org.apache.ignite.internal.processors.hadoop.shuffle.direct: Hadoop data output context for direct communication.
HadoopDirectDataOutputContext(int, boolean, HadoopTaskContext) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutputContext: Constructor.
HadoopDirectDataOutputState - Class in org.apache.ignite.internal.processors.hadoop.shuffle.direct: Hadoop data output state for direct communication.
HadoopDirectDataOutputState(byte[], int, int) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutputState: Constructor.
HadoopEmbeddedTaskExecutor - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor: Task executor.
HadoopEmbeddedTaskExecutor() - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopEmbeddedTaskExecutor
HadoopExecutorService - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor: Executor service without thread pooling.
HadoopExecutorService(IgniteLogger, String, int, int) - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopExecutorService
HadoopExternalCommunication - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication: Hadoop external communication class.
HadoopExternalCommunication(UUID, UUID, Marshaller, IgniteLogger, ExecutorService, String, String) - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication
HadoopExternalCommunication.ProcessHandshakeMessage - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication: Process ID message.
HadoopExternalProcessStarter - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor.external.child: Hadoop external process base class.
HadoopExternalProcessStarter(HadoopExternalProcessStarter.Args) - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.child.HadoopExternalProcessStarter
HadoopExternalSplit - Class in org.apache.ignite.internal.processors.hadoop: Split serialized in external file.
HadoopExternalSplit() - Constructor for class org.apache.ignite.internal.processors.hadoop.HadoopExternalSplit: For Externalizable.
HadoopExternalSplit(String[], long) - Constructor for class org.apache.ignite.internal.processors.hadoop.HadoopExternalSplit
HadoopExternalTaskExecutor - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor.external: External process registry.
HadoopExternalTaskExecutor() - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskExecutor
HadoopExternalTaskMetadata - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor.external: External task metadata (classpath, JVM options) needed to start external process execution.
HadoopExternalTaskMetadata() - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskMetadata
HadoopFileSystemCacheUtils - Class in org.apache.ignite.internal.processors.hadoop.impl.fs: File system cache utility methods used by Map-Reduce tasks and jobs.
HadoopFileSystemCacheUtils() - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopFileSystemCacheUtils
HadoopFileSystemCacheUtils.FsCacheKey - Class in org.apache.ignite.internal.processors.hadoop.impl.fs: Note that configuration is not a part of the key.
HadoopFileSystemCounterWriterDelegate - Interface in org.apache.ignite.internal.processors.hadoop.delegate: Counter writer delegate interface.
HadoopFileSystemCounterWriterDelegateImpl - Class in org.apache.ignite.internal.processors.hadoop.impl.delegate: Counter writer delegate implementation.
HadoopFileSystemCounterWriterDelegateImpl(IgniteHadoopFileSystemCounterWriter) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopFileSystemCounterWriterDelegateImpl: Constructor.
HadoopFileSystemFactory - Interface in org.apache.ignite.hadoop.fs: Factory for Hadoop FileSystem used by IgniteHadoopIgfsSecondaryFileSystem.
HadoopFileSystemFactoryDelegate - Interface in org.apache.ignite.internal.processors.hadoop.delegate: Hadoop file system factory delegate.
HadoopFileSystemsUtils - Class in org.apache.ignite.internal.processors.hadoop.impl.fs: Utilities for configuring file systems to support the separate working directory per each thread.
HadoopFileSystemsUtils() - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopFileSystemsUtils
HadoopHashMultimap - Class in org.apache.ignite.internal.processors.hadoop.shuffle.collections: Hash multimap.
HadoopHashMultimap(HadoopJobInfo, GridUnsafeMemory, int) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimap
HadoopHashMultimapBase - Class in org.apache.ignite.internal.processors.hadoop.shuffle.collections: Base class for hash multimaps.
HadoopHashMultimapBase(HadoopJobInfo, GridUnsafeMemory) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase
HadoopHashMultimapBase.Input - Class in org.apache.ignite.internal.processors.hadoop.shuffle.collections: Task input.
HadoopHashMultimapBase.Reader - Class in org.apache.ignite.internal.processors.hadoop.shuffle.collections: Reader for key and value.
HadoopHelperImpl - Class in org.apache.ignite.internal.processors.hadoop: Utility methods for Hadoop classloader required to avoid direct 3rd-party dependencies in class loader.
HadoopHelperImpl() - Constructor for class org.apache.ignite.internal.processors.hadoop.HadoopHelperImpl: Default constructor.
HadoopHelperImpl(GridKernalContext) - Constructor for class org.apache.ignite.internal.processors.hadoop.HadoopHelperImpl: Constructor.
HadoopIgfs - Interface in org.apache.ignite.internal.processors.hadoop.impl.igfs: Facade for communication with grid.
HadoopIgfsCommunicationException - Exception in org.apache.ignite.internal.processors.hadoop.impl.igfs: Communication exception indicating a problem between file system and IGFS instance.
HadoopIgfsCommunicationException(Exception) - Constructor for exception org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsCommunicationException: Creates new exception with given throwable as a nested cause and source of error message.
HadoopIgfsCommunicationException(String) - Constructor for exception org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsCommunicationException: Creates a new exception with given error message and optional nested cause exception.
HadoopIgfsCommunicationException(String, Exception) - Constructor for exception org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsCommunicationException: Creates a new exception with given error message and optional nested cause exception.
HadoopIgfsEndpoint - Class in org.apache.ignite.internal.processors.hadoop.igfs: IGFS endpoint abstraction.
HadoopIgfsEndpoint(String) - Constructor for class org.apache.ignite.internal.processors.hadoop.igfs.HadoopIgfsEndpoint: Constructor.
HadoopIgfsEx - Interface in org.apache.ignite.internal.processors.hadoop.impl.igfs: Extended IGFS server interface.
HadoopIgfsFuture<T> - Class in org.apache.ignite.internal.processors.hadoop.impl.igfs: IGFS client future that holds response parse closure.
HadoopIgfsFuture() - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsFuture
HadoopIgfsInProc - Class in org.apache.ignite.internal.processors.hadoop.impl.igfs: Communication with grid in the same process.
HadoopIgfsInputStream - Class in org.apache.ignite.internal.processors.hadoop.impl.igfs: IGFS input stream wrapper for hadoop interfaces.
HadoopIgfsInputStream(HadoopIgfsStreamDelegate, long, int, Log, IgfsLogger, long) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream: Creates input stream.
HadoopIgfsIo - Interface in org.apache.ignite.internal.processors.hadoop.impl.igfs: IO abstraction layer for IGFS client.
HadoopIgfsIpcIo - Class in org.apache.ignite.internal.processors.hadoop.impl.igfs: IO layer implementation based on blocking IPC streams.
HadoopIgfsIpcIo(String, IgfsMarshaller, Log) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIpcIo
HadoopIgfsIpcIoListener - Interface in org.apache.ignite.internal.processors.hadoop.impl.igfs: Listens to the events of HadoopIgfsIpcIo.
HadoopIgfsJclLogger - Class in org.apache.ignite.internal.processors.hadoop.impl.igfs: JCL logger wrapper for Hadoop.
HadoopIgfsOutProc - Class in org.apache.ignite.internal.processors.hadoop.impl.igfs: Communication with external process (TCP or shmem).
HadoopIgfsOutProc(String, int, String, Log, String) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Constructor for TCP endpoint.
HadoopIgfsOutProc(int, String, Log, String) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Constructor for shmem endpoint.
HadoopIgfsOutputStream - Class in org.apache.ignite.internal.processors.hadoop.impl.igfs: IGFS Hadoop output stream implementation.
HadoopIgfsOutputStream(HadoopIgfsStreamDelegate, Log, IgfsLogger, long) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutputStream: Creates light output stream.
HadoopIgfsProperties - Class in org.apache.ignite.internal.processors.hadoop.impl.igfs: Hadoop file system properties.
HadoopIgfsProperties(Map<String, String>) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProperties: Constructor.
HadoopIgfsProxyInputStream - Class in org.apache.ignite.internal.processors.hadoop.impl.igfs: Secondary Hadoop file system input stream wrapper.
HadoopIgfsProxyInputStream(FSDataInputStream, IgfsLogger, long) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyInputStream: Constructor.
HadoopIgfsProxyOutputStream - Class in org.apache.ignite.internal.processors.hadoop.impl.igfs: Secondary Hadoop file system output stream wrapper.
HadoopIgfsProxyOutputStream(FSDataOutputStream, IgfsLogger, long) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyOutputStream: Constructor.
HadoopIgfsSecondaryFileSystemDelegate - Interface in org.apache.ignite.internal.processors.hadoop.delegate: Interface to secondary file system implementation.
HadoopIgfsSecondaryFileSystemDelegateImpl - Class in org.apache.ignite.internal.processors.hadoop.impl.delegate: Secondary file system implementation.
HadoopIgfsSecondaryFileSystemDelegateImpl(IgniteHadoopIgfsSecondaryFileSystem) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl: Constructor.
HadoopIgfsSecondaryFileSystemPositionedReadable - Class in org.apache.ignite.internal.processors.hadoop.impl.igfs: Secondary file system input stream wrapper which actually opens input stream only in case it is explicitly requested.
HadoopIgfsSecondaryFileSystemPositionedReadable(FileSystem, Path, int) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsSecondaryFileSystemPositionedReadable: Constructor.
HadoopIgfsStreamDelegate - Class in org.apache.ignite.internal.processors.hadoop.impl.igfs: IGFS Hadoop stream descriptor.
HadoopIgfsStreamDelegate(HadoopIgfsEx, Object) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsStreamDelegate: Constructor.
HadoopIgfsStreamDelegate(HadoopIgfsEx, Object, long) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsStreamDelegate: Constructor.
HadoopIgfsStreamEventListener - Interface in org.apache.ignite.internal.processors.hadoop.impl.igfs: IGFS input stream event listener.
HadoopIgfsUtils - Class in org.apache.ignite.internal.processors.hadoop.impl.igfs: Utility constants and methods for IGFS Hadoop file system.
HadoopIgfsWrapper - Class in org.apache.ignite.internal.processors.hadoop.impl.igfs: Wrapper for IGFS server.
HadoopIgfsWrapper(String, String, Configuration, Log, String) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Constructor.
HadoopImpl - Class in org.apache.ignite.internal.processors.hadoop: Hadoop facade implementation.
HadoopIpcToNioAdapter<T> - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication: Allows to re-use existing GridNioFilters on IPC (specifically shared memory IPC) communications.
HadoopIpcToNioAdapter(IgniteLogger, IpcEndpoint, boolean, GridNioServerListener<T>, GridNioFilter...) - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopIpcToNioAdapter
HadoopJobInfoUpdateRequest - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor.external: Job info update request.
HadoopJobInfoUpdateRequest() - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopJobInfoUpdateRequest: Constructor required by Externalizable.
HadoopJobInfoUpdateRequest(HadoopJobId, HadoopJobPhase, HadoopProcessDescriptor[]) - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopJobInfoUpdateRequest
HadoopJobMetadata - Class in org.apache.ignite.internal.processors.hadoop.jobtracker: Hadoop job metadata.
HadoopJobMetadata() - Constructor for class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata: Empty constructor required by Externalizable.
HadoopJobMetadata(UUID, HadoopJobId, HadoopJobInfo) - Constructor for class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata: Constructor.
HadoopJobMetadata(HadoopJobMetadata) - Constructor for class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata: Copy constructor.
HadoopJobTracker - Class in org.apache.ignite.internal.processors.hadoop.jobtracker: Hadoop job tracker.
HadoopJobTracker() - Constructor for class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker
HadoopKerberosFileSystemFactoryDelegate - Class in org.apache.ignite.internal.processors.hadoop.impl.delegate: Kerberos Hadoop file system factory delegate.
HadoopKerberosFileSystemFactoryDelegate(KerberosHadoopFileSystemFactory) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopKerberosFileSystemFactoryDelegate: Constructor.
HadoopLazyConcurrentMap<K,V extends Closeable> - Class in org.apache.ignite.internal.processors.hadoop.impl.fs: Maps values by keys.
HadoopLazyConcurrentMap(HadoopLazyConcurrentMap.ValueFactory<K, V>) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopLazyConcurrentMap: Constructor.
HadoopLazyConcurrentMap.ValueFactory<K,V> - Interface in org.apache.ignite.internal.processors.hadoop.impl.fs: Interface representing the factory that creates map values.
HadoopLocalFileSystemV1 - Class in org.apache.ignite.internal.processors.hadoop.impl.fs: Local file system replacement for Hadoop jobs.
HadoopLocalFileSystemV1() - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopLocalFileSystemV1: Creates new local file system.
HadoopLocalFileSystemV2 - Class in org.apache.ignite.internal.processors.hadoop.impl.fs: Local file system replacement for Hadoop jobs.
HadoopLocalFileSystemV2(Configuration) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopLocalFileSystemV2: Creates new local file system.
HadoopLocalFileSystemV2(URI, Configuration) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopLocalFileSystemV2: Creates new local file system.
HadoopLongCounter - Class in org.apache.ignite.internal.processors.hadoop.counter: Standard hadoop counter to use via original Hadoop API in Hadoop jobs.
HadoopLongCounter() - Constructor for class org.apache.ignite.internal.processors.hadoop.counter.HadoopLongCounter: Default constructor required by Externalizable.
HadoopLongCounter(String, String) - Constructor for class org.apache.ignite.internal.processors.hadoop.counter.HadoopLongCounter: Constructor.
HadoopMapperUtils - Class in org.apache.ignite.internal.processors.hadoop: Set of mapper utility methods.
HadoopMapReduceCounters - Class in org.apache.ignite.internal.processors.hadoop.impl: Hadoop counters adapter.
HadoopMapReduceCounters(HadoopCounters) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters: Creates new instance based on given counters.
HadoopMapReducePlanGroup - Class in org.apache.ignite.internal.processors.hadoop.planner: Map-reduce plan group of nodes on a single physical machine.
HadoopMapReducePlanGroup(ClusterNode, String) - Constructor for class org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanGroup: Constructor.
HadoopMapReducePlanTopology - Class in org.apache.ignite.internal.processors.hadoop.planner: Map-reduce plan topology.
HadoopMapReducePlanTopology(List<HadoopMapReducePlanGroup>, Map<UUID, HadoopMapReducePlanGroup>, Map<String, HadoopMapReducePlanGroup>) - Constructor for class org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanTopology: Constructor.
HadoopMarshallerFilter - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication: Serialization filter.
HadoopMarshallerFilter(Marshaller) - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopMarshallerFilter
HadoopMessageListener - Interface in org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication: Hadoop communication message listener.
HadoopMultimap - Interface in org.apache.ignite.internal.processors.hadoop.shuffle.collections: Multimap for hadoop intermediate results.
HadoopMultimap.Adder - Interface in org.apache.ignite.internal.processors.hadoop.shuffle.collections: Adder.
HadoopMultimap.Key - Interface in org.apache.ignite.internal.processors.hadoop.shuffle.collections: Key add values to.
HadoopMultimap.Value - Interface in org.apache.ignite.internal.processors.hadoop.shuffle.collections: Value.
HadoopMultimap.Visitor - Interface in org.apache.ignite.internal.processors.hadoop.shuffle.collections: Key and values visitor.
HadoopMultimapBase - Class in org.apache.ignite.internal.processors.hadoop.shuffle.collections: Base class for all multimaps.
HadoopMultimapBase(HadoopJobInfo, GridUnsafeMemory) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase
HadoopMultimapBase.AdderBase - Class in org.apache.ignite.internal.processors.hadoop.shuffle.collections: Base class for adders.
HadoopMultimapBase.ReaderBase - Class in org.apache.ignite.internal.processors.hadoop.shuffle.collections: Reader for key and value.
HadoopMultimapBase.ValueIterator - Class in org.apache.ignite.internal.processors.hadoop.shuffle.collections: Iterator over values.
HadoopOffheapBuffer - Class in org.apache.ignite.internal.processors.hadoop.shuffle.streams: Offheap buffer.
HadoopOffheapBuffer(long, long) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopOffheapBuffer
HadoopParameters - Class in org.apache.ignite.internal.processors.hadoop.impl.fs: This class lists parameters that can be specified in Hadoop configuration.
HadoopParameters() - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopParameters
HadoopPerformanceCounter - Class in org.apache.ignite.internal.processors.hadoop.counter: Counter for the job statistics accumulation.
HadoopPerformanceCounter() - Constructor for class org.apache.ignite.internal.processors.hadoop.counter.HadoopPerformanceCounter: Default constructor required by Externalizable.
HadoopPerformanceCounter(String, String) - Constructor for class org.apache.ignite.internal.processors.hadoop.counter.HadoopPerformanceCounter: Constructor.
HadoopPerformanceCounter(UUID) - Constructor for class org.apache.ignite.internal.processors.hadoop.counter.HadoopPerformanceCounter: Constructor to create instance to use this as helper.
HadoopPrepareForJobRequest - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor.external: Child process initialization request.
HadoopPrepareForJobRequest() - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopPrepareForJobRequest: Constructor required by Externalizable.
HadoopPrepareForJobRequest(HadoopJobId, HadoopJobInfo, int, int[]) - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopPrepareForJobRequest
HadoopProcessDescriptor - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor.external: Process descriptor used to identify process for which task is running.
HadoopProcessDescriptor(UUID, UUID) - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessDescriptor
HadoopProcessor - Class in org.apache.ignite.internal.processors.hadoop: Hadoop processor.
HadoopProcessor(GridKernalContext) - Constructor for class org.apache.ignite.internal.processors.hadoop.HadoopProcessor: Constructor.
HadoopProcessStartedAck - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor.external: Process started message.
HadoopProcessStartedAck() - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessStartedAck
HadoopProtocolJobCountersTask - Class in org.apache.ignite.internal.processors.hadoop.proto: Task to get job counters.
HadoopProtocolJobCountersTask() - Constructor for class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolJobCountersTask
HadoopProtocolJobStatusTask - Class in org.apache.ignite.internal.processors.hadoop.proto: Job status task.
HadoopProtocolJobStatusTask() - Constructor for class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolJobStatusTask
HadoopProtocolKillJobTask - Class in org.apache.ignite.internal.processors.hadoop.proto: Kill job task.
HadoopProtocolKillJobTask() - Constructor for class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolKillJobTask
HadoopProtocolNextTaskIdTask - Class in org.apache.ignite.internal.processors.hadoop.proto: Task to get the next job ID.
HadoopProtocolNextTaskIdTask() - Constructor for class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolNextTaskIdTask
HadoopProtocolSubmitJobTask - Class in org.apache.ignite.internal.processors.hadoop.proto: Submit job task.
HadoopProtocolSubmitJobTask() - Constructor for class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolSubmitJobTask
HadoopProtocolTaskAdapter<R> - Class in org.apache.ignite.internal.processors.hadoop.proto: Hadoop protocol task adapter.
HadoopProtocolTaskAdapter() - Constructor for class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolTaskAdapter
HadoopProtocolTaskArguments - Class in org.apache.ignite.internal.processors.hadoop.proto: Task arguments.
HadoopProtocolTaskArguments() - Constructor for class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolTaskArguments: Externalizable support.
HadoopProtocolTaskArguments(Object...) - Constructor for class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolTaskArguments: Constructor.
HadoopRawLocalFileSystem - Class in org.apache.ignite.internal.processors.hadoop.impl.fs: Local file system implementation for Hadoop.
HadoopRawLocalFileSystem() - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
HadoopRunnableTask - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor: Runnable task.
HadoopRunnableTask(IgniteLogger, HadoopJobEx, GridUnsafeMemory, HadoopTaskInfo, UUID) - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopRunnableTask
HadoopSerializationWrapper<T> - Class in org.apache.ignite.internal.processors.hadoop.impl.v2: The wrapper around external serializer.
HadoopSerializationWrapper(Serialization<T>, Class<T>) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopSerializationWrapper
HadoopSetup - Class in org.apache.ignite.internal.processors.hadoop: Setup tool to configure Hadoop client.
HadoopSetup() - Constructor for class org.apache.ignite.internal.processors.hadoop.HadoopSetup
HadoopShuffle - Class in org.apache.ignite.internal.processors.hadoop.shuffle: Shuffle.
HadoopShuffle() - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffle
HadoopShuffleJob<T> - Class in org.apache.ignite.internal.processors.hadoop.shuffle: Shuffle job.
HadoopShuffleJob(T, IgniteLogger, HadoopJobEx, GridUnsafeMemory, int, int[], int, boolean) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob
HadoopShuffleJob.PartitionedOutput - Class in org.apache.ignite.internal.processors.hadoop.shuffle: Partitioned output.
HadoopShutdownHookManager - Class in org.apache.ignite.internal.processors.hadoop.impl.v2: Fake manager for shutdown hooks.
HadoopSkipList - Class in org.apache.ignite.internal.processors.hadoop.shuffle.collections: Skip list.
HadoopSkipList(HadoopJobInfo, GridUnsafeMemory) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopSkipList
HadoopSplitWrapper - Class in org.apache.ignite.internal.processors.hadoop: The wrapper for native hadoop input splits.
HadoopSplitWrapper() - Constructor for class org.apache.ignite.internal.processors.hadoop.HadoopSplitWrapper: Creates new split wrapper.
HadoopSplitWrapper(int, String, byte[], String[]) - Constructor for class org.apache.ignite.internal.processors.hadoop.HadoopSplitWrapper: Creates new split wrapper.
HadoopTaskCancelledException - Exception in org.apache.ignite.internal.processors.hadoop: Exception that throws when the task is cancelling.
HadoopTaskCancelledException(String) - Constructor for exception org.apache.ignite.internal.processors.hadoop.HadoopTaskCancelledException
HadoopTaskExecutionRequest - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor.external: Message sent from node to child process to start task(s) execution.
HadoopTaskExecutionRequest() - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskExecutionRequest
HadoopTaskExecutorAdapter - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor: Common superclass for task executor.
HadoopTaskExecutorAdapter() - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskExecutorAdapter
HadoopTaskFinishedMessage - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor.external: Task finished message.
HadoopTaskFinishedMessage() - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskFinishedMessage: Constructor required by Externalizable.
HadoopTaskFinishedMessage(HadoopTaskInfo, HadoopTaskStatus) - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskFinishedMessage
HadoopTaskState - Enum in org.apache.ignite.internal.processors.hadoop.taskexecutor: State of the task.
HadoopTaskStatus - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor: Task status.
HadoopTaskStatus() - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskStatus: Default constructor required by Externalizable.
HadoopTaskStatus(HadoopTaskState, Throwable) - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskStatus: Creates new instance.
HadoopTaskStatus(HadoopTaskState, Throwable, HadoopCounters) - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskStatus: Creates new instance.
HadoopTcpNioCommunicationClient - Class in org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication: Grid client for NIO server.
HadoopTcpNioCommunicationClient() - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopTcpNioCommunicationClient: Constructor for test purposes only.
HadoopTcpNioCommunicationClient(GridNioSession) - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopTcpNioCommunicationClient
HadoopTestRoundRobinMrPlanner - Class in org.apache.ignite.hadoop.planner: Round-robin mr planner.
HadoopTestRoundRobinMrPlanner() - Constructor for class org.apache.ignite.hadoop.planner.HadoopTestRoundRobinMrPlanner
HadoopUtils - Class in org.apache.ignite.internal.processors.hadoop.impl: Hadoop utility methods.
HadoopV1CleanupTask - Class in org.apache.ignite.internal.processors.hadoop.impl.v1: Hadoop cleanup task implementation for v1 API.
HadoopV1CleanupTask(HadoopTaskInfo, boolean) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1CleanupTask
HadoopV1Counter - Class in org.apache.ignite.internal.processors.hadoop.impl.v1: Hadoop counter implementation for v1 API.
HadoopV1Counter(HadoopLongCounter) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Counter: Creates new instance.
HadoopV1MapTask - Class in org.apache.ignite.internal.processors.hadoop.impl.v1: Hadoop map task implementation for v1 API.
HadoopV1MapTask(HadoopTaskInfo) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1MapTask: Constructor.
HadoopV1OutputCollector - Class in org.apache.ignite.internal.processors.hadoop.impl.v1: Hadoop output collector.
HadoopV1Partitioner - Class in org.apache.ignite.internal.processors.hadoop.impl.v1: Hadoop partitioner adapter for v1 API.
HadoopV1Partitioner(Class<? extends Partitioner>, Configuration) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Partitioner
HadoopV1ReduceTask - Class in org.apache.ignite.internal.processors.hadoop.impl.v1: Hadoop reduce task implementation for v1 API.
HadoopV1ReduceTask(HadoopTaskInfo, boolean) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1ReduceTask: Constructor.
HadoopV1Reporter - Class in org.apache.ignite.internal.processors.hadoop.impl.v1: Hadoop reporter implementation for v1 API.
HadoopV1Reporter(HadoopTaskContext, InputSplit) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Reporter: Creates new instance.
HadoopV1SetupTask - Class in org.apache.ignite.internal.processors.hadoop.impl.v1: Hadoop setup task implementation for v1 API.
HadoopV1SetupTask(HadoopTaskInfo) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1SetupTask: Constructor.
HadoopV1Splitter - Class in org.apache.ignite.internal.processors.hadoop.impl.v1: Hadoop API v1 splitter.
HadoopV1Splitter() - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Splitter
HadoopV1Task - Class in org.apache.ignite.internal.processors.hadoop.impl.v1: Extended Hadoop v1 task.
HadoopV1Task(HadoopTaskInfo) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Task: Constructor.
HadoopV2CleanupTask - Class in org.apache.ignite.internal.processors.hadoop.impl.v2: Hadoop cleanup task (commits or aborts job).
HadoopV2CleanupTask(HadoopTaskInfo, boolean) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2CleanupTask
HadoopV2Context - Class in org.apache.ignite.internal.processors.hadoop.impl.v2: Hadoop context implementation for v2 API.
HadoopV2Context(HadoopV2TaskContext) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
HadoopV2Counter - Class in org.apache.ignite.internal.processors.hadoop.impl.v2: Adapter from own counter implementation into Hadoop API Counter od version 2.0.
HadoopV2Counter(HadoopLongCounter) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Counter: Creates new instance with given delegate.
HadoopV2DelegatingPartiallyOffheapRawComparator<T> - Class in org.apache.ignite.internal.processors.hadoop.impl.v2: Delegating partial raw comparator.
HadoopV2DelegatingPartiallyOffheapRawComparator(PartiallyRawComparator<T>) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2DelegatingPartiallyOffheapRawComparator: Constructor.
HadoopV2Job - Class in org.apache.ignite.internal.processors.hadoop.impl.v2: Hadoop job implementation for v2 API.
HadoopV2Job(HadoopJobId, HadoopDefaultJobInfo, IgniteLogger, String[], HadoopHelper) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Job: Constructor.
HadoopV2MapTask - Class in org.apache.ignite.internal.processors.hadoop.impl.v2: Hadoop map task implementation for v2 API.
HadoopV2MapTask(HadoopTaskInfo) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2MapTask
HadoopV2Partitioner - Class in org.apache.ignite.internal.processors.hadoop.impl.v2: Hadoop partitioner adapter for v2 API.
HadoopV2Partitioner(Class<? extends Partitioner<?, ?>>, Configuration) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Partitioner
HadoopV2ReduceTask - Class in org.apache.ignite.internal.processors.hadoop.impl.v2: Hadoop reduce task implementation for v2 API.
HadoopV2ReduceTask(HadoopTaskInfo, boolean) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2ReduceTask: Constructor.
HadoopV2SetupTask - Class in org.apache.ignite.internal.processors.hadoop.impl.v2: Hadoop setup task (prepares job).
HadoopV2SetupTask(HadoopTaskInfo) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2SetupTask: Constructor.
HadoopV2Splitter - Class in org.apache.ignite.internal.processors.hadoop.impl.v2: Hadoop API v2 splitter.
HadoopV2Splitter() - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Splitter
HadoopV2Task - Class in org.apache.ignite.internal.processors.hadoop.impl.v2: Extended Hadoop v2 task.
HadoopV2Task(HadoopTaskInfo) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Task: Constructor.
HadoopV2TaskContext - Class in org.apache.ignite.internal.processors.hadoop.impl.v2: Context for task execution.
HadoopV2TaskContext(HadoopTaskInfo, HadoopJobEx, HadoopJobId, UUID, DataInput) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext
HadoopWritableSerialization - Class in org.apache.ignite.internal.processors.hadoop.impl.v2: Optimized serialization for Hadoop Writable types.
HadoopWritableSerialization(Class<? extends Writable>) - Constructor for class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopWritableSerialization
handshake(String) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Perform handshake.
handshake(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Perform handshake.
handshake(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Perform handshake.
handshake(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Perform handshake.
hashCode() - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCounterAdapter
hashCode() - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCountersImpl
hashCode() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopExternalSplit
hashCode() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopSplitWrapper
hashCode() - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopFileSystemCacheUtils.FsCacheKey
hashCode() - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters
hashCode() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsStreamDelegate
hashCode() - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanGroup
hashCode() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessDescriptor
hasNext() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.ValueIterator
hasShutdownHook(Runnable) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopShutdownHookManager: Indicates if a shutdownHook is registered or not.
head(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.ValueIterator
host() - Method in class org.apache.ignite.internal.processors.hadoop.igfs.HadoopIgfsEndpoint

I

id() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Job
igfs() - Method in class org.apache.ignite.internal.processors.hadoop.igfs.HadoopIgfsEndpoint
ignite - Variable in class org.apache.ignite.hadoop.planner.HadoopAbstractMapReducePlanner: Injected grid.
IgniteHadoopClientProtocolProvider - Class in org.apache.ignite.hadoop.mapreduce: Ignite Hadoop client protocol provider.
IgniteHadoopClientProtocolProvider() - Constructor for class org.apache.ignite.hadoop.mapreduce.IgniteHadoopClientProtocolProvider
IgniteHadoopFileSystem - Class in org.apache.ignite.hadoop.fs.v1: IGFS Hadoop 1.x file system driver over file system API.
IgniteHadoopFileSystem() - Constructor for class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
IgniteHadoopFileSystem - Class in org.apache.ignite.hadoop.fs.v2: IGFS Hadoop 2.x file system driver over file system API.
IgniteHadoopFileSystem(URI, Configuration) - Constructor for class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
IgniteHadoopFileSystemCounterWriter - Class in org.apache.ignite.hadoop.fs: Statistic writer implementation that writes info into any Hadoop file system.
IgniteHadoopFileSystemCounterWriter() - Constructor for class org.apache.ignite.hadoop.fs.IgniteHadoopFileSystemCounterWriter
IgniteHadoopIgfsSecondaryFileSystem - Class in org.apache.ignite.hadoop.fs: Secondary file system which delegates calls to Hadoop org.apache.hadoop.fs.FileSystem.
IgniteHadoopIgfsSecondaryFileSystem() - Constructor for class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem: Default constructor for Spring.
IgniteHadoopIgfsSecondaryFileSystem(String) - Constructor for class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem: Deprecated.
Use IgniteHadoopIgfsSecondaryFileSystem.getFileSystemFactory() instead.
IgniteHadoopIgfsSecondaryFileSystem(String, String) - Constructor for class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem: Deprecated.
Use IgniteHadoopIgfsSecondaryFileSystem.getFileSystemFactory() instead.
IgniteHadoopIgfsSecondaryFileSystem(String, String, String) - Constructor for class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem: Deprecated.
Use IgniteHadoopIgfsSecondaryFileSystem.getFileSystemFactory() instead.
IgniteHadoopWeightedMapReducePlanner - Class in org.apache.ignite.hadoop.mapreduce: Map-reduce planner which assigns mappers and reducers based on their "weights".
IgniteHadoopWeightedMapReducePlanner() - Constructor for class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner
igniteWorkDirectory() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Job
incrAllCounters(AbstractCounters<Counter, CounterGroup>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters
incrCounter(Enum<?>, long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Reporter
incrCounter(String, String, long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Reporter
increment(long) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopLongCounter: Increment this counter by the given value.
increment(long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Counter
increment(long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Counter
info(IgfsPath) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
info(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
info(IgfsPath) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Command to retrieve file info for some IGFS path.
info(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Command to retrieve file info for some IGFS path.
info(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsJclLogger
info(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Command to retrieve file info for some IGFS path.
info(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Command to retrieve file info for some IGFS path.
info() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Job
initialize(URI, Configuration) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
initialize(URI, Configuration) - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
initialize(boolean, UUID) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Job
initializeReduceAddresses(T[]) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob
input() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Job
input(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopConcurrentHashMultimap
input(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase
Input(HadoopTaskContext) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase.Input
input(HadoopTaskContext) - Method in interface org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimap
input(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopSkipList
input(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffle
input(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob
isCancelled() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Task: Returns true if task is cancelled.
isDebugEnabled() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsJclLogger
isDirectBuffer() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication
isInfoEnabled() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsJclLogger
isInside(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopOffheapBuffer
isLocal() - Method in class org.apache.ignite.internal.processors.hadoop.igfs.HadoopIgfsEndpoint
isNoOp() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopHelperImpl
isParticipating(HadoopJobMetadata) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopContext
isQuiet() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsJclLogger
isShutdown() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopExecutorService
isShutdownInProgress() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopShutdownHookManager: Indicates if shutdown is in progress or not.
isTcpNoDelay() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication
isTraceEnabled() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsJclLogger
isUseDefaultUserName() - Method in class org.apache.ignite.hadoop.util.BasicUserNameMapper: Get whether to use default user name when there is no mapping for current user name.
iterateGroup(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters: Returns counters iterator for specified group.
iterator() - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters

J

job(HadoopJobId, HadoopJobInfo) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker: Gets or creates job instance.
JOB_CLS_NAME - Static variable in class org.apache.ignite.internal.processors.hadoop.HadoopCommonUtils: Job class name.
JOB_COUNTER_WRITER_PROPERTY - Static variable in class org.apache.ignite.internal.processors.hadoop.HadoopCommonUtils: Property to set custom writer of job statistics.
JOB_SUBMISSION_START_TS_PROPERTY - Static variable in class org.apache.ignite.internal.processors.hadoop.HadoopCommonUtils: Property to store timestamp of job submission.
jobConf() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Job: Getter for job configuration.
jobConf() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext: Gets job configuration of the task.
jobContext() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext: Gets job context of the task.
jobCounters(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker: Returns job counters.
jobFile(Configuration, String, JobID) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopUtils: Gets job file.
jobFinished(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffle
jobId() - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata
jobId() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopJobInfoUpdateRequest
jobId() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopPrepareForJobRequest
jobId() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskExecutionRequest
jobId(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskExecutionRequest
jobInfo - Variable in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Job: Job info.
jobInfo() - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata
jobInfo() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopPrepareForJobRequest
jobInfo() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskExecutionRequest
jobInfo(HadoopJobInfo) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskExecutionRequest
jobLocalDir(String, UUID, HadoopJobId) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopUtils: Returns work directory for job execution.
jobPhase() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopJobInfoUpdateRequest
jobTracker() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopContext
jobUpdateLeader() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopContext
jvmOptions() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskMetadata
jvmOptions(Collection<String>) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskMetadata

K

KerberosHadoopFileSystemFactory - Class in org.apache.ignite.hadoop.fs: Secure Hadoop file system factory that can work with underlying file system protected with Kerberos.
KerberosHadoopFileSystemFactory() - Constructor for class org.apache.ignite.hadoop.fs.KerberosHadoopFileSystemFactory: Constructor.
KerberosUserNameMapper - Class in org.apache.ignite.hadoop.util: Kerberos user name mapper.
KerberosUserNameMapper() - Constructor for class org.apache.ignite.hadoop.util.KerberosUserNameMapper
kernalContext() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopContext: Gets kernal context.
key() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase.Input
key(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase
keyHash(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase
keys() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopConcurrentHashMultimap
keys() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimap
keySer - Variable in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.AdderBase
keySerialization() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext
keySize(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase
kill(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopImpl
kill(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopProcessor
killJob(JobID) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
killJob(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker: Kills job.
killTask(TaskAttemptID, boolean) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol

L

length() - Method in interface org.apache.ignite.hadoop.io.RawMemory: Get length.
length() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsStreamDelegate
length() - Method in class org.apache.ignite.internal.processors.hadoop.io.OffheapRawMemory: Get length.
limits() - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters
listFiles(IgfsPath) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
listFiles(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
listFiles(IgfsPath) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Command to get list of files in directory.
listFiles(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Command to get list of files in directory.
listFiles(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Command to get list of files in directory.
listFiles(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Command to get list of files in directory.
listPaths(IgfsPath) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
listPaths(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
listPaths(IgfsPath) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Command to get directory listing.
listPaths(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Command to get directory listing.
listPaths(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Command to get directory listing.
listPaths(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Command to get directory listing.
listStatus(Path) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
listStatus(Path) - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
listStatus(Path) - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
loadClassBytes(ClassLoader, String) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopHelperImpl
loadReplace(InputStream, String, String) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopHelperImpl
LOC_FS_WORK_DIR_PROP - Static variable in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopFileSystemsUtils: Name of the property for setting working directory on create new local FS instance.
localDeallocate(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.AdderBase: Rewinds local allocation pointer to the given pointer if possible.
LOCALHOST - Static variable in class org.apache.ignite.internal.processors.hadoop.igfs.HadoopIgfsEndpoint: Localhost.
localNodeId() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopContext: Gets local node ID.
localNodeOrder() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopContext: Gets local node order.
localProcessDescriptor() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Gets local process descriptor.
localReducers() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopPrepareForJobRequest
log - Variable in class org.apache.ignite.hadoop.planner.HadoopAbstractMapReducePlanner: Logger.
log - Variable in class org.apache.ignite.internal.processors.hadoop.HadoopComponent: Logger.

M

macs() - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanGroup
main(String[]) - Static method in class org.apache.ignite.internal.processors.hadoop.HadoopSetup: The main method.
main(String[]) - Static method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.child.HadoopExternalProcessStarter
makeEscapedCompactString() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Counter
map(String) - Method in class org.apache.ignite.hadoop.util.BasicUserNameMapper: Map user name.
map(String) - Method in class org.apache.ignite.hadoop.util.ChainedUserNameMapper: Map user name.
map(String) - Method in class org.apache.ignite.hadoop.util.KerberosUserNameMapper: Map user name.
map(String) - Method in interface org.apache.ignite.hadoop.util.UserNameMapper: Map user name.
map(List<ClusterNode>, HadoopProtocolTaskArguments) - Method in class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolTaskAdapter
mapperIndex() - Static method in class org.apache.ignite.internal.processors.hadoop.HadoopMapperUtils
mapperIndex(Integer) - Static method in class org.apache.ignite.internal.processors.hadoop.HadoopMapperUtils
mapperNodeIds() - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopDefaultMapReducePlan
mappers() - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopDefaultMapReducePlan
mappers(UUID) - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopDefaultMapReducePlan
MapReduceClient - Class in org.apache.ignite.internal.processors.hadoop.mapreduce: Client.
MapReduceClient(String, Collection<String>) - Constructor for class org.apache.ignite.internal.processors.hadoop.mapreduce.MapReduceClient: Constructor.
mapReducePlan(HadoopMapReducePlan) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata
mapReducePlan() - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata
mark(int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream
mark(int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyInputStream
markSupported() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream
markSupported() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyInputStream
markUsed() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopAbstractCommunicationClient: Updates used time.
maxParallelTasks() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopAttributes
maxTaskQueueSize() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopAttributes
mem - Variable in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase
mem - Variable in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffle
mem - Variable in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.child.HadoopChildProcessRunner
memory() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffle
merge(HadoopCounters) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCountersImpl
merge(HadoopCounter) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopLongCounter
merge(HadoopCounter) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopPerformanceCounter
meta(int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopConcurrentHashMultimap
meta(int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimap
meta(int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase
mkdir(Path, FsPermission, boolean) - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
mkdirs(IgfsPath) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
mkdirs(IgfsPath, Map<String, String>) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
mkdirs(Path, FsPermission) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
mkdirs(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
mkdirs(IgfsPath, Map<String, String>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
mkdirs(Path, FsPermission) - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
mkdirs(IgfsPath, Map<String, String>) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Command to create directories.
mkdirs(IgfsPath, Map<String, String>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Command to create directories.
mkdirs(IgfsPath, Map<String, String>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Command to create directories.
mkdirs(IgfsPath, Map<String, String>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Command to create directories.
modeResolver() - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsEx
modeResolver() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc
modeResolver() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc
modeResolver() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper
move(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
move(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
move(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopOffheapBuffer
moveBackward(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopOffheapBuffer

N

name() - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCounterAdapter
NAME - Static variable in class org.apache.ignite.internal.processors.hadoop.HadoopAttributes: Attribute name.
nativeLibraryNames() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopAttributes
next() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase.Input
next() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.ValueIterator
nextJobId() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopImpl
nextJobId() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopProcessor
nextKey() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
nextKeyValue() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
nextValue(long, long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase
nextValue(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase
nodeCount() - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanGroup
nodeForReducer(int) - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopDefaultMapReducePlan
nodeId(int) - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanGroup: Get node ID by index.
nodes() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopContext
normalize(URI) - Static method in class org.apache.ignite.internal.processors.hadoop.igfs.HadoopIgfsEndpoint: Normalize IGFS URI.
notifyListener(HadoopProcessDescriptor, HadoopMessage) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication

O

OffheapRawMemory - Class in org.apache.ignite.internal.processors.hadoop.io: Offheap-based memory.
OffheapRawMemory(long, int) - Constructor for class org.apache.ignite.internal.processors.hadoop.io.OffheapRawMemory: Constructor.
offset() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopExternalSplit
onClose() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream: Callback invoked when the stream is being closed.
onClose() - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIpcIoListener: Callback invoked when the IO is being closed.
onClose() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Callback invoked when the IO is being closed.
onClose() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutputStream: Callback invoked when the stream is being closed.
onClose() - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsStreamEventListener: Callback invoked when the stream is being closed.
onConnectionLost(HadoopProcessDescriptor) - Method in interface org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopMessageListener: Called when connection to remote process was lost.
onDirectShuffleMessage(T, HadoopDirectShuffleMessage) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob: Process shuffle message.
onError(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream: Callback invoked when remote error occurs.
onError(long, String) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIpcIoListener: Callback invoked when remote error occurs.
onError(long, String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Callback invoked when remote error occurs.
onError(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutputStream: Callback invoked when remote error occurs.
onError(String) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsStreamEventListener: Callback invoked when remote error occurs.
onExceptionCaught(GridNioSession, IgniteCheckedException) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopMarshallerFilter
onExternalMappersInitialized(HadoopJobId, Collection<Integer>, HadoopProcessDescriptor) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker: Callback from task executor called when process is ready to received shuffle messages.
onJobPrepare(long) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopPerformanceCounter: Adds event of the job preparation.
onJobStart(long) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopPerformanceCounter: Adds event of the job start.
onJobStateChanged(HadoopJobMetadata) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskExecutor: On job state change callback;
onJobStateChanged(HadoopJobMetadata) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopEmbeddedTaskExecutor: On job state change callback;
onJobStateChanged(HadoopJobMetadata) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskExecutorAdapter: On job state change callback;
onKernalStart() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopComponent: Callback invoked when all grid components are started.
onKernalStart(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopProcessor
onKernalStart() - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker: Callback invoked when all grid components are started.
onKernalStart() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopEmbeddedTaskExecutor: Callback invoked when all grid components are started.
onKernalStop(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopComponent: Callback invoked before all grid components are stopped.
onKernalStop(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopProcessor
onKernalStop(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker: Callback invoked before all grid components are stopped.
onKernalStop(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopEmbeddedTaskExecutor: Callback invoked before all grid components are stopped.
onKey(long, int) - Method in interface org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimap.Visitor
onMapperFinished() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob.PartitionedOutput
onMessageReceived(UUID, HadoopMessage) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffle: Message received callback.
onMessageReceived(GridNioSession, Object) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopMarshallerFilter
onMessageReceived(HadoopProcessDescriptor, HadoopMessage) - Method in interface org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopMessageListener
onSessionClose(GridNioSession) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopMarshallerFilter
onSessionClosed(GridNioSession) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopMarshallerFilter
onSessionIdleTimeout(GridNioSession) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopMarshallerFilter
onSessionOpened(GridNioSession) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopMarshallerFilter
onSessionWrite(GridNioSession, Object, boolean, IgniteInClosure<IgniteException>) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopMarshallerFilter
onSessionWriteTimeout(GridNioSession) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopMarshallerFilter
onShuffleAck(HadoopShuffleAck) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob
onShuffleFinishRequest(T, HadoopShuffleFinishRequest) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob: Process shuffle finish request.
onShuffleFinishResponse(T) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob: Process shuffle finish response.
onShuffleMessage(int, long) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopPerformanceCounter: Registers shuffle message event.
onShuffleMessage(T, HadoopShuffleMessage) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob
onTaskFinish(HadoopTaskInfo, long) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopPerformanceCounter: Adds event of the task finish.
onTaskFinished(HadoopTaskInfo, HadoopTaskStatus) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker: Callback from task executor invoked when a task has been finished.
onTaskFinished(HadoopTaskStatus) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopRunnableTask
onTaskPrepare(HadoopTaskInfo, long) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopPerformanceCounter: Adds event of the task preparation.
onTaskStart(HadoopTaskInfo, long) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopPerformanceCounter: Adds event of the task run.
onTaskSubmit(HadoopTaskInfo, long) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopPerformanceCounter: Adds event of the task submission (task instance creation).
onValue(long, int) - Method in interface org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimap.Visitor
open(IgfsPath, int) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
open(Path, int) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
open(Path, int) - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
open(IgfsPath, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
open(Path, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
open(IgfsPath) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Command to open file for reading.
open(IgfsPath, int) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Command to open file for reading.
open(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Command to open file for reading.
open(IgfsPath, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Command to open file for reading.
open(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Command to open file for reading.
open(IgfsPath, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Command to open file for reading.
open(IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Command to open file for reading.
open(IgfsPath, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Command to open file for reading.
org.apache.ignite.hadoop.fs - package org.apache.ignite.hadoop.fs: Ignite Hadoop Accelerator file system API.
org.apache.ignite.hadoop.fs.v1 - package org.apache.ignite.hadoop.fs.v1: Contains Ignite Hadoop 1.x FileSystem implementation.
org.apache.ignite.hadoop.fs.v2 - package org.apache.ignite.hadoop.fs.v2: Contains Ignite Hadoop 2.x FileSystem implementation.
org.apache.ignite.hadoop.io - package org.apache.ignite.hadoop.io: Contains Hadoop Accelerator API for input-output operations.
org.apache.ignite.hadoop.mapreduce - package org.apache.ignite.hadoop.mapreduce: Ignite Hadoop Accelerator map-reduce classes.
org.apache.ignite.hadoop.planner - package org.apache.ignite.hadoop.planner: Ignite Hadoop Accelerator planner classes.
org.apache.ignite.hadoop.util - package org.apache.ignite.hadoop.util: Ignite Hadoop Accelerator utility classes.
org.apache.ignite.internal.processors.hadoop - package org.apache.ignite.internal.processors.hadoop
org.apache.ignite.internal.processors.hadoop.counter - package org.apache.ignite.internal.processors.hadoop.counter
org.apache.ignite.internal.processors.hadoop.delegate - package org.apache.ignite.internal.processors.hadoop.delegate
org.apache.ignite.internal.processors.hadoop.igfs - package org.apache.ignite.internal.processors.hadoop.igfs
org.apache.ignite.internal.processors.hadoop.impl - package org.apache.ignite.internal.processors.hadoop.impl
org.apache.ignite.internal.processors.hadoop.impl.delegate - package org.apache.ignite.internal.processors.hadoop.impl.delegate
org.apache.ignite.internal.processors.hadoop.impl.fs - package org.apache.ignite.internal.processors.hadoop.impl.fs
org.apache.ignite.internal.processors.hadoop.impl.igfs - package org.apache.ignite.internal.processors.hadoop.impl.igfs
org.apache.ignite.internal.processors.hadoop.impl.proto - package org.apache.ignite.internal.processors.hadoop.impl.proto
org.apache.ignite.internal.processors.hadoop.impl.v1 - package org.apache.ignite.internal.processors.hadoop.impl.v1
org.apache.ignite.internal.processors.hadoop.impl.v2 - package org.apache.ignite.internal.processors.hadoop.impl.v2
org.apache.ignite.internal.processors.hadoop.io - package org.apache.ignite.internal.processors.hadoop.io
org.apache.ignite.internal.processors.hadoop.jobtracker - package org.apache.ignite.internal.processors.hadoop.jobtracker
org.apache.ignite.internal.processors.hadoop.mapreduce - package org.apache.ignite.internal.processors.hadoop.mapreduce
org.apache.ignite.internal.processors.hadoop.planner - package org.apache.ignite.internal.processors.hadoop.planner
org.apache.ignite.internal.processors.hadoop.proto - package org.apache.ignite.internal.processors.hadoop.proto
org.apache.ignite.internal.processors.hadoop.shuffle - package org.apache.ignite.internal.processors.hadoop.shuffle
org.apache.ignite.internal.processors.hadoop.shuffle.collections - package org.apache.ignite.internal.processors.hadoop.shuffle.collections
org.apache.ignite.internal.processors.hadoop.shuffle.direct - package org.apache.ignite.internal.processors.hadoop.shuffle.direct
org.apache.ignite.internal.processors.hadoop.shuffle.streams - package org.apache.ignite.internal.processors.hadoop.shuffle.streams
org.apache.ignite.internal.processors.hadoop.taskexecutor - package org.apache.ignite.internal.processors.hadoop.taskexecutor
org.apache.ignite.internal.processors.hadoop.taskexecutor.external - package org.apache.ignite.internal.processors.hadoop.taskexecutor.external
org.apache.ignite.internal.processors.hadoop.taskexecutor.external.child - package org.apache.ignite.internal.processors.hadoop.taskexecutor.external.child
org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication - package org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication
OUT_OF_RESOURCES_TCP_MSG - Static variable in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: IPC error message.
output(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffle
output(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob
outputBuffer() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsFuture
outputBuffer(byte[]) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsFuture
outputLength() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsFuture
outputLength(int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsFuture
outputOffset() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsFuture
outputOffset(int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsFuture

P

pageSize - Variable in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase
PARAM_IGFS_COLOCATED_WRITES - Static variable in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopParameters: Parameter name for control over file colocation write mode.
PARAM_IGFS_ENDPOINT_IGNITE_CFG_PATH - Static variable in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsUtils: Parameter name for endpoint path to Ignite client configuration.
PARAM_IGFS_ENDPOINT_NO_EMBED - Static variable in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsUtils: Parameter name for endpoint no embed mode flag.
PARAM_IGFS_ENDPOINT_NO_LOCAL_SHMEM - Static variable in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsUtils: Parameter name for endpoint no shared memory flag.
PARAM_IGFS_ENDPOINT_NO_LOCAL_TCP - Static variable in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsUtils: Parameter name for endpoint no local TCP flag.
PARAM_IGFS_ENDPOINT_NO_REMOTE_TCP - Static variable in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsUtils: Parameter name for endpoint no remote TCP flag.
PARAM_IGFS_LOG_BATCH_SIZE - Static variable in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopParameters: Parameter name for log batch size.
PARAM_IGFS_LOG_DIR - Static variable in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopParameters: Parameter name for client logger directory.
PARAM_IGFS_LOG_ENABLED - Static variable in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopParameters: Parameter name for log enabled flag.
PARAM_IGFS_PREFER_LOCAL_WRITES - Static variable in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopParameters: Parameter name for prefer local writes flag.
PARAM_IGFS_SEQ_READS_BEFORE_PREFETCH - Static variable in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopParameters: Parameter name for custom sequential reads before prefetch value.
parameter(Configuration, String, String, String) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsUtils: Get string parameter.
parameter(Configuration, String, String, int) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsUtils: Get integer parameter.
parameter(Configuration, String, String, boolean) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsUtils: Get boolean parameter.
parentNodeId() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessDescriptor: Gets parent node ID.
PartiallyRawComparator<T> - Interface in org.apache.ignite.hadoop.io: Partially raw comparator.
partialRawSortComparator() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext
partition(Object, Object, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Partitioner
partition(Object, Object, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Partitioner
partitioner() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext
pathToFile(Path) - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopLocalFileSystemV1
pendingReducers(Collection<Integer>) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata: Sets collection of pending reducers.
pendingReducers() - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata: Gets collection of pending reducers.
pendingSplits(Map<HadoopInputSplit, Integer>) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata: Sets collection of pending splits.
pendingSplits() - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata: Gets collection of pending splits.
PERFORMANCE_COUNTER_FILE_NAME - Static variable in class org.apache.ignite.hadoop.fs.IgniteHadoopFileSystemCounterWriter
permission() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProperties: Get permission.
phase(HadoopJobPhase) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata
phase() - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata
plan(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker: Gets job plan by job ID.
planner() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopContext
plannerClassName() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopAttributes
pointer() - Method in class org.apache.ignite.internal.processors.hadoop.io.OffheapRawMemory
pointer() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopOffheapBuffer
pointer(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopOffheapBuffer
port() - Method in class org.apache.ignite.internal.processors.hadoop.igfs.HadoopIgfsEndpoint
position() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
preparePlan(HadoopJob, Collection<ClusterNode>, HadoopMapReducePlan) - Method in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner
preparePlan(HadoopJob, Collection<ClusterNode>, HadoopMapReducePlan) - Method in class org.apache.ignite.hadoop.planner.HadoopTestRoundRobinMrPlanner
prepareTaskEnvironment(HadoopTaskInfo) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Job
prepareTaskEnvironment() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext
prepareWriter(JobContext) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Task: Put write into Hadoop context and return associated output format instance.
processDescriptor() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication.ProcessHandshakeMessage
ProcessHandshakeMessage() - Constructor for class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication.ProcessHandshakeMessage
processId() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessDescriptor: Gets process ID.
progress() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Reporter
progress() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
proxy - Variable in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopBasicFileSystemFactoryDelegate: Proxy.

R

randomLevel(Random) - Static method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopSkipList
RawMemory - Interface in org.apache.ignite.hadoop.io: Memory abstraction for raw comparison.
read(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsFuture
read() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsFuture
read() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream
read(byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream
read(long, byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream
read(byte[]) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyInputStream
read(byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyInputStream
read() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyInputStream
read(long, byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyInputStream
read(long, byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsSecondaryFileSystemPositionedReadable
read(DataInput, Object) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopSerializationWrapper
read(DataInput, Object) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopWritableSerialization
read(long, long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.ReaderBase
read() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput
read() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
read(byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
readBoolean() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput
readBoolean() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
readByte() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput
readByte() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
readChar() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput
readChar() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
readData(HadoopIgfsStreamDelegate, long, int, byte[], int, int) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsEx: Asynchronously reads specified amount of bytes from opened input stream.
readData(HadoopIgfsStreamDelegate, long, int, byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Asynchronously reads specified amount of bytes from opened input stream.
readData(HadoopIgfsStreamDelegate, long, int, byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Asynchronously reads specified amount of bytes from opened input stream.
readDouble() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput
readDouble() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
reader(RecordReader) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context: Overrides default input data reader.
Reader(HadoopSerialization) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase.Reader
ReaderBase(HadoopSerialization) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.ReaderBase
readExternal(ObjectInput) - Method in class org.apache.ignite.hadoop.fs.BasicHadoopFileSystemFactory
readExternal(ObjectInput) - Method in class org.apache.ignite.hadoop.fs.KerberosHadoopFileSystemFactory
readExternal(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCounterAdapter
readExternal(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCountersImpl
readExternal(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopAttributes
readExternal(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopExternalSplit
readExternal(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopSplitWrapper
readExternal(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata
readExternal(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolTaskArguments
readExternal(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication.ProcessHandshakeMessage
readExternal(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopJobInfoUpdateRequest
readExternal(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopPrepareForJobRequest
readExternal(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessStartedAck
readExternal(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskExecutionRequest
readExternal(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskFinishedMessage
readExternal(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskStatus
readFields(DataInput) - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters
readFields(DataInput) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Counter
readFields(DataInput) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Counter
readFileBlock(String, FSDataInputStream, String[]) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Splitter
readFileBlock(String, DataInput, String[]) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Splitter
readFloat() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput
readFloat() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
readFully(long, byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream
readFully(long, byte[]) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream
readFully(long, byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyInputStream
readFully(long, byte[]) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyInputStream
readFully(byte[]) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput
readFully(byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput
readFully(byte[]) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
readFully(byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
readInt() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput
readInt() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
readKey(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase.Reader
readLine() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput
readLine() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
readLong() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput
readLong() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
readShort() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput
readShort() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
readUnsignedByte() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput
readUnsignedByte() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
readUnsignedShort() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput
readUnsignedShort() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
readUTF() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput
readUTF() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
readValue(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCounterAdapter: Read value of this counter from input.
readValue(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopLongCounter: Read value of this counter from input.
readValue(ObjectInput) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopPerformanceCounter: Read value of this counter from input.
readValue(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.ReaderBase
readyForFlush() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
reduce(List<ComputeJobResult>) - Method in class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolTaskAdapter
reducerNodeIds() - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopDefaultMapReducePlan
reducers() - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopDefaultMapReducePlan
reducers(UUID) - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopDefaultMapReducePlan
reducersAddresses() - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata: Gets reducers addresses for external execution.
reducersAddresses(Map<Integer, HadoopProcessDescriptor>) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata: Sets reducers addresses for external execution.
reducersAddresses() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopJobInfoUpdateRequest
reducersInitialized() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob
release() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIpcIo: Releases this instance, decrementing usage count.
release() - Method in class org.apache.ignite.internal.processors.hadoop.mapreduce.MapReduceClient: Decrements the usages of the client and closes it if this is the last usage.
release() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopAbstractCommunicationClient: Releases this client by decreasing reservations.
release() - Method in interface org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopCommunicationClient: Releases this client by decreasing reservations.
remaining() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopOffheapBuffer
remove() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.ValueIterator
removeEventListener(HadoopIgfsStreamDelegate) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsEx: Removes event listener that will be invoked when connection with server is lost or remote error has occurred.
removeEventListener(HadoopIgfsStreamDelegate) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Removes event listener that will be invoked when connection with server is lost or remote error has occurred.
removeEventListener(HadoopIgfsIpcIoListener) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIo: Removes event listener that will be invoked when connection with server is lost or remote error has occurred.
removeEventListener(HadoopIgfsIpcIoListener) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIpcIo: Removes event listener that will be invoked when connection with server is lost or remote error has occurred.
removeEventListener(HadoopIgfsStreamDelegate) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Removes event listener that will be invoked when connection with server is lost or remote error has occurred.
removeShutdownHook(Runnable) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopShutdownHookManager: Removes a shutdownHook.
rename(IgfsPath, IgfsPath) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
rename(Path, Path) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
rename(IgfsPath, IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
rename(Path, Path) - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
rename(IgfsPath, IgfsPath) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Command to rename given path.
rename(IgfsPath, IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Command to rename given path.
rename(IgfsPath, IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Command to rename given path.
rename(IgfsPath, IgfsPath) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Command to rename given path.
renameInternal(Path, Path) - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
renewDelegationToken(Token<DelegationTokenIdentifier>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
REQ_NEW_JOBID_TS_PROPERTY - Static variable in class org.apache.ignite.internal.processors.hadoop.HadoopCommonUtils: Property to store timestamp of new job id request.
reserve() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopAbstractCommunicationClient
reserve() - Method in interface org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopCommunicationClient
reserved() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopAbstractCommunicationClient
reserved() - Method in interface org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopCommunicationClient
reset() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream
reset() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyInputStream
reset() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput: Reset the stream.
reset() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutputContext: Reset buffer.
reset() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopOffheapBuffer: Resets position to the beginning of buffer.
resetReusedObject(Object) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.ReaderBase: Resets temporary object to the given one.
RESPONSE_NEW_JOBID_TS_PROPERTY - Static variable in class org.apache.ignite.internal.processors.hadoop.HadoopCommonUtils: Property to store timestamp of response of new job id request.
restoreContextClassLoader(ClassLoader) - Static method in class org.apache.ignite.internal.processors.hadoop.HadoopCommonUtils: Restore context class loader.
result(ComputeJobResult, List<ComputeJobResult>) - Method in class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolTaskAdapter
run(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1CleanupTask
run(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1MapTask
run(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1ReduceTask
run(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1SetupTask
run(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Task
run() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext
run(ComputeJobContext, Hadoop, HadoopProtocolTaskArguments) - Method in class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolJobCountersTask: Run the task.
run(ComputeJobContext, Hadoop, HadoopProtocolTaskArguments) - Method in class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolJobStatusTask: Run the task.
run(ComputeJobContext, Hadoop, HadoopProtocolTaskArguments) - Method in class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolKillJobTask: Run the task.
run(ComputeJobContext, Hadoop, HadoopProtocolTaskArguments) - Method in class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolNextTaskIdTask: Run the task.
run(ComputeJobContext, Hadoop, HadoopProtocolTaskArguments) - Method in class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolSubmitJobTask: Run the task.
run(ComputeJobContext, Hadoop, HadoopProtocolTaskArguments) - Method in class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolTaskAdapter: Run the task.
run() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.child.HadoopExternalProcessStarter: Run the process.
run(HadoopJobEx, Collection<HadoopTaskInfo>) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskExecutor: Runs tasks.
run(HadoopJobEx, Collection<HadoopTaskInfo>) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopEmbeddedTaskExecutor: Runs tasks.
run(HadoopJobEx, Collection<HadoopTaskInfo>) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskExecutorAdapter: Runs tasks.
run0(HadoopV2TaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2CleanupTask: Internal task routine.
run0(HadoopV2TaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2MapTask: Internal task routine.
run0(HadoopV2TaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2ReduceTask: Internal task routine.
run0(HadoopV2TaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2SetupTask: Internal task routine.
run0(HadoopV2TaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Task: Internal task routine.
runAsJobOwner(Callable<T>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext

S

safeCreateConfiguration() - Static method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopUtils: Creates Configuration in a correct class loader context to avoid caching of inappropriate class loader in the Configuration object.
secondaryFileSystemDelegate(HadoopClassLoader, IgniteHadoopIgfsSecondaryFileSystem) - Static method in class org.apache.ignite.internal.processors.hadoop.delegate.HadoopDelegateUtils: Create delegate for secondary file system.
seek(long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream
seek(long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyInputStream
seekToNewSource(long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream
seekToNewSource(long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyInputStream
send(IgfsMessage) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIo: Sends given IGFS client message and asynchronously awaits for response.
send(IgfsMessage, byte[], int, int) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIo: Sends given IGFS client message and asynchronously awaits for response.
send(IgfsMessage) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIpcIo: Sends given IGFS client message and asynchronously awaits for response.
send(IgfsMessage, byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIpcIo: Sends given IGFS client message and asynchronously awaits for response.
sendMessage(HadoopProcessDescriptor, HadoopMessage) - Method in interface org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopCommunicationClient
sendMessage(HadoopProcessDescriptor, HadoopMessage) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Sends message to Hadoop process.
sendMessage(HadoopProcessDescriptor, HadoopMessage) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopTcpNioCommunicationClient
sendPlain(IgfsMessage) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIo: Sends given message and does not wait for response.
sendPlain(IgfsMessage) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIpcIo: Sends given message and does not wait for response.
sentMsgs - Variable in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob
serve() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopIpcToNioAdapter: Serves given set of listeners repeatedly reading data from the endpoint.
session() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopIpcToNioAdapter: Gets dummy session for this adapter.
set(long, long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopOffheapBuffer
setConfigPaths(String...) - Method in class org.apache.ignite.hadoop.fs.BasicHadoopFileSystemFactory: Set paths to additional file system configuration files (e.g. core-site.xml).
setConnectTimeout(long) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Sets connect timeout used when establishing connection with remote nodes.
setContextClassLoader(ClassLoader) - Static method in class org.apache.ignite.internal.processors.hadoop.HadoopCommonUtils: Set context class loader.
setDefaultUserName(String) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem: Sets default user name.
setDefaultUserName(String) - Method in class org.apache.ignite.hadoop.util.BasicUserNameMapper: Set default user name (optional).
setDirectBuffer(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Sets flag to allocate direct or heap buffer in SPI.
setDisplayName(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Counter
setDisplayName(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Counter
setFileSystemFactory(HadoopFileSystemFactory) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem: Sets secondary file system factory.
setIgniteInstance(IgniteEx) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
setInstance(String) - Method in class org.apache.ignite.hadoop.util.KerberosUserNameMapper: Set Kerberos instance (optional).
setJobPriority(JobID, String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
setKeyTab(String) - Method in class org.apache.ignite.hadoop.fs.KerberosHadoopFileSystemFactory: Sets the key tab file name.
setKeyTabPrincipal(String) - Method in class org.apache.ignite.hadoop.fs.KerberosHadoopFileSystemFactory: Set the key tab principal name.
setListener(HadoopMessageListener) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Sets Hadoop communication message listener.
setLocalMapperWeight(int) - Method in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner: Set local mapper weight.
setLocalPort(int) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Sets local port for socket binding.
setLocalPortRange(int) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Sets local port range for local host ports (value must greater than or equal to 0).
setLocalReducerWeight(int) - Method in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner: Set local reducer weight.
setMappers(UserNameMapper...) - Method in class org.apache.ignite.hadoop.util.ChainedUserNameMapper: Set child mappers.
setMappings(Map<String, String>) - Method in class org.apache.ignite.hadoop.util.BasicUserNameMapper: Set mappings.
setMaxConnectTimeout(long) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Sets maximum connect timeout.
setMessageQueueLimit(int) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Sets message queue limit for incoming and outgoing messages.
setOwner(Path, String, String) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
setOwner(Path, String, String) - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
setPermission(Path, FsPermission) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
setPermission(Path, FsPermission) - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
setPreferLocalReducerThresholdWeight(int) - Method in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner: Set reducer migration threshold weight.
setRealm(String) - Method in class org.apache.ignite.hadoop.util.KerberosUserNameMapper: Set Kerberos realm (optional).
setReconnectCount(int) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Sets maximum number of reconnect attempts used when establishing connection with remote nodes.
setReloginInterval(long) - Method in class org.apache.ignite.hadoop.fs.KerberosHadoopFileSystemFactory: Sets the relogin interval in milliseconds.
setRemoteMapperWeight(int) - Method in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner: Set remote mapper weight.
setRemoteReducerWeight(int) - Method in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner: Set remote reducer weight.
setReplication(Path, short) - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
setSelectorsCount(int) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Sets the count of selectors te be used in TCP server.
setSharedMemoryPort(int) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Sets local port to accept shared memory connections.
setSocketReceiveBuffer(int) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Sets receive buffer size for sockets created or accepted by this SPI.
setSocketSendBuffer(int) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Sets send buffer size for sockets created or accepted by this SPI.
setStatus(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Reporter
setStatus(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
setTcpNoDelay(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Sets value for TCP_NODELAY socket option.
setTimes(IgfsPath, long, long) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
setTimes(Path, long, long) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
setTimes(Path, long, long) - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
setTimes(IgfsPath, long, long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
setTimes(IgfsPath, long, long) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Sets last access time and last modification time for a file.
setTimes(IgfsPath, long, long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Sets last access time and last modification time for a file.
setTimes(IgfsPath, long, long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Sets last access time and last modification time for a file.
setTimes(IgfsPath, long, long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Sets last access time and last modification time for a file.
setup() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1OutputCollector: Setup task.
setup(OutputFormat) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Task: Setup task.
setupFileSystems(Configuration) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopFileSystemsUtils: Setup wrappers of filesystems to support the separate working directory.
setUri(String) - Method in class org.apache.ignite.hadoop.fs.BasicHadoopFileSystemFactory: Sets file system URI.
setUseDefaultUserName(boolean) - Method in class org.apache.ignite.hadoop.util.BasicUserNameMapper: Set whether to use default user name when there is no mapping for current user name.
setUserNameMapper(UserNameMapper) - Method in class org.apache.ignite.hadoop.fs.BasicHadoopFileSystemFactory: Set optional user name mapper.
setValue(long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Counter
setValue(long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Counter
setVerifyChecksum(boolean) - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
setWorkingDirectory(Path) - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
setWorkingDirectory(Path) - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem
setWriteAllCounters(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters
sharedMemoryPort() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessDescriptor
sharedMemoryPort(int) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessDescriptor: Sets shared memory port.
shuffle() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopContext
shutdown(long) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopExecutorService: Shuts down this executor service.
single() - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanGroup
size() - Method in class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolTaskArguments
size() - Method in interface org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimap.Value
skip(long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInputStream
skip(long) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyInputStream
skip(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
skipBytes(int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataInput
skipBytes(int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataInStream
sortComparator() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext
sortInputSplits(Collection<HadoopInputSplit>) - Static method in class org.apache.ignite.internal.processors.hadoop.HadoopCommonUtils: Sort input splits by length.
splitJob(JobConf) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Splitter
splitJob(JobContext) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Splitter
stagingAreaDir(Configuration, String) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopUtils: Gets staging area directory.
start() - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
start() - Method in class org.apache.ignite.hadoop.util.ChainedUserNameMapper
start() - Method in class org.apache.ignite.hadoop.util.KerberosUserNameMapper
start(HadoopContext) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopComponent
start() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopProcessor
start() - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopBasicFileSystemFactoryDelegate
start() - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopCachingFileSystemFactoryDelegate
start() - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopDefaultFileSystemFactoryDelegate
start() - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
start() - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopKerberosFileSystemFactoryDelegate
start(HadoopContext) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker
start(HadoopContext) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffle
start(HadoopExternalCommunication, HadoopProcessDescriptor, ExecutorService, IgniteLogger) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.child.HadoopChildProcessRunner: Starts child process runner.
start() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Starts communication.
start(HadoopContext) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskExecutor
startAdding(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopConcurrentHashMultimap
startAdding(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimap
startAdding(HadoopTaskContext) - Method in interface org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimap
startAdding(HadoopTaskContext) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopSkipList
startSending(String, IgniteInClosure2X<T, HadoopMessage>) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob
state() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutputContext
state() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskStatus
status(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopImpl
status(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopProcessor
status(HadoopJobStatus, Configuration) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopUtils: Convert Ignite job status to Hadoop job status.
status(HadoopJobMetadata) - Static method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker: Convert Hadoop job metadata to job status.
status(HadoopJobId) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker: Gets hadoop job status for given job ID.
status() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskFinishedMessage
stop() - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
stop() - Method in class org.apache.ignite.hadoop.util.ChainedUserNameMapper
stop() - Method in class org.apache.ignite.hadoop.util.KerberosUserNameMapper
stop(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopComponent: Stops manager.
stop(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopProcessor
stop() - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopBasicFileSystemFactoryDelegate
stop() - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopCachingFileSystemFactoryDelegate
stop() - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopDefaultFileSystemFactoryDelegate
stop() - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
stop(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffle: Stops shuffle.
stop() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication: Stops the server.
stop(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskExecutor: Stops manager.
stop(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopEmbeddedTaskExecutor: Stops manager.
submit(HadoopJobId, HadoopJobInfo) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopImpl
submit(HadoopJobId, HadoopJobInfo) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopProcessor
submit(HadoopJobId, HadoopJobInfo) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobTracker: Submits execution of Hadoop job to grid.
submit(Callable<?>) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopExecutorService: Submit task.
submitJob(JobID, String, Credentials) - Method in class org.apache.ignite.internal.processors.hadoop.impl.proto.HadoopClientProtocol
submitNodeId() - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata
supportsSymlinks() - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
supportsSymlinks() - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopRawLocalFileSystem

T

target() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsStreamDelegate
taskExecutor() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopContext
taskInfo() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskFinishedMessage
taskInfo() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopRunnableTask
taskLocalDir(String, UUID, HadoopTaskInfo) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopUtils: Returns subdirectory of job working directory for task execution.
taskNumber(HadoopInputSplit) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata
tasks() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskExecutionRequest
tasks(Collection<HadoopTaskInfo>) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskExecutionRequest
tcpPort() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessDescriptor
tcpPort(int) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessDescriptor: Sets TCP port.
TextPartiallyRawComparator - Class in org.apache.ignite.hadoop.io: Partial raw comparator for Text data type.
TextPartiallyRawComparator() - Constructor for class org.apache.ignite.hadoop.io.TextPartiallyRawComparator
topology(Collection<ClusterNode>) - Static method in class org.apache.ignite.hadoop.planner.HadoopAbstractMapReducePlanner: Create plan topology.
toString() - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem
toString() - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem
toString() - Method in class org.apache.ignite.hadoop.mapreduce.IgniteHadoopWeightedMapReducePlanner
toString() - Method in class org.apache.ignite.hadoop.util.BasicUserNameMapper
toString() - Method in class org.apache.ignite.hadoop.util.ChainedUserNameMapper
toString() - Method in class org.apache.ignite.hadoop.util.KerberosUserNameMapper
toString() - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCounterAdapter
toString() - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCountersImpl
toString() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopAttributes
toString() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopExternalSplit
toString() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopProcessor
toString() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopSplitWrapper
toString() - Method in class org.apache.ignite.internal.processors.hadoop.igfs.HadoopIgfsEndpoint
toString() - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
toString() - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopFileSystemCacheUtils.FsCacheKey
toString() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsIpcIo
toString() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsJclLogger
toString() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsStreamDelegate
toString() - Method in class org.apache.ignite.internal.processors.hadoop.io.OffheapRawMemory
toString() - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata
toString() - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanGroup
toString() - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanTopology
toString() - Method in class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolTaskArguments
toString() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopAbstractCommunicationClient
toString() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication.ProcessHandshakeMessage
toString() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication
toString() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopTcpNioCommunicationClient
toString() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopExternalTaskMetadata
toString() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopJobInfoUpdateRequest
toString() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopPrepareForJobRequest
toString() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessDescriptor
toString() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessStartedAck
toString() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskExecutionRequest
toString() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskFinishedMessage
toString() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskStatus
totalReducerCount() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopPrepareForJobRequest
trace(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsJclLogger
transformException(Throwable) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopUtils: Throws new IgniteCheckedException with original exception is serialized into string.

U

unwrapSplit(HadoopSplitWrapper) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopUtils: Unwraps native split.
update(IgfsPath, Map<String, String>) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
update(IgfsPath, Map<String, String>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
update(IgfsPath, Map<String, String>) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfs: Command to update file properties.
update(IgfsPath, Map<String, String>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Command to update file properties.
update(IgfsPath, Map<String, String>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Command to update file properties.
update(IgfsPath, Map<String, String>) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsWrapper: Command to update file properties.
update(long, int) - Method in class org.apache.ignite.internal.processors.hadoop.io.OffheapRawMemory: Update pointer and length.
uri() - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopFileSystemCacheUtils.FsCacheKey: The URI.
usedSpaceSize() - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopIgfsSecondaryFileSystem
usedSpaceSize() - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopIgfsSecondaryFileSystemDelegateImpl
user() - Method in class org.apache.ignite.hadoop.fs.v1.IgniteHadoopFileSystem: Returns the user name this File System is created on behalf of.
user() - Method in class org.apache.ignite.hadoop.fs.v2.IgniteHadoopFileSystem: Returns the user name this File System is created on behalf of.
user() - Method in class org.apache.ignite.internal.processors.hadoop.impl.fs.HadoopFileSystemCacheUtils.FsCacheKey: The User.
user() - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsEx: The user this Igfs instance works on behalf of.
user() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: The user this Igfs instance works on behalf of.
user() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: The user this Igfs instance works on behalf of.
userName() - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProperties: Get user name.
UserNameMapper - Interface in org.apache.ignite.hadoop.util: Hadoop file system name mapper.

V

validateEnvironment() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopProcessor
valSer - Variable in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.AdderBase
value() - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopLongCounter: Gets current value of this counter.
value(long) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopLongCounter: Sets current value by the given value.
value(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopConcurrentHashMultimap
value(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase
value(long, long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase
ValueIterator(long, HadoopMultimapBase.ReaderBase) - Constructor for class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.ValueIterator
valueOf(String) - Static method in enum org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskState: Returns the enum constant of this type with the specified name.
values() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase.Input
values() - Static method in enum org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskState: Returns an array containing the constants of this enum type, in the order they are declared.
valueSerialization() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2TaskContext
valueSize(long, int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase
valueSize(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase
version() - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata
visit(boolean, HadoopMultimap.Visitor) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopConcurrentHashMultimap: Incrementally visits all the keys and values in the map.
visit(boolean, HadoopMultimap.Visitor) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopHashMultimapBase: Incrementally visits all the keys and values in the map.
visit(boolean, HadoopMultimap.Visitor) - Method in interface org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimap: Incrementally visits all the keys and values in the map.
visit(boolean, HadoopMultimap.Visitor) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopSkipList: Incrementally visits all the keys and values in the map.

W

waitTime() - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopRunnableTask
warning(String) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsJclLogger
warning(String, Throwable) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsJclLogger
weight() - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanGroup
weight(int) - Method in class org.apache.ignite.internal.processors.hadoop.planner.HadoopMapReducePlanGroup
WINUTILS_EXE - Static variable in class org.apache.ignite.internal.processors.hadoop.HadoopSetup
workDir - Variable in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopBasicFileSystemFactoryDelegate: Work directory.
workDirectory() - Method in class org.apache.ignite.internal.processors.hadoop.HadoopHelperImpl
wrapSplit(int, Object, String[]) - Static method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopUtils: Wraps native split.
write(HadoopJobEx, HadoopCounters) - Method in class org.apache.ignite.hadoop.fs.IgniteHadoopFileSystemCounterWriter
write(HadoopJobEx, HadoopCounters) - Method in interface org.apache.ignite.internal.processors.hadoop.delegate.HadoopFileSystemCounterWriterDelegate: Writes counters of given job to some statistics storage.
write(HadoopJobEx, HadoopCounters) - Method in class org.apache.ignite.internal.processors.hadoop.impl.delegate.HadoopFileSystemCounterWriterDelegateImpl: Writes counters of given job to some statistics storage.
write(DataOutput) - Method in class org.apache.ignite.internal.processors.hadoop.impl.HadoopMapReduceCounters
write(byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutputStream
write(int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutputStream
write(int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyOutputStream
write(byte[]) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyOutputStream
write(byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsProxyOutputStream
write(DataOutput) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v1.HadoopV1Counter
write(DataOutput, Object) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopSerializationWrapper
write(Object, Object) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
write(DataOutput) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Counter
write(DataOutput, Object) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopWritableSerialization
write(int, Object, HadoopSerialization) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.AdderBase
write(byte[]) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
write(byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
write(int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
write(Object, Object) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutputContext: Write key-value pair.
write(Object, Object) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.HadoopShuffleJob.PartitionedOutput
write(int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
write(byte[]) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
write(byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
writeBoolean(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
writeBoolean(boolean) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
writeByte(int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
writeByte(int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
writeBytes(String) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
writeBytes(String) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
writeChar(int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
writeChar(int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
writeChars(String) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
writeChars(String) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
writeData(HadoopIgfsStreamDelegate, byte[], int, int) - Method in interface org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsEx: Writes data to the stream with given streamId.
writeData(HadoopIgfsStreamDelegate, byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsInProc: Writes data to the stream with given streamId.
writeData(HadoopIgfsStreamDelegate, byte[], int, int) - Method in class org.apache.ignite.internal.processors.hadoop.impl.igfs.HadoopIgfsOutProc: Writes data to the stream with given streamId.
writeDouble(double) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
writeDouble(double) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
writeExternal(ObjectOutput) - Method in class org.apache.ignite.hadoop.fs.BasicHadoopFileSystemFactory
writeExternal(ObjectOutput) - Method in class org.apache.ignite.hadoop.fs.KerberosHadoopFileSystemFactory
writeExternal(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCounterAdapter
writeExternal(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCountersImpl
writeExternal(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopAttributes
writeExternal(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopExternalSplit
writeExternal(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.HadoopSplitWrapper
writeExternal(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.jobtracker.HadoopJobMetadata
writeExternal(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.proto.HadoopProtocolTaskArguments
writeExternal(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.communication.HadoopExternalCommunication.ProcessHandshakeMessage
writeExternal(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopJobInfoUpdateRequest
writeExternal(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopPrepareForJobRequest
writeExternal(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopProcessStartedAck
writeExternal(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskExecutionRequest
writeExternal(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.external.HadoopTaskFinishedMessage
writeExternal(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.taskexecutor.HadoopTaskStatus
writeFloat(float) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
writeFloat(float) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
writeInt(int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
writeInt(int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
writeLong(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
writeLong(long) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
writer() - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context
writer(RecordWriter) - Method in class org.apache.ignite.internal.processors.hadoop.impl.v2.HadoopV2Context: Overrides default output data writer.
writeShort(int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
writeShort(int) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
writeUTF(String) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.direct.HadoopDirectDataOutput
writeUTF(String) - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.streams.HadoopDataOutStream
writeValue(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopCounterAdapter: Writes value of this counter to output.
writeValue(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopLongCounter: Writes value of this counter to output.
writeValue(ObjectOutput) - Method in class org.apache.ignite.internal.processors.hadoop.counter.HadoopPerformanceCounter: Writes value of this counter to output.
writtenSize() - Method in class org.apache.ignite.internal.processors.hadoop.shuffle.collections.HadoopMultimapBase.AdderBase

A B C D E F G H I J K L M N O P R S T U V W