Fix the name of avro schema file in Test
Fixed the name of avro schema file in Test Signed-off-by: Yishuang Lu <luystu@gmail.com>
This commit is contained in:
committed by
vinoth chandar
parent
460e24e84b
commit
faf93b6340
@@ -47,7 +47,7 @@ import org.apache.avro.io.DecoderFactory;
|
|||||||
public class SchemaTestUtil {
|
public class SchemaTestUtil {
|
||||||
|
|
||||||
public static Schema getSimpleSchema() throws IOException {
|
public static Schema getSimpleSchema() throws IOException {
|
||||||
return new Schema.Parser().parse(SchemaTestUtil.class.getResourceAsStream("/simple-test.avro"));
|
return new Schema.Parser().parse(SchemaTestUtil.class.getResourceAsStream("/simple-test.avsc"));
|
||||||
}
|
}
|
||||||
|
|
||||||
public static List<IndexedRecord> generateTestRecords(int from, int limit) throws IOException, URISyntaxException {
|
public static List<IndexedRecord> generateTestRecords(int from, int limit) throws IOException, URISyntaxException {
|
||||||
@@ -163,7 +163,7 @@ public class SchemaTestUtil {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public static Schema getEvolvedSchema() throws IOException {
|
public static Schema getEvolvedSchema() throws IOException {
|
||||||
return new Schema.Parser().parse(SchemaTestUtil.class.getResourceAsStream("/simple-test-evolved.avro"));
|
return new Schema.Parser().parse(SchemaTestUtil.class.getResourceAsStream("/simple-test-evolved.avsc"));
|
||||||
}
|
}
|
||||||
|
|
||||||
public static List<IndexedRecord> generateEvolvedTestRecords(int from, int limit)
|
public static List<IndexedRecord> generateEvolvedTestRecords(int from, int limit)
|
||||||
@@ -172,7 +172,7 @@ public class SchemaTestUtil {
|
|||||||
}
|
}
|
||||||
|
|
||||||
public static Schema getComplexEvolvedSchema() throws IOException {
|
public static Schema getComplexEvolvedSchema() throws IOException {
|
||||||
return new Schema.Parser().parse(SchemaTestUtil.class.getResourceAsStream("/complex-test-evolved.avro"));
|
return new Schema.Parser().parse(SchemaTestUtil.class.getResourceAsStream("/complex-test-evolved.avsc"));
|
||||||
}
|
}
|
||||||
|
|
||||||
public static GenericRecord generateAvroRecordFromJson(Schema schema, int recordNumber, String commitTime,
|
public static GenericRecord generateAvroRecordFromJson(Schema schema, int recordNumber, String commitTime,
|
||||||
|
|||||||
@@ -176,7 +176,7 @@ public class HoodieInputFormatTest {
|
|||||||
//TODO enable this after enabling predicate pushdown
|
//TODO enable this after enabling predicate pushdown
|
||||||
public void testPredicatePushDown() throws IOException {
|
public void testPredicatePushDown() throws IOException {
|
||||||
// initial commit
|
// initial commit
|
||||||
Schema schema = InputFormatTestUtil.readSchema("/sample1.avro");
|
Schema schema = InputFormatTestUtil.readSchema("/sample1.avsc");
|
||||||
String commit1 = "20160628071126";
|
String commit1 = "20160628071126";
|
||||||
File partitionDir = InputFormatTestUtil.prepareParquetDataset(basePath, schema, 1, 10, commit1);
|
File partitionDir = InputFormatTestUtil.prepareParquetDataset(basePath, schema, 1, 10, commit1);
|
||||||
InputFormatTestUtil.commit(basePath, commit1);
|
InputFormatTestUtil.commit(basePath, commit1);
|
||||||
|
|||||||
2
pom.xml
2
pom.xml
@@ -288,7 +288,7 @@
|
|||||||
<exclude>**/*.sh</exclude>
|
<exclude>**/*.sh</exclude>
|
||||||
<exclude>**/*.log</exclude>
|
<exclude>**/*.log</exclude>
|
||||||
<exclude>**/dependency-reduced-pom.xml</exclude>
|
<exclude>**/dependency-reduced-pom.xml</exclude>
|
||||||
<exclude>**/test/resources/*.avro</exclude>
|
<exclude>**/test/resources/*.avsc</exclude>
|
||||||
<exclude>**/test/resources/*.data</exclude>
|
<exclude>**/test/resources/*.data</exclude>
|
||||||
<exclude>**/test/resources/*.schema</exclude>
|
<exclude>**/test/resources/*.schema</exclude>
|
||||||
<exclude>**/test/resources/*.csv</exclude>
|
<exclude>**/test/resources/*.csv</exclude>
|
||||||
|
|||||||
Reference in New Issue
Block a user