importPackage(Packages.com.collective.celos.ci.testing.fixtures.compare);

var tableScript = fixFile("CREATE TABLE wordcount PARTITIONED BY (year INT)" +
                        "  ROW FORMAT SERDE 'org.apache.hadoop.hive.serde2.avro.AvroSerDe'" +
                        "  WITH SERDEPROPERTIES ('avro.schema.url'='${SANDBOX}/schema/wordcount.avsc')" +
                        "  STORED as INPUTFORMAT 'org.apache.hadoop.hive.ql.io.avro.AvroContainerInputFormat'" +
                        "  OUTPUTFORMAT 'org.apache.hadoop.hive.ql.io.avro.AvroContainerOutputFormat'");

var resTableScript = fixFile("CREATE TABLE result (word string, number int)");

addTestCase({
    name: "Hive wordcount test case 1",
    sampleTimeStart: "2013-12-20T16:00Z",
    sampleTimeEnd: "2013-12-20T16:00Z",
    inputs: [
        hdfsInput(fixDirFromResource("test-1/input/wordcount"), "input/wordcount"),
        hdfsInput(fixDirFromResource("test-1/schema"), "/schema"),
        hiveInput("celosdb", "wordcount", tableScript, fixTableFromResource("test-1/input/tsv/wordcount.tsv")),
        hiveInput("celosdb", "result", resTableScript)
    ],
    outputs: [
        ci.fixTableCompare(
            ci.fixTableFromResource("test-1/output/tsv/result.tsv"),
            ci.hiveTable("celosdb", "result")
        )
    ]
});

@@ -1,79 +1,4 @@
-importPackage(Packages.com.collective.celos.ci.testing.fixtures.compare);%0A%0A
 var 
@@ -3,32 +3,35 @@
 r tableScript = 
+ci.
 fixFile(%22CREATE 
@@ -99,16 +99,18 @@
         
+  
 %22  ROW F
@@ -167,24 +167,26 @@
 roSerDe'%22 +%0A
+  
             
@@ -303,16 +303,18 @@
         
+  
 %22  STORE
@@ -418,16 +418,18 @@
         
+ 
+ 
 %22  OUTPU
@@ -523,16 +523,19 @@
 cript = 
+ci.
 fixFile(
@@ -585,16 +585,19 @@
 nt)%22);%0A%0A
+ci.
 addTestC
@@ -738,32 +738,35 @@
 puts: %5B%0A        
+ci.
 hdfsInput(fixDir
@@ -751,32 +751,35 @@
    ci.hdfsInput(
+ci.
 fixDirFromResour
@@ -836,16 +836,19 @@
         
+ci.
 hdfsInpu
@@ -849,16 +849,19 @@
 fsInput(
+ci.
 fixDirFr
@@ -901,32 +901,35 @@
 hema%22),%0A        
+ci.
 hiveInput(%22celos
@@ -959,16 +959,19 @@
 Script, 
+ci.
 fixTable
@@ -1027,16 +1027,19 @@
         
+ci.
 hiveInpu

Use ci prefix for all CCI API calls.