- identity() - Static method in interface net.sansa_stack.hadoop.generic.Accumulating
-
Identity accumulator - turns each item into a group that contains only the item and whose value is the item
- in - Variable in class net.sansa_stack.hadoop.util.InterruptingReadableByteChannel
-
- initialize(InputSplit, TaskAttemptContext) - Method in class net.sansa_stack.hadoop.generic.RecordReaderGenericBase
-
Read out config paramaters (prefixes, length thresholds, ...) and
examine the codec in order to set an internal
flag whether the stream will be encoded or not.
- initRecordFlow() - Method in class net.sansa_stack.hadoop.generic.RecordReaderGenericBase
-
- InputStreamWithCloseIgnore - Class in net.sansa_stack.hadoop.util
-
- InputStreamWithCloseIgnore(InputStream) - Constructor for class net.sansa_stack.hadoop.util.InputStreamWithCloseIgnore
-
Constructs a new ProxyInputStream.
- InputStreamWithCloseLogging - Class in net.sansa_stack.hadoop.util
-
Util class to debug a stream already closed exception
- InputStreamWithCloseLogging(InputStream, BiConsumer<? super Throwable, ? super Throwable>) - Constructor for class net.sansa_stack.hadoop.util.InputStreamWithCloseLogging
-
- InputStreamWithZeroOffsetRead - Class in net.sansa_stack.hadoop.util
-
Workaround for HADOOP-17453: read(bts, off, len) with off != 0 is broken in several version of BZip2Codec
Invoking read with a non-zero offset creates a in intermediate buffer to which is read with a zero offset
The content of the intermidate buffer is then copied to the requesting buffer bts at the appropriate offset.
- InputStreamWithZeroOffsetRead(InputStream) - Constructor for class net.sansa_stack.hadoop.util.InputStreamWithZeroOffsetRead
-
Constructs a new ProxyInputStream.
- interrupted - Variable in class net.sansa_stack.hadoop.util.InterruptingReadableByteChannel
-
- InterruptingReadableByteChannel - Class in net.sansa_stack.hadoop.util
-
ReadabalByteChannel whose read method is guaranteed to return at a specific position
(before crossing it) such as a split boundary
- InterruptingReadableByteChannel(InputStream, Seekable, long) - Constructor for class net.sansa_stack.hadoop.util.InterruptingReadableByteChannel
-
- InterruptingReadableByteChannel(InputStream, Seekable, long, Consumer<InterruptingReadableByteChannel>) - Constructor for class net.sansa_stack.hadoop.util.InterruptingReadableByteChannel
-
- interruptPos - Variable in class net.sansa_stack.hadoop.util.InterruptingReadableByteChannel
-
- interruptPosFoundCallback - Variable in class net.sansa_stack.hadoop.util.InterruptingReadableByteChannel
-
- isEncoded - Variable in class net.sansa_stack.hadoop.generic.RecordReaderGenericBase
-
- isInEofState - Variable in class net.sansa_stack.hadoop.util.ReadableByteChannelWithConditionalBound
-
- isOpen() - Method in class net.sansa_stack.hadoop.util.InterruptingReadableByteChannel
-
- isOpen() - Method in interface net.sansa_stack.hadoop.util.ReadableByteChannelDecorator
-
- isOpen() - Method in class net.sansa_stack.hadoop.util.ReadableByteChannelWithoutCloseOnInterrupt
-
- isSplitable(JobContext, Path) - Method in class net.sansa_stack.hadoop.jena.rdf.base.FileInputFormatRdfBase
-