com.cloudera.api.model
Class ApiHiveReplicationResult

java.lang.Object
  extended by com.cloudera.api.model.ApiHiveReplicationResult

public class ApiHiveReplicationResult
extends Object

Detailed information about a Hive replication job.


Constructor Summary
ApiHiveReplicationResult()
           
 
Method Summary
 boolean equals(Object o)
           
 ApiHdfsReplicationResult getDataReplicationResult()
          Result of table data replication, if performed.
 long getDbExpected()
          Number of Db's Expected.
 long getDbProcessed()
          Number of Db's Imported/Exported.
 Integer getErrorCount()
          Number of errors detected during replication job.
 List<ApiHiveReplicationError> getErrors()
          List of errors encountered during replication.
 long getFunctionExpected()
          Number of Functions Expected.
 long getFunctionProcessed()
          Number of Functions Imported/Exported.
 Integer getHiveUDFCount()
          Number of hive UDFs that were successfully replicated.
 List<ApiHiveUDF> getHiveUDFs()
          The list of Impala UDFs successfully replicated.
 Integer getImpalaUDFCount()
          Number of impala UDFs that were successfully replicated.
 List<ApiImpalaUDF> getImpalaUDFs()
          The list of Impala UDFs successfully replicated.
 long getIndexExpected()
          Number of Indexes Expected.
 long getIndexProcessed()
          Number of Indexes Imported/Exported.
 long getPartitionExpected()
          Number of Partitions Expected.
 long getPartitionProcessed()
          Number of Partitions Imported/Exported.
 String getPhase()
          Phase the replication is in.
 String getRunAsUser()
          Name of the of proxy user, if any.
 String getRunOnSourceAsUser()
          Name of the source proxy user, if any.
 long getStatsExpected()
          Number of Table and Partition Statistics Expected.
 long getStatsProcessed()
          Number of Table and Partitions Statistics Imported/Exported.
 Integer getTableCount()
          Number of tables that were successfully replicated.
 long getTableExpected()
          Number of Tables Expected.
 long getTableProcessed()
          Number of Tables Imported/Exported.
 List<ApiHiveTable> getTables()
          The list of tables successfully replicated.
 int hashCode()
           
 boolean isDryRun()
          Whether this was a dry run.
 boolean isStatsAvailable()
          Whether stats are available to display or not.
 void setDataReplicationResult(ApiHdfsReplicationResult dataReplicationResult)
           
 void setDbExpected(long dbExpected)
           
 void setDbProcessed(long dbProcessed)
           
 void setDryRun(boolean dryRun)
           
 void setErrorCount(Integer errorCount)
           
 void setErrors(List<ApiHiveReplicationError> errors)
           
 void setFunctionExpected(long functionExpected)
           
 void setFunctionProcessed(long functionProcessed)
           
 void setHiveUDFCount(Integer hiveUDFCount)
           
 void setHiveUDFs(List<ApiHiveUDF> hiveUDFs)
           
 void setImpalaUDFCount(Integer impalaUDFCount)
           
 void setImpalaUDFs(List<ApiImpalaUDF> impalaUDFs)
           
 void setIndexExpected(long indexExpected)
           
 void setIndexProcessed(long indexProcessed)
           
 void setPartitionExpected(long partitionExpected)
           
 void setPartitionProcessed(long partitionProcessed)
           
 void setPhase(String phase)
           
 void setRunAsUser(String runAsUser)
           
 void setRunOnSourceAsUser(String runOnSourceAsUser)
           
 void setStatsAvailable(boolean statsAvailable)
           
 void setStatsExpected(long statsExpected)
           
 void setStatsProcessed(long statsProcessed)
           
 void setTableCount(Integer tableCount)
           
 void setTableExpected(long tableExpected)
           
 void setTableProcessed(long tableProcessed)
           
 void setTables(List<ApiHiveTable> tables)
           
 String toString()
           
 
Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, wait, wait, wait
 

Constructor Detail

ApiHiveReplicationResult

public ApiHiveReplicationResult()
Method Detail

getPhase

public String getPhase()
Phase the replication is in.

If the replication job is still active, this will contain a string describing the current phase. This will be one of: EXPORT, DATA or IMPORT, for, respectively, exporting the source metastore information, replicating table data (if configured), and importing metastore information in the target.

This value will not be present if the replication is not active.

Available since API v4.


setPhase

public void setPhase(String phase)

getTableCount

public Integer getTableCount()
Number of tables that were successfully replicated. Available since API v4.


setTableCount

public void setTableCount(Integer tableCount)

getTables

public List<ApiHiveTable> getTables()
The list of tables successfully replicated.

Since API v4, this is only available in the full view.


setTables

