Package org.apache.polaris.persistence.nosql.metastore.committers

Interface CatalogChangeCommitter<RESULT>

Functional Interface:
This is a functional interface and can therefore be used as the assignment target for a lambda expression or method reference.
@FunctionalInterface public interface CatalogChangeCommitter<RESULT>

  • Method Summary

    Modifier and Type
    Method
    Description
    @NonNull ChangeResult<RESULT>
    change(@NonNull org.apache.polaris.persistence.nosql.api.commit.CommitterState<org.apache.polaris.persistence.nosql.coretypes.catalog.CatalogStateObj,RESULT> state, @NonNull org.apache.polaris.persistence.nosql.coretypes.catalog.CatalogStateObj.Builder ref, @NonNull org.apache.polaris.persistence.nosql.api.index.UpdatableIndex<org.apache.polaris.persistence.nosql.api.obj.ObjRef> byName, @NonNull org.apache.polaris.persistence.nosql.api.index.UpdatableIndex<org.apache.polaris.persistence.nosql.api.index.IndexKey> byId, @NonNull org.apache.polaris.persistence.nosql.api.index.UpdatableIndex<org.apache.polaris.persistence.nosql.coretypes.changes.Change> changes, @NonNull org.apache.polaris.persistence.nosql.api.index.UpdatableIndex<org.apache.polaris.persistence.nosql.coretypes.catalog.EntityIdSet> locations)
     

  • Method Details

    • change

      @NonNull ChangeResult<RESULT> change(@NonNull org.apache.polaris.persistence.nosql.api.commit.CommitterState<org.apache.polaris.persistence.nosql.coretypes.catalog.CatalogStateObj,RESULT> state, @NonNull org.apache.polaris.persistence.nosql.coretypes.catalog.CatalogStateObj.Builder ref, @NonNull org.apache.polaris.persistence.nosql.api.index.UpdatableIndex<org.apache.polaris.persistence.nosql.api.obj.ObjRef> byName, @NonNull org.apache.polaris.persistence.nosql.api.index.UpdatableIndex<org.apache.polaris.persistence.nosql.api.index.IndexKey> byId, @NonNull org.apache.polaris.persistence.nosql.api.index.UpdatableIndex<org.apache.polaris.persistence.nosql.coretypes.changes.Change> changes, @NonNull org.apache.polaris.persistence.nosql.api.index.UpdatableIndex<org.apache.polaris.persistence.nosql.coretypes.catalog.EntityIdSet> locations) throws org.apache.polaris.persistence.nosql.api.commit.CommitException
      Throws:
      org.apache.polaris.persistence.nosql.api.commit.CommitException