public class org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds extends org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$CoreContext
{
java.lang.String dbName;
java.lang.String tblName;
public void <init>()
{
org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds v;
v := @this: org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds;
specialinvoke v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$CoreContext: void <init>()>();
v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds: java.lang.String dbName> = "test_db";
v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds: java.lang.String tblName> = "tmp_table";
return;
}
public void allocateTableWriteIds(org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState) throws org.apache.thrift.TException
{
java.util.List v;
org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds v;
java.lang.String v, v;
org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState v;
org.apache.hadoop.hive.metastore.tools.HMSClient v;
v := @this: org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds;
v := @parameter: org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState;
v = v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState: org.apache.hadoop.hive.metastore.tools.HMSClient client>;
v = v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds: java.lang.String dbName>;
v = v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds: java.lang.String tblName>;
v = v.<org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$ThreadState: java.util.List openTxns>;
virtualinvoke v.<org.apache.hadoop.hive.metastore.tools.HMSClient: boolean allocateTableWriteIds(java.lang.String,java.lang.String,java.util.List)>(v, v, v);
return;
}
private static long executeOpenTxnAndGetTxnId(org.apache.hadoop.hive.metastore.tools.HMSClient)
{
org.apache.hadoop.hive.metastore.tools.Util$ThrowingSupplier v;
java.lang.Object v;
long v;
org.apache.hadoop.hive.metastore.tools.HMSClient v;
v := @parameter: org.apache.hadoop.hive.metastore.tools.HMSClient;
v = staticinvoke <org.apache.hadoop.hive.metastore.tools.ACIDBenchmarks$TestAllocateTableWriteIds$lambda_executeOpenTxnAndGetTxnId_0__1: org.apache.hadoop.hive.metastore.tools.Util$ThrowingSupplier bootstrap$(org.apache.hadoop.hive.metastore.tools.HMSClient)>(v);
v = staticinvoke <org.apache.hadoop.hive.metastore.tools.Util: java.lang.Object throwingSupplierWrapper(org.apache.hadoop.hive.metastore.tools.Util$ThrowingSupplier)>(v);
v = virtualinvoke v.<java.lang.Long: long longValue()>();
return v;
}
}