public class HCatELFunctions extends Object
Constructor and Description |
---|
HCatELFunctions() |
Modifier and Type | Method and Description |
---|---|
static boolean |
hcat_exists(String uri)
Return true if partitions exists or false if not.
|
static String |
ph1_coord_databaseIn_echo(String dataInName)
Echo the same EL function without evaluating anything
|
static String |
ph1_coord_databaseOut_echo(String dataName) |
static String |
ph1_coord_dataInPartitionFilter_echo(String dataInName,
String type) |
static String |
ph1_coord_dataInPartitionMax_echo(String dataInName,
String partition) |
static String |
ph1_coord_dataInPartitionMin_echo(String dataInName,
String partition) |
static String |
ph1_coord_dataInPartitions_echo(String dataInName,
String type) |
static String |
ph1_coord_dataOutPartitions_echo(String dataOutName) |
static String |
ph1_coord_dataOutPartitionValue_echo(String dataOutName,
String partition) |
static String |
ph1_coord_tableIn_echo(String dataName) |
static String |
ph1_coord_tableOut_echo(String dataName) |
static String |
ph3_coord_databaseIn(String dataInName)
Extract the hcat DB name from the URI-template associate with
'dataInName'.
|
static String |
ph3_coord_databaseOut(String dataOutName)
Extract the hcat DB name from the URI-template associate with
'dataOutName'.
|
static String |
ph3_coord_dataInPartitionFilter(String dataInName,
String type)
Used to specify the HCat partition filter which is input dependency for workflow job.
|
static String |
ph3_coord_dataInPartitionMax(String dataInName,
String partitionName)
Used to specify the MINIMUM value of an HCat partition which is input dependency for workflow job.
|
static String |
ph3_coord_dataInPartitionMin(String dataInName,
String partitionName)
Used to specify the MAXIMUM value of an HCat partition which is input dependency for workflow job.
|
static String |
ph3_coord_dataInPartitions(String dataInName,
String type)
Used to specify the entire HCat partition defining input for workflow job.
|
static String |
ph3_coord_dataOutPartitions(String dataOutName)
Used to specify the entire HCat partition defining output for workflow job.
|
static String |
ph3_coord_dataOutPartitionValue(String dataOutName,
String partitionName)
Used to specify the HCat partition's value defining output for workflow job.
|
static String |
ph3_coord_tableIn(String dataInName)
Extract the hcat Table name from the URI-template associate with
'dataInName'.
|
static String |
ph3_coord_tableOut(String dataOutName)
Extract the hcat Table name from the URI-template associate with
'dataOutName'.
|
public HCatELFunctions()
public static boolean hcat_exists(String uri) throws Exception
uri
- hcatalog partition uri.true
if the uri exists, false
if it does not.Exception
public static String ph1_coord_databaseIn_echo(String dataInName)
dataInName
- public static String ph1_coord_databaseOut_echo(String dataName)
public static String ph1_coord_tableIn_echo(String dataName)
public static String ph1_coord_tableOut_echo(String dataName)
public static String ph1_coord_dataInPartitionFilter_echo(String dataInName, String type)
public static String ph1_coord_dataInPartitionMin_echo(String dataInName, String partition)
public static String ph1_coord_dataInPartitionMax_echo(String dataInName, String partition)
public static String ph1_coord_dataOutPartitions_echo(String dataOutName)
public static String ph1_coord_dataInPartitions_echo(String dataInName, String type)
public static String ph1_coord_dataOutPartitionValue_echo(String dataOutName, String partition)
public static String ph3_coord_databaseIn(String dataInName)
dataInName
- public static String ph3_coord_databaseOut(String dataOutName)
dataOutName
- public static String ph3_coord_tableIn(String dataInName)
dataInName
- public static String ph3_coord_tableOut(String dataOutName)
dataOutName
- public static String ph3_coord_dataInPartitionFilter(String dataInName, String type)
Look for two evaluator-level variables
A) .datain.<DATAIN_NAME> B) .datain.<DATAIN_NAME>.unresolved
A defines the current list of HCat URIs.
B defines whether there are any unresolved EL-function (i.e latest)
If there are something unresolved, this function will echo back the original function
otherwise it sends the partition filter.
dataInName
- : Datain nametype
- : for action type - pig, MR or hivepublic static String ph3_coord_dataOutPartitionValue(String dataOutName, String partitionName)
Look for two evaluator-level variables
A) .dataout.<DATAOUT_NAME> B) .dataout.<DATAOUT_NAME>.unresolved
A defines the current list of HCat URIs.
B defines whether there are any unresolved EL-function (i.e latest)
If there are something unresolved, this function will echo back the original function
otherwise it sends the partition value.
dataOutName
- : Dataout namepartitionName
- : Specific partition name whose value is wantedpublic static String ph3_coord_dataOutPartitions(String dataOutName)
Look for two evaluator-level variables
A) .dataout.<DATAOUT_NAME> B) .dataout.<DATAOUT_NAME>.unresolved
A defines the data-out HCat URI.
B defines whether there are any unresolved EL-function (i.e latest)
If there are something unresolved, this function will echo back the original function
otherwise it sends the partition.
dataOutName
- : DataOut namepublic static String ph3_coord_dataInPartitions(String dataInName, String type)
Look for two evaluator-level variables
A) .datain.<DATAIN_NAME> B) .datain.<DATAIN_NAME>.unresolved
A defines the data-in HCat URI.
B defines whether there are any unresolved EL-function (i.e latest)
If there are something unresolved, this function will echo back the original function
otherwise it sends the partition.
dataInName
- : DataIn nametype
- : for action type: hive-exportpublic static String ph3_coord_dataInPartitionMin(String dataInName, String partitionName)
Look for two evaluator-level variables
A) .datain.<DATAIN_NAME> B) .datain.<DATAIN_NAME>.unresolved
A defines the current list of HCat URIs.
B defines whether there are any unresolved EL-function (i.e latest)
If there are something unresolved, this function will echo back the original function
otherwise it sends the max partition value.
dataInName
- : Datain namepartitionName
- : Specific partition name whose MAX value is wantedpublic static String ph3_coord_dataInPartitionMax(String dataInName, String partitionName)
Look for two evaluator-level variables
A) .datain.<DATAIN_NAME> B) .datain.<DATAIN_NAME>.unresolved
A defines the current list of HCat URIs.
B defines whether there are any unresolved EL-function (i.e latest)
If there are something unresolved, this function will echo back the original function
otherwise it sends the min partition value.
dataInName
- : Datain namepartitionName
- : Specific partition name whose MIN value is wantedCopyright © 2018 Apache Software Foundation. All rights reserved.