public static class HadoopShimsSecure.InputSplitShim
extends org.apache.hadoop.mapred.lib.CombineFileSplit
Constructor and Description |
---|
InputSplitShim() |
InputSplitShim(org.apache.hadoop.mapred.JobConf conf,
org.apache.hadoop.fs.Path[] paths,
long[] startOffsets,
long[] lengths,
String[] locations) |
Modifier and Type | Method and Description |
---|---|
long |
getShrinkedLength() |
boolean |
isShrinked() |
void |
readFields(DataInput in) |
void |
shrinkSplit(long length) |
void |
write(DataOutput out) |
getLength, getLength, getLengths, getLocations, getNumPaths, getOffset, getPath, getPaths, getStartOffsets, toString
public InputSplitShim()
public InputSplitShim(org.apache.hadoop.mapred.JobConf conf, org.apache.hadoop.fs.Path[] paths, long[] startOffsets, long[] lengths, String[] locations) throws IOException
IOException
public void shrinkSplit(long length)
public boolean isShrinked()
public long getShrinkedLength()
public void readFields(DataInput in) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
readFields
in class org.apache.hadoop.mapreduce.lib.input.CombineFileSplit
IOException
public void write(DataOutput out) throws IOException
write
in interface org.apache.hadoop.io.Writable
write
in class org.apache.hadoop.mapreduce.lib.input.CombineFileSplit
IOException
Copyright © 2019 The Apache Software Foundation. All rights reserved.