Details
-
Type:
Bug
-
Status: Open
-
Priority:
Major
-
Resolution: Unresolved
-
Affects Version/s: 0.16.0
-
Fix Version/s: None
-
Component/s: HBase Module
-
Labels:None
Description
The following doesn't work:
DatasetDescriptor.Builder builder = new DatasetDescriptor.Builder(); builder.partitionStrategy(getClass().getClassLoader(). getResourceAsStream("partition_strategy/MessagePartitionStrategy.json")); builder.schema(Message.getClassSchema()); Dataset<Message> messages = Datasets.create( "dataset:hbase:" + zookeeperQuorum + "/messages", builder.build(), Message.class);
it fails with an exception:
org.kitesdk.data.ValidationException: Fields are key-mapped without identity partitioners: id
This works if the mapping is embedded in the fields, but not if it's embedded in the top-level of the schema.