public class TableInputSplit extends InputSplit implements Writable
Modifier and Type | Field and Description |
---|---|
static String |
EMPTY_STR |
static int |
QUERY_BY_INDEX |
static int |
QUERY_BY_ONQL_ALL_PARTITIONS |
static int |
QUERY_BY_ONQL_SHARDS |
static int |
QUERY_BY_ONQL_SINGLE_PARTITION |
static int |
QUERY_BY_PRIMARY_ALL_PARTITIONS |
static int |
QUERY_BY_PRIMARY_SINGLE_PARTITION |
Constructor and Description |
---|
TableInputSplit()
No-arg constructor required by Hadoop semantics.
|
Modifier and Type | Method and Description |
---|---|
boolean |
equals(Object obj) |
String[] |
getKVHelperHosts()
Returns a String array with elements of the form, '
|
String |
getKVStoreName()
Returns the name of the store containing the records associated with
this split.
|
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.
|
List<Set<Integer>> |
getPartitionSets()
Returns a
List whose elements are Set s of
partitions; whose union is the set of all partitions in the store. |
int |
getQueryBy() |
PasswordCredentials |
getSecurityCredentials() |
String |
getSecurityLogin() |
String |
getSecurityTrust() |
Set<oracle.kv.impl.topo.RepGroupId> |
getShardSet() |
String |
getTableName() |
String |
getWhereClause() |
int |
hashCode() |
void |
readFields(DataInput in)
Deserialize the fields of this object from
in . |
TableInputSplit |
setQueryInfo(int newQueryBy,
String whereClause) |
String |
toString() |
void |
write(DataOutput out)
Serialize the fields of this object to
out . |
getLocationInfo
public static final int QUERY_BY_PRIMARY_ALL_PARTITIONS
public static final int QUERY_BY_PRIMARY_SINGLE_PARTITION
public static final int QUERY_BY_INDEX
public static final int QUERY_BY_ONQL_ALL_PARTITIONS
public static final int QUERY_BY_ONQL_SINGLE_PARTITION
public static final int QUERY_BY_ONQL_SHARDS
public static final String EMPTY_STR
public TableInputSplit()
public long getLength()
getLength
in class InputSplit
public String[] getLocations()
getLocations
in class InputSplit
public String[] getKVHelperHosts()
public String getKVStoreName()
public String getTableName()
public List<Set<Integer>> getPartitionSets()
List
whose elements are Set
s of
partitions; whose union is the set of all partitions in the store.
Note that this method is declared public
so that the
method TableHiveInputSplit.getPartitionSets
can delegate
to this method.public TableInputSplit setQueryInfo(int newQueryBy, String whereClause)
public int getQueryBy()
public String getWhereClause()
public Set<oracle.kv.impl.topo.RepGroupId> getShardSet()
public String getSecurityLogin()
public PasswordCredentials getSecurityCredentials()
public String getSecurityTrust()
public void write(DataOutput out) throws IOException
out
.write
in interface Writable
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
in
- DataInput
to deseriablize this object from.IOException
Copyright (c) 2011, 2017 Oracle and/or its affiliates. All rights reserved.