public interface SparkPigSplit
extends org.apache.hadoop.io.Writable, org.apache.hadoop.conf.Configurable, java.io.Serializable
Modifier and Type | Interface and Description |
---|---|
static class |
SparkPigSplit.FileSparkPigSplit |
static class |
SparkPigSplit.GenericSparkPigSplit |
static class |
SparkPigSplit.SparkPigSplitsUtils |
Modifier and Type | Method and Description |
---|---|
boolean |
disableCounter() |
long |
getLength(int idx) |
org.apache.hadoop.mapred.SplitLocationInfo[] |
getLocationInfo() |
int |
getNumPaths() |
int |
getSplitIndex() |
PigSplit |
getWrappedPigSplit() |
org.apache.hadoop.mapreduce.InputSplit |
getWrappedSplit() |
org.apache.hadoop.mapreduce.InputSplit |
getWrappedSplit(int idx) |
boolean |
isMultiInputs() |
void |
setCurrentIdx(int idx) |
void |
setDisableCounter(boolean disableCounter) |
void |
setMultiInputs(boolean b) |
org.apache.hadoop.mapreduce.InputSplit getWrappedSplit()
org.apache.hadoop.mapreduce.InputSplit getWrappedSplit(int idx)
org.apache.hadoop.mapred.SplitLocationInfo[] getLocationInfo() throws java.io.IOException
java.io.IOException
long getLength(int idx) throws java.io.IOException, java.lang.InterruptedException
java.io.IOException
java.lang.InterruptedException
int getSplitIndex()
void setMultiInputs(boolean b)
boolean isMultiInputs()
int getNumPaths()
void setDisableCounter(boolean disableCounter)
boolean disableCounter()
void setCurrentIdx(int idx)
PigSplit getWrappedPigSplit()
Copyright © 2007-2025 The Apache Software Foundation