Skip to content
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

SAMZA-1381: Create Utility Class for interacting with Azure Table Storage #258

Closed
wants to merge 15 commits into from

Conversation

PawasChhokra
Copy link
Contributor

@PawasChhokra PawasChhokra commented Aug 3, 2017

PR 1: AzureClient + AzureConfig
PR 2: LeaseBlobManager
PR 3: BlobUtils + JobModelBundle
PR 4: TableUtils + ProcessorEntity (Current PR)

@PawasChhokra PawasChhokra force-pushed the TableUtils branch 2 times, most recently from 15dd932 to bfc9740 Compare August 7, 2017 21:48
Copy link
Contributor

@navina navina left a comment

Choose a reason for hiding this comment

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

looks good, except for a few nits/comments.

Please rebase once the previous PR is committed. Thanks!

* @return Iterable list of processor entities.
*/
public Iterable<ProcessorEntity> getEntitiesWithPartition(String partitionKey) {
String partitionFilter = TableQuery.generateFilterCondition(this.PARTITION_KEY, TableQuery.QueryComparisons.EQUAL, partitionKey);
Copy link
Contributor

Choose a reason for hiding this comment

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

nit: s/this.PARTITION_KEY/PARTITION_KEY/

Copy link
Contributor Author

Choose a reason for hiding this comment

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

Done.

public Iterable<ProcessorEntity> getEntitiesWithPartition(String partitionKey) {
String partitionFilter = TableQuery.generateFilterCondition(this.PARTITION_KEY, TableQuery.QueryComparisons.EQUAL, partitionKey);
TableQuery<ProcessorEntity> partitionQuery = TableQuery.from(ProcessorEntity.class).where(partitionFilter);
return table.execute(partitionQuery);
Copy link
Contributor

Choose a reason for hiding this comment

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

Any exception handling required here?

Copy link
Contributor Author

Choose a reason for hiding this comment

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

None of the internal methods used throw an exception. Hence, not required.

@asfgit asfgit closed this in bf4c761 Aug 8, 2017
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
None yet
Projects
None yet
2 participants