THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block | ||
---|---|---|
| ||
public void createDatabase(Database database) throws InvalidObjectException, AlreadyExistsException, MetaException, TException { client.createDatabase(database); } public void createTable(Table table) throws AlreadyExistsException, InvalidObjectException, MetaException, NoSuchObjectException, TException { client.createTable(table); } public Partition add_partition(Partition partition) throws InvalidObjectException, AlreadyExistsException, MetaException, TException { return client.add_partition(partition); } public int add_partitions(List<Partition> partitionList) throws InvalidObjectException, AlreadyExistsException, MetaException, TException { return client.add_partitions(partitionList); } |
HiveShimLoader
we add a shim loader to load HiveShim.
- Added interface
HiveShim
to define methods that need shimming. - Implemented
HiveShimV1
andHiveShimV2
for 1.x and 2.x respectively. - Added
HiveShimLoader
to automatically load HiveShim.
hudi on flink refactor
StreamWriteOperatorCoordinator#syncHive needs to rewrite in order to fit the new framework.