public class JdbcInputSplit
extends org.apache.hadoop.mapred.FileSplit
implements org.apache.hadoop.mapred.InputSplit
Constructor and Description |
---|
JdbcInputSplit() |
JdbcInputSplit(int limit,
int offset,
org.apache.hadoop.fs.Path dummyPath) |
JdbcInputSplit(org.apache.hadoop.fs.Path dummyPath) |
JdbcInputSplit(String partitionColumn,
String lowerBound,
String upperBound,
org.apache.hadoop.fs.Path dummyPath) |
Modifier and Type | Method and Description |
---|---|
long |
getLength() |
int |
getLimit() |
String[] |
getLocations() |
String |
getLowerBound() |
int |
getOffset() |
String |
getPartitionColumn() |
String |
getUpperBound() |
void |
readFields(DataInput in) |
void |
setLimit(int limit) |
void |
setOffset(int offset) |
String |
toString() |
void |
write(DataOutput out) |
public JdbcInputSplit()
public JdbcInputSplit(org.apache.hadoop.fs.Path dummyPath)
public JdbcInputSplit(int limit, int offset, org.apache.hadoop.fs.Path dummyPath)
public void write(DataOutput out) throws IOException
write
in interface org.apache.hadoop.io.Writable
write
in class org.apache.hadoop.mapred.FileSplit
IOException
public void readFields(DataInput in) throws IOException
readFields
in interface org.apache.hadoop.io.Writable
readFields
in class org.apache.hadoop.mapred.FileSplit
IOException
public long getLength()
getLength
in interface org.apache.hadoop.mapred.InputSplit
getLength
in class org.apache.hadoop.mapred.FileSplit
public String[] getLocations() throws IOException
getLocations
in interface org.apache.hadoop.mapred.InputSplit
getLocations
in class org.apache.hadoop.mapred.FileSplit
IOException
public int getLimit()
public void setLimit(int limit)
public int getOffset()
public void setOffset(int offset)
public String getPartitionColumn()
public String getLowerBound()
public String getUpperBound()
public String toString()
toString
in class org.apache.hadoop.mapred.FileSplit
Copyright © 2022 The Apache Software Foundation. All rights reserved.