public void setTables(List<ApiHiveTable> tables)

getImpalaUDFCount

public Integer getImpalaUDFCount()
Number of impala UDFs that were successfully replicated. Available since API v6.


setImpalaUDFCount

public void setImpalaUDFCount(Integer impalaUDFCount)

getHiveUDFCount

public Integer getHiveUDFCount()
Number of hive UDFs that were successfully replicated. Available since API v14.


setHiveUDFCount

public void setHiveUDFCount(Integer hiveUDFCount)

getImpalaUDFs

public List<ApiImpalaUDF> getImpalaUDFs()
The list of Impala UDFs successfully replicated. Available since API v6 in the full view.


setImpalaUDFs

public void setImpalaUDFs(List<ApiImpalaUDF> impalaUDFs)

getHiveUDFs

public List<ApiHiveUDF> getHiveUDFs()
The list of Impala UDFs successfully replicated. Available since API v6 in the full view.


setHiveUDFs

public void setHiveUDFs(List<ApiHiveUDF> hiveUDFs)

getErrorCount

public Integer getErrorCount()
Number of errors detected during replication job. Available since API v4.


setErrorCount

public void setErrorCount(Integer errorCount)

getErrors

public List<ApiHiveReplicationError> getErrors()
List of errors encountered during replication.

Since API v4, this is only available in the full view.


setErrors

public void setErrors(List<ApiHiveReplicationError> errors)

getDataReplicationResult

public ApiHdfsReplicationResult getDataReplicationResult()
Result of table data replication, if performed.


setDataReplicationResult

public void setDataReplicationResult(ApiHdfsReplicationResult dataReplicationResult)

isDryRun

public boolean isDryRun()
Whether this was a dry run.


setDryRun

public void setDryRun(boolean dryRun)

getRunAsUser

public String getRunAsUser()
Name of the of proxy user, if any. Available since API v11.


setRunAsUser

public void setRunAsUser(String runAsUser)

getRunOnSourceAsUser

public String getRunOnSourceAsUser()
Name of the source proxy user, if any. Available since API v18.


setRunOnSourceAsUser

public void setRunOnSourceAsUser(String runOnSourceAsUser)

isStatsAvailable

public boolean isStatsAvailable()
Whether stats are available to display or not. Available since API v19.


setStatsAvailable

public void setStatsAvailable(boolean statsAvailable)

getDbProcessed

public long getDbProcessed()
Number of Db's Imported/Exported. Available since API v19.


setDbProcessed

public void setDbProcessed(long dbProcessed)

getTableProcessed

public long getTableProcessed()
Number of Tables Imported/Exported. Available since API v19.


setTableProcessed

public void setTableProcessed(long tableProcessed)

getPartitionProcessed

public long getPartitionProcessed()
Number of Partitions Imported/Exported. Available since API v19.


setPartitionProcessed

public void setPartitionProcessed(long partitionProcessed)

getFunctionProcessed

public long getFunctionProcessed()
Number of Functions Imported/Exported. Available since API v19.


setFunctionProcessed

public void setFunctionProcessed(long functionProcessed)

getIndexProcessed

public long getIndexProcessed()
Number of Indexes Imported/Exported. Available since API v19.


setIndexProcessed

public void setIndexProcessed(long indexProcessed)

getStatsProcessed

public long getStatsProcessed()
Number of Table and Partitions Statistics Imported/Exported. Available since API v19.


setStatsProcessed

public void setStatsProcessed(long statsProcessed)

getDbExpected

public long getDbExpected()
Number of Db's Expected. Available since API v19.


setDbExpected

public void setDbExpected(long dbExpected)

getTableExpected

public long getTableExpected()
Number of Tables Expected. Available since API v19.


setTableExpected

public void setTableExpected(long tableExpected)

getPartitionExpected

public long getPartitionExpected()
Number of Partitions Expected. Available since API v19.


setPartitionExpected

public void setPartitionExpected(long partitionExpected)

getFunctionExpected

public long getFunctionExpected()
Number of Functions Expected. Available since API v19.


setFunctionExpected

public void setFunctionExpected(long functionExpected)

getIndexExpected

public long getIndexExpected()
Number of Indexes Expected. Available since API v19.


setIndexExpected

public void setIndexExpected(long indexExpected)

getStatsExpected

public long getStatsExpected()
Number of Table and Partition Statistics Expected. Available since API v19.


setStatsExpected

public void setStatsExpected(long statsExpected)

equals

public boolean equals(Object o)
Overrides:
equals in class Object

hashCode

public int hashCode()
Overrides:
hashCode in class Object

toString

public String toString()
Overrides:
toString in class Object


Copyright © Cloudera, Inc. Released under Apache License, Version 2.0.