Skip to content

Conversation

@smiklosovic
Copy link

No description provided.


SSTable.Owner useOwner;

if (this.owner != null && this.owner.compressionDictionaryManager() != null && compressionDictionary != null)
Copy link
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

CQLSSTableWriter uses such a flow that owner passed to this method is null. Then compression manager will be null (logic in SSTableTxnWriter.create) and we do not want that.

So when compression dictionary is set from outside, we need cfs as owner of that as well so we pass that owner to create method instead.

}

IDictionaryCompressor compressor = (IDictionaryCompressor) compressionParams.getSstableCompressor();
if (!compressor.canConsumeDictionary(compressionDictionary))
Copy link
Author

Choose a reason for hiding this comment

The reason will be displayed to describe this comment to others. Learn more.

I can not actually test this one because the check in that method is based on kinds and there is just one ... it is an enum. There is nothing else to set but that. We do not have two dictionary compressors of two different kinds yet.

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment

Labels

None yet

Projects

None yet

Development

Successfully merging this pull request may close these issues.

1 participant