// LOAD SAMPLE WORKLOAD

            Filter filter =  new ProcedureNameFilter(false)

                    .include(this.origProc.getName())

                    .attach(new NoAbortFilter())

            File workloadFile = this.getWorkloadFile(ProjectType.SMALLBANK);

            workloads[0] = new Workload(catalogContext.catalog).load(workloadFile, catalogContext.database, filter);

            File tempFile = FileUtil.getTempFile("workload", true);

            workloads[0].save(tempFile, catalogContext.database);

            assertTrue(tempFile.exists());

                    .attach(new ProcParameterValueFilter().include(1, new Integer(5))) // D_ID

                    // .attach(new ProcParameterArraySizeFilter(CatalogUtil.getArrayProcParameters(catalog_proc).get(0), 10, ExpressionType.COMPARE_EQUAL))

                    .attach(new BasePartitionTxnFilter(p_estimator, BASE_PARTITION))

                    .attach(new MultiPartitionTxnFilter(p_estimator, false))

            workload.load(file, catalogContext.database, filter);

           

            // Make a copy that doesn't have the first TransactionTrace

            Workload clone = new Workload(catalogContext.catalog, new Filter() {

                private boolean first = true;

        if (workload == null) {

            workload_file = this.getWorkloadFile(ProjectType.TPCC);

            workload = new Workload(catalog);

           

            assert(workload.getTransactionCount() > 0) : "No transaction loaded from workload";

            assertEquals(WORKLOAD_XACT_LIMIT, workload.getTransactionCount());

        }

        assertNotNull(workload_file);

    }

        if (workload == null) {

            File file = this.getWorkloadFile(ProjectType.TPCC);

            workload = new Workload(catalog);

            Filter filter = new ProcedureNameFilter(false).include(TARGET_PROCEDURE.getSimpleName())

            workload.load(file, catalog_db, filter);

        }

       

        this.catalog_proc = this.getProcedure(TARGET_PROCEDURE);

        this.fset = new FeatureSet();

//                    .attach(new ProcParameterArraySizeFilter(CatalogUtil.getArrayProcParameters(catalog_proc).get(0), 10, ExpressionType.COMPARE_EQUAL))

//                    .attach(new BasePartitionTxnFilter(p_estimator, BASE_PARTITION))

//                    .attach(new MultiPartitionTxnFilter(p_estimator))

            workload.load(file, catalog_db, filter);

            assert(workload.getTransactionCount() > 0);

           

            // Now extract the FeatureSet that we will use in our tests

            Map<Procedure, FeatureSet> fsets = new FeatureExtractor(catalogContext, p_estimator).calculate(workload);

           

            // All Multi-Partition Txn Workload

            ProcedureNameFilter multi_filter = new ProcedureNameFilter(false);

            multi_filter.include(MULTIPARTITION_PROCEDURES);

            multip_workload = new Workload(catalog);

            ((Workload)multip_workload).load(f, catalog_db, multi_filter);

            assert(multip_workload.getTransactionCount() > 0);

            // All Single-Partition Txn Workload

            ProcedureNameFilter single_filter = new ProcedureNameFilter(false);

            single_filter.include(SINGLEPARTITION_PROCEDURES);

            singlep_workload = new Workload(catalog);

            ((Workload)singlep_workload).load(f, catalog_db, single_filter);

            assert(singlep_workload.getTransactionCount() > 0);

           

            // Workload Statistics

            // Where is your god now???

            Filter filter = new ProcedureNameFilter(false)

                    .include(TARGET_PROCEDURE.getSimpleName())

                    .attach(new BasePartitionTxnFilter(p_estimator, BASE_PARTITION))

            workload.load(file, catalogContext.database, filter);

            assert(workload.getTransactionCount() > 0);

           

            markov = new MarkovGraph(catalog_proc).initialize();

            for (TransactionTrace txn_trace : workload.getTransactions()) {

            // Where is your god now???

            Filter filter = new ProcedureNameFilter(false).include(TARGET_PROCEDURE.getSimpleName());

            filter.attach(new BasePartitionTxnFilter(p_estimator, BASE_PARTITION))

            // .attach(new MultiPartitionTxnFilter(p_estimator))

            workload.load(file, catalogContext.database, filter);

            // assertEquals(WORKLOAD_XACT_LIMIT, workload.getTransactionCount());

            // for (TransactionTrace xact : workload.getTransactions()) {

            // System.err.println(xact + ": " + p_estimator.getAllPartitions(xact));

            File file = this.getWorkloadFile(ProjectType.TPCC);

            workload = new Workload(catalog);

            Filter filter = new ProcedureNameFilter(false)

                    .include(TARGET_PROCEDURE.getSimpleName())

            workload.load(file, catalog_db, filter);

            assert(workload.getTransactionCount() > 0);

           

            // Now extract the FeatureSet that we will use in our tests

            Map<Procedure, FeatureSet> fsets = new FeatureExtractor(catalogContext, p_estimator).calculate(workload);