Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
	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 and HiveShimV2 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.

hudi on spark refactor