-
Notifications
You must be signed in to change notification settings - Fork 11
New issue
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
Issue 1352 - One S3 state store for all tables #1379
Conversation
…state-store-for-all-tables # Conflicts: # java/statestore/src/main/java/sleeper/statestore/s3/S3PartitionStore.java # java/statestore/src/main/java/sleeper/statestore/s3/S3StateStoreCreator.java # java/statestore/src/test/java/sleeper/statestore/s3/S3StateStoreIT.java
…es' into 1352-s3-state-store-for-all-tables
…state-store-for-all-tables # Conflicts: # java/statestore/src/main/java/sleeper/statestore/s3/S3PartitionStore.java
…state-store-for-all-tables
…state-store-for-all-tables # Conflicts: # java/cdk/src/main/java/sleeper/cdk/stack/TableStack.java
java/statestore/src/main/java/sleeper/statestore/s3/S3PartitionStore.java
Outdated
Show resolved
Hide resolved
…state-store-for-all-tables # Conflicts: # java/cdk/src/main/java/sleeper/cdk/stack/TableStack.java # java/statestore/src/main/java/sleeper/statestore/s3/S3FileInfoStore.java # java/statestore/src/main/java/sleeper/statestore/s3/S3PartitionStore.java # java/statestore/src/main/java/sleeper/statestore/s3/S3RevisionUtils.java
this.keySerDe = new KeySerDe(rowKeyTypes); | ||
this.fileSchema = initialiseFileInfoSchema(); | ||
this.conf = builder.conf; | ||
this.s3RevisionUtils = new S3RevisionUtils(dynamoDB, dynamoRevisionIdTable); | ||
this.s3RevisionUtils = new S3RevisionUtils(builder.dynamoDB, builder.dynamoRevisionIdTable, builder.sleeperTable); |
There was a problem hiding this comment.
Choose a reason for hiding this comment
The reason will be displayed to describe this comment to others. Learn more.
sleeperTable is set on the builder and then used to create this S3RevisionUtils. The s3Path variable is created outside of this class and also contains sleeperTable. It might be cleaner to create s3Path from sleeperTable inside this constructor, as sleeperTable is effectively being passed in twice?
Make sure you have checked all steps below.
Issue
PR"
Tests
Documentation
separate issue for that below.
NOTICES file to reflect this.