public class TableHiveInputSplit extends FileSplit
Note that the Hive infrastructure requires that even though the data associated with instances of this class resides in a table in an Oracle NoSQL Database store rather than an HDFS file, this class still must subclass FileSplit. As a result, a Hadoop HDFS Path must be specified for this class.
Also note that although this InputSplit is based on version 1 of MapReduce (as requied by the Hive infrastructure), it wraps and delegates to a YARN based (MapReduce version 2) InputSplit. This is done because the InputSplit class Oracle NoSQL Database provides to support Hadoop integration is YARN based, and this class wishes to exploit and reuse the functionality already provided by the YARN based InputSplit class.
Constructor and Description |
---|
TableHiveInputSplit() |
TableHiveInputSplit(Path filePath,
TableInputSplit v2Split) |
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
String[] |
getKVHelperHosts() |
String |
getKVStoreName() |
long |
getLength()
Get the size of the split, so that the input splits can be sorted by
size.
|
String[] |
getLocations()
Get the list of nodes by name where the data for the split would be
local.
|
Path |
getPath()
Returns the HDFS Path associated with this split.
|
int |
getQueryBy() |
PasswordCredentials |
getSecurityCredentials() |
String |
getSecurityLogin() |
String |
getSecurityTrust() |
String |
getTableName() |
String |
getWhereClause() |
int |
hashCode() |
void |
readFields(DataInput in)
Deserialize the fields of this object from
in . |
String |
toString() |
void |
write(DataOutput out)
Serialize the fields of this object to
out . |
getLocationInfo, getStart
public TableHiveInputSplit()
public TableHiveInputSplit(Path filePath, TableInputSplit v2Split)
public Path getPath()
public long getLength()
getLength
in interface InputSplit
getLength
in class FileSplit
public String[] getLocations() throws IOException
getLocations
in interface InputSplit
getLocations
in class FileSplit
IOException
public void write(DataOutput out) throws IOException
out
.write
in interface Writable
write
in class FileSplit
out
- DataOuput
to serialize this object into.IOException
public void readFields(DataInput in) throws IOException
in
.
For efficiency, implementations should attempt to re-use storage in the existing object where possible.
readFields
in interface Writable
readFields
in class FileSplit
in
- DataInput
to deseriablize this object from.IOException
public String getKVStoreName()
public String[] getKVHelperHosts()
public String getTableName()
public int getQueryBy()
public String getWhereClause()
public String getSecurityLogin()
public PasswordCredentials getSecurityCredentials()
public String getSecurityTrust()
Copyright (c) 2011, 2017 Oracle and/or its affiliates. All rights reserved.