signature:
public class SettingsURIMatcher { /** * / * ( non - Javadoc )
 * @ see org . commonjava . indy . dotmaven . util . URIMatcher # getStoreKey ( ) */
@ Override public StoreKey getStoreKey ( ) { } }

implementation: final StoreType type = getStoreType ( ) ; if ( type == null ) { return null ; } final String name = matcher . group ( NAME_GRP ) ; if ( isEmpty ( name ) ) { return null ; } return new StoreKey ( type , name ) ;


signature:
public class KeycloakConfig { /** * Set system properties for keycloak to use when filtering keycloak . json . . . */
public KeycloakConfig setSystemProperties ( ) { } }

implementation: if ( ! isEnabled ( ) ) { return this ; } final Properties properties = System . getProperties ( ) ; properties . setProperty ( KEYCLOAK_REALM , getRealm ( ) ) ; properties . setProperty ( KEYCLOAK_URL , getUrl ( ) ) ; if ( getServerResource ( ) != null ) { properties . setProperty ( KEYCLOAK_SERVER_RESOURCE , getServerResource ( ) ) ; } if ( getServerCredentialSecret ( ) != null ) { properties . setProperty ( KEYCLOAK_SERVER_CREDENTIAL_SECRET , getServerCredentialSecret ( ) ) ; } if ( getRealmPublicKey ( ) != null ) { properties . setProperty ( KEYCLOAK_REALM_PUBLIC_KEY , getRealmPublicKey ( ) ) ; } System . setProperties ( properties ) ; return this ;


signature:
public class IndyLifecycleManager { /** * Start sequence is :
 * < ul >
 * < li > Start all { @ link BootupAction } instances , with highest priority executing first . < / li >
 * < li > Run all { @ link MigrationAction } instances , with highest priority executing first . < / li >
 * < li > Run all { @ link StartupAction } instances , with highest priority executing first . < / li >
 * < / ul >
 * @ throws IndyLifecycleException */
public void start ( ) throws IndyLifecycleException { } }

implementation: logger . info ( "\n\n\n\n\n STARTING Indy\n    Version: {}\n    Built-By: {}\n    Commit-ID: {}\n    Built-On: {}\n\n\n\n\n" , versioning . getVersion ( ) , versioning . getBuilder ( ) , versioning . getCommitId ( ) , versioning . getTimestamp ( ) ) ; runBootupActions ( ) ; runMigrationActions ( ) ; runStartupActions ( ) ; logger . info ( "...done. Indy is ready to run." ) ; if ( lifecycleEvents == null ) { logger . error ( "Cannot fire IndyLifecycleEvent::started! Event manager is null. Did you construct this {} instance by hand?" , getClass ( ) . getSimpleName ( ) ) ; } else { lifecycleEvents . fireStarted ( ) ; }


signature:
public class IndyLifecycleManager { /** * Run all { @ link ShutdownAction } instances , with highest priority executing first .
 * @ throws IndyLifecycleException */
public void stop ( ) throws IndyLifecycleException { } }

implementation: System . out . println ( "Shutting down Indy" ) ; logger . info ( "\n\n\n\n\n SHUTTING DOWN Indy\n    Version: {}\n    Built-By: {}\n    Commit-ID: {}\n    Built-On: {}\n\n\n\n\n" , versioning . getVersion ( ) , versioning . getBuilder ( ) , versioning . getCommitId ( ) , versioning . getTimestamp ( ) ) ; runShutdownActions ( ) ; logger . info ( "...done. Indy is ready to shut down." ) ;


signature:
public class CacheProducer { /** * Get a BasicCache instance . If the remote cache is enabled , it will match the named with remote . patterns .
 * If matched , it will create / return a RemoteCache . If not matched , an embedded cache will be created / returned to the caller . */
public synchronized < K , V > BasicCacheHandle < K , V > getBasicCache ( String named ) { } }

implementation: BasicCacheHandle handle = caches . computeIfAbsent ( named , ( k ) -> { if ( remoteConfiguration . isEnabled ( ) && remoteConfiguration . isRemoteCache ( k ) ) { RemoteCache < K , V > cache = null ; try { cache = remoteCacheManager . getCache ( k ) ; if ( cache == null ) { logger . warn ( "Can not get remote cache, name: {}" , k ) ; return null ; } } catch ( Exception e ) { logger . warn ( "Get remote cache failed" , e ) ; return null ; } logger . info ( "Get remote cache, name: {}" , k ) ; return new RemoteCacheHandle ( k , cache , metricsManager , getCacheMetricPrefix ( k ) ) ;


signature:
public class FileRangeHandler { /** * Returns an ArrayList of File Ranges for the given stream .
 * @ return an ArrayList of File Ranges for the given stream .
 * @ throws SAXException
 * @ throws ParserConfigurationException
 * @ throws IOException */
protected static ArrayList < FileRange > getFileRanges ( InputStream streamRef ) throws ParserConfigurationException , SAXException , IOException { } }

implementation: SAXParser saxParser = Utility . getSAXParser ( ) ; FileRangeHandler handler = new FileRangeHandler ( ) ; saxParser . parse ( streamRef , handler ) ; return handler . fileRanges ;


signature:
public class QueueMessageHandler { /** * Populates CloudQueueMessage objects from the XMLStreamReader ; the reader must be at the Start element of
 * QueuesElement .
 * @ param stream
 * The < code > InputStream < / code > object to deserialize from .
 * @ param shouldEncodeMessage
 * A flag indicating whether messages should be base - 64 encoded .
 * @ return An < code > ArrayList < / code > of { @ link CloudQueueMessage } from the
 * stream .
 * @ throws IOException
 * @ throws SAXException
 * @ throws ParserConfigurationException */
public static ArrayList < CloudQueueMessage > readMessages ( final InputStream stream , final boolean shouldEncodeMessage ) throws SAXException , IOException , ParserConfigurationException { } }

implementation: SAXParser saxParser = Utility . getSAXParser ( ) ; QueueMessageHandler handler = new QueueMessageHandler ( shouldEncodeMessage ) ; saxParser . parse ( stream , handler ) ; return handler . messages ;


signature:
public class CloudTable { /** * Creates the table in the storage service , using the specified { @ link TableRequestOptions } and
 * { @ link OperationContext } .
 * This method invokes the < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd135729 . aspx " > Create Table < / a >
 * REST API to create the specified table , using the Table service endpoint and storage account credentials of this
 * instance .
 * Use the { @ link TableRequestOptions } to override execution options such as the timeout or retry policy for the
 * operation .
 * @ param options
 * A { @ link TableRequestOptions } object that specifies execution options such as retry policy and timeout
 * settings for the operation . Specify < code > null < / code > to use the request options specified on the
 * { @ link CloudTableClient } .
 * @ param opContext
 * An { @ link OperationContext } object for tracking the current operation . Specify < code > null < / code > to
 * safely ignore operation context .
 * @ throws StorageException
 * If an error occurs accessing the storage service , or because the table cannot be
 * created , or already exists . */
@ DoesServiceRequest public void create ( TableRequestOptions options , OperationContext opContext ) throws StorageException { } }

implementation: if ( opContext == null ) { opContext = new OperationContext ( ) ; } opContext . initialize ( ) ; options = TableRequestOptions . populateAndApplyDefaults ( options , this . tableServiceClient ) ; Utility . assertNotNullOrEmpty ( "tableName" , this . name ) ; final DynamicTableEntity tableEntry = new DynamicTableEntity ( ) ; tableEntry . getProperties ( ) . put ( TableConstants . TABLE_NAME , new EntityProperty ( this . name ) ) ; TableOperation . insert ( tableEntry ) . execute ( this . tableServiceClient , TableConstants . TABLES_SERVICE_TABLES_NAME , options , opContext ) ;


signature:
public class CloudTable { /** * Creates the table in the storage service with the specified request options and operation context , if it does not
 * already exist .
 * @ param options
 * A { @ link TableRequestOptions } object that specifies any additional options for the request . Specifying
 * < code > null < / code > will use the default request options from the associated service client (
 * { @ link CloudTableClient } ) .
 * @ param opContext
 * An { @ link OperationContext } object that represents the context for the current operation . This object
 * is used to track requests to the storage service , and to provide additional runtime information about
 * the operation .
 * @ return < code > true < / code > if the table did not already exist and was created ; otherwise < code > false < / code > .
 * @ throws StorageException
 * If a storage service error occurred during the operation . */
@ DoesServiceRequest public boolean createIfNotExists ( TableRequestOptions options , OperationContext opContext ) throws StorageException { } }

implementation: options = TableRequestOptions . populateAndApplyDefaults ( options , this . tableServiceClient ) ; boolean exists = this . exists ( true , options , opContext ) ; if ( exists ) { return false ; } else { try { this . create ( options , opContext ) ; return true ; } catch ( StorageException e ) { if ( e . getHttpStatusCode ( ) == HttpURLConnection . HTTP_CONFLICT && StorageErrorCodeStrings . TABLE_ALREADY_EXISTS . equals ( e . getErrorCode ( ) ) ) { return false ; } else { throw e ; } } }


signature:
public class CloudTable { /** * Deletes the table from the storage service , using the specified request options and operation context .
 * @ param options
 * A { @ link TableRequestOptions } object that specifies any additional options for the request . Specifying
 * < code > null < / code > will use the default request options from the associated service client (
 * { @ link CloudTableClient } ) .
 * @ param opContext
 * An { @ link OperationContext } object that represents the context for the current operation . This object
 * is used to track requests to the storage service , and to provide additional runtime information about
 * the operation .
 * @ throws StorageException
 * If a storage service error occurred during the operation . */
@ DoesServiceRequest public void delete ( TableRequestOptions options , OperationContext opContext ) throws StorageException { } }

implementation: if ( opContext == null ) { opContext = new OperationContext ( ) ; } opContext . initialize ( ) ; options = TableRequestOptions . populateAndApplyDefaults ( options , this . tableServiceClient ) ; Utility . assertNotNullOrEmpty ( "tableName" , this . name ) ; final DynamicTableEntity tableEntry = new DynamicTableEntity ( ) ; tableEntry . getProperties ( ) . put ( TableConstants . TABLE_NAME , new EntityProperty ( this . name ) ) ; TableOperation deleteOp = new TableOperation ( tableEntry , TableOperationType . DELETE ) ; deleteOp . execute ( this . tableServiceClient , TableConstants . TABLES_SERVICE_TABLES_NAME , options , opContext ) ;


signature:
public class CloudTable { /** * Deletes the table from the storage service using the specified request options and operation context , if it
 * exists .
 * @ param options
 * A { @ link TableRequestOptions } object that specifies any additional options for the request . Specifying
 * < code > null < / code > will use the default request options from the associated service client (
 * { @ link CloudTableClient } ) .
 * @ param opContext
 * An { @ link OperationContext } object that represents the context for the current operation . This object
 * is used to track requests to the storage service , and to provide additional runtime information about
 * the operation .
 * @ return A value of < code > true < / code > if the table existed in the storage service and has been deleted , otherwise
 * < code > false < / code > .
 * @ throws StorageException
 * If a storage service error occurred during the operation . */
@ DoesServiceRequest public boolean deleteIfExists ( TableRequestOptions options , OperationContext opContext ) throws StorageException { } }

implementation: options = TableRequestOptions . populateAndApplyDefaults ( options , this . tableServiceClient ) ; if ( this . exists ( true , options , opContext ) ) { try { this . delete ( options , opContext ) ; } catch ( StorageException ex ) { if ( ex . getHttpStatusCode ( ) == HttpURLConnection . HTTP_NOT_FOUND && StorageErrorCodeStrings . RESOURCE_NOT_FOUND . equals ( ex . getErrorCode ( ) ) ) { return false ; } else { throw ex ; } } return true ; } else { return false ; }


signature:
public class CloudTable { /** * Executes the specified batch operation on a table as an atomic operation . A batch operation may contain up to 100
 * individual table operations , with the requirement that each operation entity must have same partition key . Only
 * one retrieve operation is allowed per batch . Note that the total payload of a batch operation is limited to 4MB .
 * This method invokes an < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd894038 . aspx " > Entity Group
 * Transaction < / a > on the REST API to execute the specified batch operation on the table as an atomic unit , using
 * the Table service endpoint and storage account credentials of this instance .
 * @ param batch
 * The { @ link TableBatchOperation } object representing the operations to execute on the table .
 * @ return
 * A < code > java . util . ArrayList < / code > of { @ link TableResult } that contains the results , in order , of
 * each { @ link TableOperation } in the { @ link TableBatchOperation } on the named table .
 * @ throws StorageException
 * if an error occurs accessing the storage service , or the operation fails . */
@ DoesServiceRequest public ArrayList < TableResult > execute ( final TableBatchOperation batch ) throws StorageException { } }

implementation:
return this . execute ( batch , null /* options */
, null /* opContext */
) ;


signature:
public class CloudTable { /** * Executes the specified batch operation on a table as an atomic operation , using the specified
 * { @ link TableRequestOptions } and { @ link OperationContext } . A batch operation may contain up to 100 individual
 * table operations , with the requirement that each operation entity must have same partition key . Only one retrieve
 * operation is allowed per batch . Note that the total payload of a batch operation is limited to 4MB .
 * This method invokes an < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd894038 . aspx " > Entity Group
 * Transaction < / a > on the REST API to execute the specified batch operation on the table as an atomic unit , using
 * the Table service endpoint and storage account credentials of this instance .
 * Use the { @ link TableRequestOptions } to override execution options such as the timeout or retry policy for the
 * operation .
 * @ param batch
 * The { @ link TableBatchOperation } object representing the operations to execute on the table .
 * @ param options
 * A { @ link TableRequestOptions } object that specifies execution options such as retry policy and timeout
 * settings for the operation . Specify < code > null < / code > to use the request options specified on the
 * { @ link CloudTableClient } .
 * @ param opContext
 * An { @ link OperationContext } object for tracking the current operation . Specify < code > null < / code > to
 * safely ignore operation context .
 * @ return
 * A < code > java . util . ArrayList < / code > of { @ link TableResult } that contains the results , in order , of
 * each { @ link TableOperation } in the { @ link TableBatchOperation } on the named table .
 * @ throws StorageException
 * if an error occurs accessing the storage service , or the operation fails . */
@ DoesServiceRequest public ArrayList < TableResult > execute ( final TableBatchOperation batch , TableRequestOptions options , OperationContext opContext ) throws StorageException { } }

implementation: Utility . assertNotNull ( "batch" , batch ) ; if ( opContext == null ) { opContext = new OperationContext ( ) ; } opContext . initialize ( ) ; options = TableRequestOptions . populateAndApplyDefaults ( options , this . getServiceClient ( ) ) ; return batch . execute ( this . getServiceClient ( ) , this . getName ( ) , options , opContext ) ;


signature:
public class CloudTable { /** * Executes the operation on a table .
 * This method will invoke the < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179423 . aspx " > Table Service
 * REST API < / a > to execute the specified operation on the table , using the Table service endpoint and storage
 * account credentials of this instance .
 * @ param operation
 * The { @ link TableOperation } object representing the operation to execute on the table .
 * @ return
 * A { @ link TableResult } containing the result of executing the { @ link TableOperation } on the table .
 * @ throws StorageException
 * if an error occurs accessing the storage service , or the operation fails . */
@ DoesServiceRequest public TableResult execute ( final TableOperation operation ) throws StorageException { } }

implementation:
return this . execute ( operation , null /* options */
, null /* opContext */
) ;


signature:
public class CloudTable { /** * Executes the operation on a table , using the specified { @ link TableRequestOptions } and { @ link OperationContext } .
 * This method will invoke the < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179423 . aspx " > Table Service
 * REST API < / a > to execute the specified operation on the table , using the Table service endpoint and storage
 * account credentials of this instance .
 * Use the { @ link TableRequestOptions } to override execution options such as the timeout or retry policy for the
 * operation .
 * @ param operation
 * The { @ link TableOperation } object representing the operation to execute on the table .
 * @ param options
 * A { @ link TableRequestOptions } object that specifies execution options such as retry policy and timeout
 * settings for the operation . Specify < code > null < / code > to use the request options specified on the
 * { @ link CloudTableClient } .
 * @ param opContext
 * An { @ link OperationContext } object for tracking the current operation . Specify < code > null < / code > to
 * safely ignore operation context .
 * @ return
 * A { @ link TableResult } containing the result of executing the { @ link TableOperation } on the table .
 * @ throws StorageException
 * if an error occurs accessing the storage service , or the operation fails . */
@ DoesServiceRequest public TableResult execute ( final TableOperation operation , final TableRequestOptions options , final OperationContext opContext ) throws StorageException { } }

implementation: Utility . assertNotNull ( "operation" , operation ) ; return operation . execute ( this . getServiceClient ( ) , this . getName ( ) , options , opContext ) ;


signature:
public class CloudTable { /** * Executes a query , applying the specified { @ link EntityResolver } to the result .
 * This method will invoke a < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179421 . aspx " > Query
 * Entities < / a > operation on the < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179423 . aspx " > Table Service
 * REST API < / a > to query the table , using the Table service endpoint and storage account credentials of this
 * instance .
 * @ param query
 * A { @ link TableQuery } instance specifying the table to query and the query parameters to use .
 * @ param resolver
 * An { @ link EntityResolver } instance which creates a projection of the table query result entities into
 * the specified type < code > R < / code > .
 * @ return
 * A collection implementing the < code > Iterable < / code > interface containing the projection into type
 * < code > R < / code > of the results of executing the query . */
@ DoesServiceRequest public < R > Iterable < R > execute ( final TableQuery < ? > query , final EntityResolver < R > resolver ) { } }

implementation:
return this . execute ( query , resolver , null /* options */
, null /* opContext */
) ;


signature:
public class CloudTable { /** * Executes a query , applying the specified { @ link EntityResolver } to the result , using the
 * specified { @ link TableRequestOptions } and { @ link OperationContext } .
 * This method will invoke a < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179421 . aspx " > Query
 * Entities < / a > operation on the < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179423 . aspx " > Table Service
 * REST API < / a > to query the table , using the Table service endpoint and storage account credentials of this
 * instance .
 * Use the { @ link TableRequestOptions } to override execution options such as the timeout or retry policy for the
 * operation .
 * @ param query
 * A { @ link TableQuery } instance specifying the table to query and the query parameters to use .
 * @ param resolver
 * An { @ link EntityResolver } instance which creates a projection of the table query result entities into
 * the specified type < code > R < / code > .
 * @ param options
 * A { @ link TableRequestOptions } object that specifies execution options such as retry policy and timeout
 * settings for the operation . Specify < code > null < / code > to use the request options specified on the
 * { @ link CloudTableClient } .
 * @ param opContext
 * An { @ link OperationContext } object for tracking the current operation . Specify < code > null < / code > to
 * safely ignore operation context .
 * @ return
 * A collection implementing the < code > Iterable < / code > interface containing the projection into type
 * < code > R < / code > of the results of executing the query . */
@ DoesServiceRequest @ SuppressWarnings ( { } }

implementation: "unchecked" } ) public < R > Iterable < R > execute ( final TableQuery < ? > query , final EntityResolver < R > resolver , final TableRequestOptions options , final OperationContext opContext ) { Utility . assertNotNull ( "query" , query ) ; Utility . assertNotNull ( SR . QUERY_REQUIRES_VALID_CLASSTYPE_OR_RESOLVER , resolver ) ; query . setSourceTableName ( this . getName ( ) ) ; return ( Iterable < R > ) this . getServiceClient ( ) . generateIteratorForQuery ( query , resolver , options , opContext ) ;


signature:
public class CloudTable { /** * Executes a query .
 * This method will invoke a < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179421 . aspx " > Query
 * Entities < / a > operation on the < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179423 . aspx " > Table Service
 * REST API < / a > to query the table , using the Table service endpoint and storage account credentials of this
 * instance .
 * @ param query
 * A { @ link TableQuery } instance specifying the table to query and the query parameters to use ,
 * specialized for a type T implementing { @ link TableEntity } .
 * @ return
 * A collection implementing the < code > Iterable < / code > interface specialized for type T of the results of
 * executing the query . */
@ DoesServiceRequest public < T extends TableEntity > Iterable < T > execute ( final TableQuery < T > query ) { } }

implementation:
return this . execute ( query , null /* options */
, null /* opContext */
) ;


signature:
public class CloudTable { /** * Executes a query , using the specified { @ link TableRequestOptions } and { @ link OperationContext } .
 * This method will invoke a < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179421 . aspx " > Query
 * Entities < / a > operation on the < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179423 . aspx " > Table Service
 * REST API < / a > to query the table , using the Table service endpoint and storage account credentials of this
 * instance .
 * Use the { @ link TableRequestOptions } to override execution options such as the timeout or retry policy for the
 * operation .
 * @ param query
 * A { @ link TableQuery } instance specifying the table to query and the query parameters to use ,
 * specialized for a type T implementing { @ link TableEntity } .
 * @ param options
 * A { @ link TableRequestOptions } object that specifies execution options such as retry policy and timeout
 * settings for the operation . Specify < code > null < / code > to use the request options specified on the
 * { @ link CloudTableClient } .
 * @ param opContext
 * An { @ link OperationContext } object for tracking the current operation . Specify < code > null < / code > to
 * safely ignore operation context .
 * @ return
 * A collection implementing the < code > Iterable < / code > interface specialized for type T of the results of
 * executing the query . */
@ SuppressWarnings ( { } }

implementation: "unchecked" } ) @ DoesServiceRequest public < T extends TableEntity > Iterable < T > execute ( final TableQuery < T > query , final TableRequestOptions options , final OperationContext opContext ) { Utility . assertNotNull ( "query" , query ) ; Utility . assertNotNull ( SR . QUERY_REQUIRES_VALID_CLASSTYPE_OR_RESOLVER , query . getClazzType ( ) ) ; query . setSourceTableName ( this . getName ( ) ) ; return ( Iterable < T > ) this . getServiceClient ( ) . generateIteratorForQuery ( query , null , options , opContext ) ;


signature:
public class CloudTable { /** * Executes a query in segmented mode with the specified { @ link ResultContinuation } continuation token ,
 * applying the { @ link EntityResolver } to the result .
 * Executing a query with < code > executeSegmented < / code > allows the query to be resumed after returning partial
 * results , using information returned by the server in the { @ link ResultSegment } object .
 * This method will invoke a < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179421 . aspx " > Query
 * Entities < / a > operation on the < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179423 . aspx " > Table Service
 * REST API < / a > to query the table , using the Table service endpoint and storage account credentials of this
 * instance .
 * @ param query
 * A { @ link TableQuery } instance specifying the table to query and the query parameters to use .
 * @ param resolver
 * An { @ link EntityResolver } instance which creates a projection of the table query result entities into
 * the specified type < code > R < / code > .
 * @ param continuationToken
 * A { @ link ResultContinuation } object representing a continuation token from the server when the
 * operation returns a partial result . Specify < code > null < / code > on the initial call . Call the
 * { @ link ResultSegment # getContinuationToken ( ) } method on the result to obtain the
 * { @ link ResultContinuation } object to use in the next call to resume the query .
 * @ return
 * A { @ link ResultSegment } containing the projection into type < code > R < / code > of the results of executing
 * the query .
 * @ throws StorageException
 * if a storage service error occurred during the operation . */
@ DoesServiceRequest public < R > ResultSegment < R > executeSegmented ( final TableQuery < ? > query , final EntityResolver < R > resolver , final ResultContinuation continuationToken ) throws StorageException { } }

implementation:
return this . executeSegmented ( query , resolver , continuationToken , null /* options */
, null /* opContext */
) ;


signature:
public class CloudTable { /** * Executes a query in segmented mode with the specified { @ link ResultContinuation } continuation token ,
 * using the specified { @ link TableRequestOptions } and { @ link OperationContext } , applying the { @ link EntityResolver }
 * to the result .
 * Executing a query with < code > executeSegmented < / code > allows the query to be resumed after returning partial
 * results , using information returned by the server in the { @ link ResultSegment } object .
 * This method will invoke a < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179421 . aspx " > Query
 * Entities < / a > operation on the < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179423 . aspx " > Table Service
 * REST API < / a > to query the table , using the Table service endpoint and storage account credentials of this
 * instance .
 * Use the { @ link TableRequestOptions } to override execution options such as the timeout or retry policy for the
 * operation .
 * @ param query
 * A { @ link TableQuery } instance specifying the table to query and the query parameters to use .
 * @ param resolver
 * An { @ link EntityResolver } instance which creates a projection of the table query result entities into
 * the specified type < code > R < / code > .
 * @ param continuationToken
 * A { @ link ResultContinuation } object representing a continuation token from the server when the
 * operation returns a partial result . Specify < code > null < / code > on the initial call . Call the
 * { @ link ResultSegment # getContinuationToken ( ) } method on the result to obtain the
 * { @ link ResultContinuation } object to use in the next call to resume the query .
 * @ param options
 * A { @ link TableRequestOptions } object that specifies execution options such as retry policy and timeout
 * settings for the operation . Specify < code > null < / code > to use the request options specified on the
 * { @ link CloudTableClient } .
 * @ param opContext
 * An { @ link OperationContext } object for tracking the current operation . Specify < code > null < / code > to
 * safely ignore operation context .
 * @ return
 * A { @ link ResultSegment } containing the projection into type < code > R < / code > of the results of executing
 * the query .
 * @ throws StorageException
 * if a storage service error occurred during the operation . */
@ DoesServiceRequest @ SuppressWarnings ( { } }

implementation: "unchecked" } ) public < R > ResultSegment < R > executeSegmented ( final TableQuery < ? > query , final EntityResolver < R > resolver , final ResultContinuation continuationToken , final TableRequestOptions options , final OperationContext opContext ) throws StorageException { Utility . assertNotNull ( SR . QUERY_REQUIRES_VALID_CLASSTYPE_OR_RESOLVER , resolver ) ; query . setSourceTableName ( this . getName ( ) ) ; return ( ResultSegment < R > ) this . getServiceClient ( ) . executeQuerySegmentedImpl ( query , resolver , continuationToken , options , opContext ) ;


signature:
public class CloudTable { /** * Executes a query in segmented mode with a { @ link ResultContinuation } continuation token .
 * Executing a query with < code > executeSegmented < / code > allows the query to be resumed after returning partial
 * results , using information returned by the server in the { @ link ResultSegment } object .
 * This method will invoke a < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179421 . aspx " > Query
 * Entities < / a > operation on the < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179423 . aspx " > Table Service
 * REST API < / a > to query the table , using the Table service endpoint and storage account credentials of this
 * instance .
 * @ param query
 * A { @ link TableQuery } instance specifying the table to query and the query parameters to use ,
 * specialized for a type T implementing { @ link TableEntity } .
 * @ param continuationToken
 * A { @ link ResultContinuation } object representing a continuation token from the server when the
 * operation returns a partial result . Specify < code > null < / code > on the initial call . Call the
 * { @ link ResultSegment # getContinuationToken ( ) } method on the result to obtain the
 * { @ link ResultContinuation } object to use in the next call to resume the query .
 * @ return
 * A { @ link ResultSegment } specialized for type T of the results of executing the query .
 * @ throws StorageException
 * if a storage service error occurred during the operation . */
@ DoesServiceRequest public < T extends TableEntity > ResultSegment < T > executeSegmented ( final TableQuery < T > query , final ResultContinuation continuationToken ) throws StorageException { } }

implementation:
return this . executeSegmented ( query , continuationToken , null /* options */
, null /* opContext */
) ;


signature:
public class CloudTable { /** * Executes a query in segmented mode with a { @ link ResultContinuation } continuation token ,
 * using the specified { @ link TableRequestOptions } and { @ link OperationContext } .
 * Executing a query with < code > executeSegmented < / code > allows the query to be resumed after returning partial
 * results , using information returned by the server in the { @ link ResultSegment } object .
 * This method will invoke a < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179421 . aspx " > Query
 * Entities < / a > operation on the < a href = " http : / / msdn . microsoft . com / en - us / library / azure / dd179423 . aspx " > Table Service
 * REST API < / a > to query the table , using the Table service endpoint and storage account credentials of this
 * instance .
 * Use the { @ link TableRequestOptions } to override execution options such as the timeout or retry policy for the
 * operation .
 * @ param query
 * A { @ link TableQuery } instance specifying the table to query and the query parameters to use ,
 * specialized for a type T implementing { @ link TableEntity } .
 * @ param continuationToken
 * A { @ link ResultContinuation } object representing a continuation token from the server when the
 * operation returns a partial result . Specify < code > null < / code > on the initial call . Call the
 * { @ link ResultSegment # getContinuationToken ( ) } method on the result to obtain the
 * { @ link ResultContinuation } object to use in the next call to resume the query .
 * @ param options
 * A { @ link TableRequestOptions } object that specifies execution options such as retry policy and timeout
 * settings for the operation . Specify < code > null < / code > to use the request options specified on the
 * { @ link CloudTableClient } .
 * @ param opContext
 * An { @ link OperationContext } object for tracking the current operation . Specify < code > null < / code > to
 * safely ignore operation context .
 * @ return
 * A { @ link ResultSegment } specialized for type T of the results of executing the query .
 * @ throws StorageException
 * if a storage service error occurred during the operation . */
@ DoesServiceRequest @ SuppressWarnings ( { } }

implementation: "unchecked" } ) public < T extends TableEntity > ResultSegment < T > executeSegmented ( final TableQuery < T > query , final ResultContinuation continuationToken , final TableRequestOptions options , final OperationContext opContext ) throws StorageException { Utility . assertNotNull ( "query" , query ) ; query . setSourceTableName ( this . getName ( ) ) ; return ( ResultSegment < T > ) this . getServiceClient ( ) . executeQuerySegmentedImpl ( query , null , continuationToken , options , opContext ) ;


signature:
public class CloudTable { /** * Returns a value that indicates whether the table exists in the storage service , using the specified request
 * options and operation context .
 * @ param options
 * A { @ link TableRequestOptions } object that specifies any additional options for the request . Specifying
 * < code > null < / code > will use the default request options from the associated service client (
 * { @ link CloudTableClient } ) .
 * @ param opContext
 * An { @ link OperationContext } object that represents the context for the current operation . This object
 * is used to track requests to the storage service , and to provide additional runtime information about
 * the operation .
 * @ return < code > true < / code > if the table exists in the storage service , otherwise < code > false < / code > .
 * @ throws StorageException
 * If a storage service error occurred during the operation . */
@ DoesServiceRequest public boolean exists ( TableRequestOptions options , OperationContext opContext ) throws StorageException { } }

implementation: return this . exists ( false , options , opContext ) ;


signature:
public class CloudTable { /** * Returns a value that indicates whether the table exists in the storage service , using the specified request
 * options and operation context .
 * @ param options
 * A { @ link TableRequestOptions } object that specifies any additional options for the request . Specifying
 * < code > null < / code > will use the default request options from the associated service client (
 * { @ link CloudTableClient } ) .
 * @ param opContext
 * An { @ link OperationContext } object that represents the context for the current operation . This object
 * is used to track requests to the storage service , and to provide additional runtime information about
 * the operation .
 * @ return < code > true < / code > if the table exists in the storage service , otherwise < code > false < / code > .
 * @ throws StorageException
 * If a storage service error occurred during the operation . */
@ DoesServiceRequest private boolean exists ( final boolean primaryOnly , TableRequestOptions options , OperationContext opContext ) throws StorageException { } }

implementation:
if ( opContext == null ) { opContext = new OperationContext ( ) ; } opContext . initialize ( ) ; options = TableRequestOptions . populateAndApplyDefaults ( options , this . tableServiceClient ) ; Utility . assertNotNullOrEmpty ( "tableName" , this . name ) ; QueryTableOperation operation = ( QueryTableOperation ) TableOperation . retrieve ( this . name /* Used As PK */
, null /* Row Key */
, DynamicTableEntity . class ) ; operation . setPrimaryOnlyRetrieve ( primaryOnly ) ; final TableResult result = operation . execute ( this . tableServiceClient , TableConstants . TABLES_SERVICE_TABLES_NAME , options , opContext ) ; if ( result . getHttpStatusCode ( ) == HttpURLConnection . HTTP_OK ) { return true ; } else if ( result . getHttpStatusCode ( ) == HttpURLConnection . HTTP_NOT_FOUND ) { return false ; } else { throw new StorageException ( StorageErrorCodeStrings . OUT_OF_RANGE_INPUT , SR . UNEXPECTED_STATUS_CODE_RECEIVED , result . getHttpStatusCode ( ) , null /* extendedErrorInfo */
, null /* innerException */
) ; }


signature:
public class CloudTable { /** * Uploads the table ' s permissions using the specified request options and operation context .
 * @ param permissions
 * A { @ link TablePermissions } object that represents the permissions to upload .
 * @ param options
 * A { @ link TableRequestOptions } object that specifies any additional options for the request . Specifying
 * < code > null < / code > will use the default request options from the associated service client (
 * { @ link CloudTableClient } ) .
 * @ param opContext
 * An { @ link OperationContext } object that represents the context for the current operation . This object
 * is used to track requests to the storage service , and to provide additional runtime information about
 * the operation .
 * @ throws StorageException
 * If a storage service error occurred . */
@ DoesServiceRequest public void uploadPermissions ( final TablePermissions permissions , TableRequestOptions options , OperationContext opContext ) throws StorageException { } }

implementation: if ( opContext == null ) { opContext = new OperationContext ( ) ; } opContext . initialize ( ) ; options = TableRequestOptions . populateAndApplyDefaults ( options , this . tableServiceClient ) ; ExecutionEngine . executeWithRetry ( this . tableServiceClient , this , this . uploadPermissionsImpl ( permissions , options ) , options . getRetryPolicyFactory ( ) , opContext ) ;


signature:
public class CloudTable { /** * Downloads the permissions settings for the table using the specified request options and operation context .
 * @ param options
 * A { @ link TableRequestOptions } object that specifies any additional options for the request . Specifying
 * < code > null < / code > will use the default request options from the associated service client (
 * { @ link CloudTableClient } ) .
 * @ param opContext
 * An { @ link OperationContext } object that represents the context for the current operation . This object
 * is used to track requests to the storage service , and to provide additional runtime information about
 * the operation .
 * @ return A { @ link TablePermissions } object that represents the table ' s permissions .
 * @ throws StorageException
 * If a storage service error occurred . */
@ DoesServiceRequest public TablePermissions downloadPermissions ( TableRequestOptions options , OperationContext opContext ) throws StorageException { } }

implementation: if ( opContext == null ) { opContext = new OperationContext ( ) ; } opContext . initialize ( ) ; options = TableRequestOptions . populateAndApplyDefaults ( options , this . tableServiceClient ) ; return ExecutionEngine . executeWithRetry ( this . tableServiceClient , this , this . downloadPermissionsImpl ( options ) , options . getRetryPolicyFactory ( ) , opContext ) ;


signature:
public class CloudTable { /** * Creates a shared access signature for the table .
 * @ param policy
 * A { @ link SharedAccessTablePolicy } object which represents the access policy for the shared access
 * signature .
 * @ param accessPolicyIdentifier
 * A < code > String < / code > which represents a table - level access policy .
 * @ param startPartitionKey
 * A < code > String < / code > which represents the starting partition key .
 * @ param startRowKey
 * A < code > String < / code > which represents the starting row key .
 * @ param endPartitionKey
 * A < code > String < / code > which represents the ending partition key .
 * @ param endRowKey
 * A < code > String < / code > which represents the ending end key .
 * @ return A < code > String < / code > containing the shared access signature for the table .
 * @ throws InvalidKeyException
 * If an invalid key was passed .
 * @ throws StorageException
 * If a storage service error occurred .
 * @ throws IllegalArgumentException
 * If an unexpected value is passed . */
public String generateSharedAccessSignature ( final SharedAccessTablePolicy policy , final String accessPolicyIdentifier , final String startPartitionKey , final String startRowKey , final String endPartitionKey , final String endRowKey ) throws InvalidKeyException , StorageException { } }

implementation:
return generateSharedAccessSignature ( policy , accessPolicyIdentifier , startPartitionKey , startRowKey , endPartitionKey , endRowKey , null /* IP Range */
, null /* Protocols */
) ;


signature:
public class CloudTable { /** * Creates a shared access signature for the table .
 * @ param policy
 * A { @ link SharedAccessTablePolicy } object which represents the access policy for the shared access
 * signature .
 * @ param accessPolicyIdentifier
 * A < code > String < / code > which represents a table - level access policy .
 * @ param startPartitionKey
 * A < code > String < / code > which represents the starting partition key .
 * @ param startRowKey
 * A < code > String < / code > which represents the starting row key .
 * @ param endPartitionKey
 * A < code > String < / code > which represents the ending partition key .
 * @ param endRowKey
 * A < code > String < / code > which represents the ending end key .
 * @ param ipRange
 * A { @ link IPRange } object containing the range of allowed IP addresses .
 * @ param protocols
 * A { @ link SharedAccessProtocols } representing the allowed Internet protocols .
 * @ return A < code > String < / code > containing the shared access signature for the table .
 * @ throws InvalidKeyException
 * If an invalid key was passed .
 * @ throws StorageException
 * If a storage service error occurred .
 * @ throws IllegalArgumentException
 * If an unexpected value is passed . */
public String generateSharedAccessSignature ( final SharedAccessTablePolicy policy , final String accessPolicyIdentifier , final String startPartitionKey , final String startRowKey , final String endPartitionKey , final String endRowKey , final IPRange ipRange , final SharedAccessProtocols protocols ) throws InvalidKeyException , StorageException { } }

implementation: if ( ! StorageCredentialsHelper . canCredentialsSignRequest ( this . tableServiceClient . getCredentials ( ) ) ) { throw new IllegalArgumentException ( SR . CANNOT_CREATE_SAS_WITHOUT_ACCOUNT_KEY ) ; } final String resourceName = this . getSharedAccessCanonicalName ( ) ; final String signature = SharedAccessSignatureHelper . generateSharedAccessSignatureHashForTable ( policy , accessPolicyIdentifier , resourceName , ipRange , protocols , startPartitionKey , startRowKey , endPartitionKey , endRowKey , this . tableServiceClient ) ; final UriQueryBuilder builder = SharedAccessSignatureHelper . generateSharedAccessSignatureForTable ( policy , startPartitionKey , startRowKey , endPartitionKey , endRowKey , accessPolicyIdentifier , ipRange , protocols , this . name , signature ) ; return builder . toString ( ) ;


signature:
public class CloudTable { /** * Returns the canonical name for shared access .
 * @ return A < code > String < / code > containing the canonical name for shared access . */
private String getSharedAccessCanonicalName ( ) { } }

implementation: String accountName = this . getServiceClient ( ) . getCredentials ( ) . getAccountName ( ) ; String tableNameLowerCase = this . getName ( ) . toLowerCase ( Locale . ENGLISH ) ; return String . format ( "/%s/%s/%s" , SR . TABLE , accountName , tableNameLowerCase ) ;


signature:
public class RequestOptions { /** * Populates the default timeout , retry policy , and location mode from client if they are null .
 * @ param modifiedOptions
 * The input options to copy from when applying defaults */
protected static void applyBaseDefaultsInternal ( final RequestOptions modifiedOptions ) { } }

implementation: Utility . assertNotNull ( "modifiedOptions" , modifiedOptions ) ; if ( modifiedOptions . getRetryPolicyFactory ( ) == null ) { modifiedOptions . setRetryPolicyFactory ( new RetryExponentialRetry ( ) ) ; } if ( modifiedOptions . getLocationMode ( ) == null ) { modifiedOptions . setLocationMode ( LocationMode . PRIMARY_ONLY ) ; }


signature:
public class RequestOptions { /** * Populates any null fields in the first requestOptions object with values from the second requestOptions object . */
protected static void populateRequestOptions ( RequestOptions modifiedOptions , final RequestOptions clientOptions , final boolean setStartTime ) { } }

implementation: if ( modifiedOptions . getRetryPolicyFactory ( ) == null ) { modifiedOptions . setRetryPolicyFactory ( clientOptions . getRetryPolicyFactory ( ) ) ; } if ( modifiedOptions . getLocationMode ( ) == null ) { modifiedOptions . setLocationMode ( clientOptions . getLocationMode ( ) ) ; } if ( modifiedOptions . getTimeoutIntervalInMs ( ) == null ) { modifiedOptions . setTimeoutIntervalInMs ( clientOptions . getTimeoutIntervalInMs ( ) ) ; } if ( modifiedOptions . getMaximumExecutionTimeInMs ( ) == null ) { modifiedOptions . setMaximumExecutionTimeInMs ( clientOptions . getMaximumExecutionTimeInMs ( ) ) ; } if ( modifiedOptions . getMaximumExecutionTimeInMs ( ) != null && modifiedOptions . getOperationExpiryTimeInMs ( ) == null && setStartTime ) { modifiedOptions . setOperationExpiryTimeInMs ( new Date ( ) . getTime ( ) + modifiedOptions . getMaximumExecutionTimeInMs ( ) ) ; }


signature:
public class StorageErrorHandler { /** * Gets the Extended Error information from the response stream .
 * @ return the Extended Error information from the response stream
 * @ throws ParserConfigurationException
 * @ throws IOException
 * @ throws SAXException */
public static StorageExtendedErrorInformation getExtendedErrorInformation ( final InputStream stream ) throws SAXException , IOException , ParserConfigurationException { } }

implementation: SAXParser saxParser = Utility . getSAXParser ( ) ; StorageErrorHandler handler = new StorageErrorHandler ( ) ; saxParser . parse ( stream , handler ) ; return handler . errorInfo ;


signature:
public class StorageUri { /** * Gets the URI for a specified { @ link StorageLocation } .
 * @ param location
 * The < code > StorageLocation < / code > object for which to retrieve a URI .
 * @ return
 * A < code > java . net . URI < / code > object for the specified < code > StorageLocation < / code > . */
public URI getUri ( StorageLocation location ) { } }

implementation: switch ( location ) { case PRIMARY : return this . primaryUri ; case SECONDARY : return this . secondaryUri ; default : throw new IllegalArgumentException ( String . format ( Utility . LOCALE_US , SR . ARGUMENT_OUT_OF_RANGE_ERROR , "location" , location . toString ( ) ) ) ; }


signature:
public class StorageUri { /** * Validate that a URI exists for the specified < code > { @ link LocationMode } < / code > .
 * @ param mode
 * The < code > LocationMode < / code > to validate .
 * @ return
 * < code > true < / code > if a URI exists for the specified mode ; otherwise < code > false < / code > . */
public boolean validateLocationMode ( LocationMode mode ) { } }

implementation: switch ( mode ) { case PRIMARY_ONLY : return this . primaryUri != null ; case SECONDARY_ONLY : return this . secondaryUri != null ; default : return ( this . primaryUri != null ) && ( this . secondaryUri != null ) ; }


signature:
public class AccessCondition { /** * Returns an access condition such that an operation will be performed only if the resource ' s ETag value matches
 * the specified ETag value .
 * Setting this access condition modifies the request to include the HTTP < i > If - Match < / i > conditional header . If
 * this access condition is set , the operation is performed only if the ETag of the resource matches the specified
 * ETag .
 * For more information , see < a href = ' http : / / go . microsoft . com / fwlink / ? LinkID = 224642 ' > Specifying Conditional Headers
 * for Blob Service Operations < / a > .
 * @ param etag
 * A < code > String < / code > that represents the ETag value to check .
 * @ return An < code > AccessCondition < / code > object that represents the < i > If - Match < / i > condition . */
public static AccessCondition generateIfMatchCondition ( final String etag ) { } }

implementation: AccessCondition retCondition = new AccessCondition ( ) ; retCondition . setIfMatch ( etag ) ; return retCondition ;


signature:
public class AccessCondition { /** * Returns an access condition such that an operation will be performed only if the resource has been modified since
 * the specified time .
 * Setting this access condition modifies the request to include the HTTP < i > If - Modified - Since < / i > conditional
 * header . If this access condition is set , the operation is performed only if the resource has been modified since
 * the specified time .
 * For more information , see < a href = ' http : / / go . microsoft . com / fwlink / ? LinkID = 224642 ' > Specifying Conditional Headers
 * for Blob Service Operations < / a > .
 * @ param lastMotified
 * A < code > java . util . Date < / code > object that represents the last - modified time to check for the resource .
 * @ return An < code > AccessCondition < / code > object that represents the < i > If - Modified - Since < / i > condition . */
public static AccessCondition generateIfModifiedSinceCondition ( final Date lastMotified ) { } }

implementation: AccessCondition retCondition = new AccessCondition ( ) ; retCondition . ifModifiedSinceDate = lastMotified ; return retCondition ;


signature:
public class AccessCondition { /** * Returns an access condition such that an operation will be performed only if the resource ' s ETag value does not
 * match the specified ETag value .
 * Setting this access condition modifies the request to include the HTTP < i > If - None - Match < / i > conditional header .
 * If this access condition is set , the operation is performed only if the ETag of the resource does not match the
 * specified ETag .
 * For more information , see < a href = ' http : / / go . microsoft . com / fwlink / ? LinkID = 224642 ' > Specifying Conditional Headers
 * for Blob Service Operations < / a > .
 * @ param etag
 * A < code > String < / code > that represents the ETag value to check .
 * @ return An < code > AccessCondition < / code > object that represents the < i > If - None - Match < / i > condition . */
public static AccessCondition generateIfNoneMatchCondition ( final String etag ) { } }

implementation: AccessCondition retCondition = new AccessCondition ( ) ; retCondition . setIfNoneMatch ( etag ) ; return retCondition ;


signature:
public class AccessCondition { /** * Returns an access condition such that an operation will be performed only if the resource has not been modified
 * since the specified time .
 * Setting this access condition modifies the request to include the HTTP < i > If - Unmodified - Since < / i > conditional
 * header . If this access condition is set , the operation is performed only if the resource has not been modified
 * since the specified time .
 * For more information , see < a href = ' http : / / go . microsoft . com / fwlink / ? LinkID = 224642 ' > Specifying Conditional Headers
 * for Blob Service Operations < / a > .
 * @ param lastMotified
 * A < code > java . util . Date < / code > object that represents the last - modified time to check for the resource .
 * @ return An < code > AccessCondition < / code > object that represents the < i > If - Unmodified - Since < / i > condition . */
public static AccessCondition generateIfNotModifiedSinceCondition ( final Date lastMotified ) { } }

implementation: AccessCondition retCondition = new AccessCondition ( ) ; retCondition . ifUnmodifiedSinceDate = lastMotified ; return retCondition ;


signature:
public class AccessCondition { /** * Returns an access condition such that an operation will be performed only if resource ' s current sequence
 * number is less than or equal to the specified value . This condition only applies to page blobs .
 * @ param sequenceNumber
 * The value to compare to the current sequence number .
 * @ return An < code > AccessCondition < / code > object that represents the < i > If - Sequence - Number - LE < / i > condition . */
public static AccessCondition generateIfSequenceNumberLessThanOrEqualCondition ( long sequenceNumber ) { } }

implementation: AccessCondition retCondition = new AccessCondition ( ) ; retCondition . ifSequenceNumberLessThanOrEqual = sequenceNumber ; return retCondition ;


signature:
public class AccessCondition { /** * Returns an access condition such that an operation will be performed only if resource ' s current sequence
 * number is less than the specified value . This condition only applies to page blobs .
 * @ param sequenceNumber
 * The value to compare to the current sequence number .
 * @ return An < code > AccessCondition < / code > object that represents the < i > If - Sequence - Number - LT < / i > condition . */
public static AccessCondition generateIfSequenceNumberLessThanCondition ( long sequenceNumber ) { } }

implementation: AccessCondition retCondition = new AccessCondition ( ) ; retCondition . ifSequenceNumberLessThan = sequenceNumber ; return retCondition ;


signature:
public class AccessCondition { /** * Returns an access condition such that an operation will be performed only if resource ' s current sequence
 * number is equal to the specified value . This condition only applies to page blobs .
 * @ param sequenceNumber
 * The value to compare to the current sequence number .
 * @ return An < code > AccessCondition < / code > object that represents the < i > If - Sequence - Number - EQ < / i > condition . */
public static AccessCondition generateIfSequenceNumberEqualCondition ( long sequenceNumber ) { } }

implementation: AccessCondition retCondition = new AccessCondition ( ) ; retCondition . ifSequenceNumberEqual = sequenceNumber ; return retCondition ;


signature:
public class AccessCondition { /** * Returns an access condition such that an operation will be performed only if the resource is accessible under the
 * specified lease ID .
 * For more information , see < a href = ' http : / / go . microsoft . com / fwlink / ? LinkID = 224642 ' > Specifying Conditional Headers
 * for Blob Service Operations < / a > .
 * @ param leaseID
 * The lease ID to specify .
 * @ return An < code > AccessCondition < / code > object that represents the lease condition . */
public static AccessCondition generateLeaseCondition ( final String leaseID ) { } }

implementation: AccessCondition retCondition = new AccessCondition ( ) ; retCondition . leaseID = leaseID ; return retCondition ;


signature:
public class AccessCondition { /** * RESERVED FOR INTERNAL USE . Applies the access conditions to the request .
 * @ param request
 * A < code > java . net . HttpURLConnection < / code > object that represents the request
 * to which the condition is being applied . */
public void applyConditionToRequest ( final HttpURLConnection request ) { } }

implementation: applyLeaseConditionToRequest ( request ) ; if ( this . ifModifiedSinceDate != null ) { request . setRequestProperty ( Constants . HeaderConstants . IF_MODIFIED_SINCE , Utility . getGMTTime ( this . ifModifiedSinceDate ) ) ; } if ( this . ifUnmodifiedSinceDate != null ) { request . setRequestProperty ( Constants . HeaderConstants . IF_UNMODIFIED_SINCE , Utility . getGMTTime ( this . ifUnmodifiedSinceDate ) ) ; } if ( ! Utility . isNullOrEmpty ( this . ifMatchETag ) ) { request . setRequestProperty ( Constants . HeaderConstants . IF_MATCH , this . ifMatchETag ) ; } if ( ! Utility . isNullOrEmpty ( this . ifNoneMatchETag ) ) { request . setRequestProperty ( Constants . HeaderConstants . IF_NONE_MATCH , this . ifNoneMatchETag ) ; }


signature:
public class AccessCondition { /** * RESERVED FOR INTERNAL USE . Applies the source access conditions to the request .
 * @ param request
 * A < code > java . net . HttpURLConnection < / code > object that represents the request
 * to which the condition is being applied . */
public void applySourceConditionToRequest ( final HttpURLConnection request ) { } }

implementation:
if ( ! Utility . isNullOrEmpty ( this . leaseID ) ) { // Unsupported
throw new IllegalArgumentException ( SR . LEASE_CONDITION_ON_SOURCE ) ; } if ( this . ifModifiedSinceDate != null ) { request . setRequestProperty ( Constants . HeaderConstants . SOURCE_IF_MODIFIED_SINCE_HEADER , Utility . getGMTTime ( this . ifModifiedSinceDate ) ) ; } if ( this . ifUnmodifiedSinceDate != null ) { request . setRequestProperty ( Constants . HeaderConstants . SOURCE_IF_UNMODIFIED_SINCE_HEADER , Utility . getGMTTime ( this . ifUnmodifiedSinceDate ) ) ; } if ( ! Utility . isNullOrEmpty ( this . ifMatchETag ) ) { request . setRequestProperty ( Constants . HeaderConstants . SOURCE_IF_MATCH_HEADER , this . ifMatchETag ) ; } if ( ! Utility . isNullOrEmpty ( this . ifNoneMatchETag ) ) { request . setRequestProperty ( Constants . HeaderConstants . SOURCE_IF_NONE_MATCH_HEADER , this . ifNoneMatchETag ) ; }


signature:
public class AccessCondition { /** * RESERVED FOR INTERNAL USE . Applies the access condition to the request .
 * @ param request
 * A < code > java . net . HttpURLConnection < / code > object that represents the request to which the condition is
 * being applied .
 * @ throws StorageException
 * If there is an error parsing the date value of the access condition . */
public void applyAppendConditionToRequest ( final HttpURLConnection request ) { } }

implementation: if ( this . ifMaxSizeLessThanOrEqual != null ) { request . setRequestProperty ( Constants . HeaderConstants . IF_MAX_SIZE_LESS_THAN_OR_EQUAL , this . ifMaxSizeLessThanOrEqual . toString ( ) ) ; } if ( this . ifAppendPositionEqual != null ) { request . setRequestProperty ( Constants . HeaderConstants . IF_APPEND_POSITION_EQUAL_HEADER , this . ifAppendPositionEqual . toString ( ) ) ; }


signature:
public class AccessCondition { /** * RESERVED FOR INTERNAL USE . Applies the lease access condition to the request .
 * @ param request
 * A < code > java . net . HttpURLConnection < / code > object that represents the request
 * to which the condition is being applied . */
public void applyLeaseConditionToRequest ( final HttpURLConnection request ) { } }

implementation: if ( ! Utility . isNullOrEmpty ( this . leaseID ) ) { request . setRequestProperty ( Constants . HeaderConstants . LEASE_ID_HEADER , this . leaseID ) ; }


signature:
public class AccessCondition { /** * RESERVED FOR INTERNAL USE . Applies the sequence number access conditions to the request .
 * @ param request
 * A < code > java . net . HttpURLConnection < / code > object that represents the request
 * to which the condition is being applied . */
public void applySequenceConditionToRequest ( final HttpURLConnection request ) { } }

implementation: if ( this . ifSequenceNumberLessThanOrEqual != null ) { request . setRequestProperty ( Constants . HeaderConstants . IF_SEQUENCE_NUMBER_LESS_THAN_OR_EQUAL , this . ifSequenceNumberLessThanOrEqual . toString ( ) ) ; } if ( this . ifSequenceNumberLessThan != null ) { request . setRequestProperty ( Constants . HeaderConstants . IF_SEQUENCE_NUMBER_LESS_THAN , this . ifSequenceNumberLessThan . toString ( ) ) ; } if ( this . ifSequenceNumberEqual != null ) { request . setRequestProperty ( Constants . HeaderConstants . IF_SEQUENCE_NUMBER_EQUAL , this . ifSequenceNumberEqual . toString ( ) ) ; }


signature:
public class AccessCondition { /** * RESERVED FOR INTERNAL USE . Verifies the condition is satisfied .
 * @ param etag
 * A < code > String < / code > that represents the ETag to check .
 * @ param lastModified
 * A < code > java . util . Date < / code > object that represents the last modified date / time .
 * @ return < code > true < / code > if the condition is satisfied ; otherwise , < code > false < / code > . */
public boolean verifyConditional ( final String etag , final Date lastModified ) { } }

implementation:
if ( this . ifModifiedSinceDate != null ) { // The IfModifiedSince has a special helper in HttpURLConnection , use it instead of manually setting the
// header .
if ( ! lastModified . after ( this . ifModifiedSinceDate ) ) { return false ; } } if ( this . ifUnmodifiedSinceDate != null ) { if ( lastModified . after ( this . ifUnmodifiedSinceDate ) ) { return false ; } } if ( ! Utility . isNullOrEmpty ( this . ifMatchETag ) ) { if ( ! this . ifMatchETag . equals ( etag ) && ! this . ifMatchETag . equals ( "*" ) ) { return false ; } } if ( ! Utility . isNullOrEmpty ( this . ifNoneMatchETag ) ) { if ( this . ifNoneMatchETag . equals ( etag ) ) { return false ; } } return true ;


signature:
public class AccessCondition { /** * Normalizes an ETag to be quoted , unless it is * .
 * @ param inTag
 * The ETag to normalize .
 * @ return The quoted ETag . */
private static String normalizeEtag ( String inTag ) { } }

implementation: if ( Utility . isNullOrEmpty ( inTag ) || inTag . equals ( "*" ) ) { return inTag ; } else if ( inTag . startsWith ( "\"" ) && inTag . endsWith ( "\"" ) ) { return inTag ; } else { return String . format ( "\"%s\"" , inTag ) ; }


signature:
public class FileShareProperties { /** * Sets the limit on the size of files ( in GB ) stored on the share .
 * @ param shareQuota
 * A < code > java . lang . Integer < / code > object which represents the limit on
 * the size of files stored on the share . */
public void setShareQuota ( Integer shareQuota ) { } }

implementation: if ( shareQuota != null ) { Utility . assertInBounds ( "Share Quota" , shareQuota , 1 , FileConstants . MAX_SHARE_QUOTA ) ; } this . shareQuota = shareQuota ;


signature:
public class TableQuery { /** * A static factory method that constructs a { @ link TableQuery } instance and defines its table entity type . The
 * method returns the { @ link TableQuery } instance reference , allowing additional methods to be chained to modify the
 * query .
 * The created { @ link TableQuery } instance is specialized for table entities of the specified class type T . Callers
 * may specify { @ link TableServiceEntity } < code > . class < / code > as the class type parameter if no more specialized
 * type is required .
 * @ param clazzType
 * The < code > java . lang . Class < / code > of the class < code > T < / code > implementing the { @ link TableEntity }
 * interface that represents the table entity type for the query .
 * @ return
 * The { @ link TableQuery } instance with the entity type specialization set . */
public static < T extends TableEntity > TableQuery < T > from ( final Class < T > clazzType ) { } }

implementation: return new TableQuery < T > ( clazzType ) ;


signature:
public class TableQuery { /** * Generates a property filter condition string for a < code > boolean < / code > value . Creates a formatted string to use
 * in a filter expression that uses the specified operation to compare the property with the value , formatted as a
 * boolean , as in the following example :
 * < code > String condition = generateFilterCondition ( " BooleanProperty " , QueryComparisons . EQUAL , false ) ; < / code >
 * This statement sets < code > condition < / code > to the following value :
 * < code > BooleanProperty eq false < / code >
 * @ param propertyName
 * A < code > String < / code > which specifies the name of the property to compare .
 * @ param operation
 * A < code > String < / code > which specifies the comparison operator to use .
 * @ param value
 * A < code > boolean < / code > which specifies the value to compare with the property .
 * @ return
 * A < code > String < / code > which represents the formatted filter condition . */
public static String generateFilterCondition ( String propertyName , String operation , final boolean value ) { } }

implementation: return generateFilterCondition ( propertyName , operation , value ? Constants . TRUE : Constants . FALSE , EdmType . BOOLEAN ) ;


signature:
public class TableQuery { /** * Generates a property filter condition string for a < code > byte [ ] < / code > value . Creates a formatted string to use
 * in a filter expression that uses the specified operation to compare the property with the value , formatted as a
 * binary value , as in the following example :
 * < code > String condition = generateFilterCondition ( " ByteArray " , QueryComparisons . EQUAL , new byte [ ] { 0x01 , 0x0f } ) ; < / code >
 * This statement sets < code > condition < / code > to the following value :
 * < code > ByteArray eq X ' 010f ' < / code >
 * @ param propertyName
 * A < code > String < / code > which specifies the name of the property to compare .
 * @ param operation
 * A < code > String < / code > which specifies the comparison operator to use .
 * @ param value
 * A < code > byte < / code > array which specifies the value to compare with the property .
 * @ return
 * A < code > String < / code > which represents the formatted filter condition . */
public static String generateFilterCondition ( String propertyName , String operation , final byte [ ] value ) { } }

implementation: StringBuilder sb = new StringBuilder ( ) ; Formatter formatter = new Formatter ( sb ) ; for ( byte b : value ) { formatter . format ( "%02x" , b ) ; } formatter . flush ( ) ; formatter . close ( ) ; return generateFilterCondition ( propertyName , operation , sb . toString ( ) , EdmType . BINARY ) ;


signature:
public class TableQuery { /** * Generates a property filter condition string for a < code > java . util . Date < / code > value . Creates a formatted string to use in
 * a filter expression that uses the specified operation to compare the property with the value , formatted as a
 * datetime value , as in the following example :
 * < code > String condition = generateFilterCondition ( " FutureDate " , QueryComparisons . GREATER _ THAN , new Date ( ) ) ; < / code >
 * This statement sets < code > condition < / code > to something like the following value :
 * < code > FutureDate gt datetime ' 2013-01-31T09:00:00 ' < / code >
 * @ param propertyName
 * A < code > String < / code > which specifies the name of the property to compare .
 * @ param operation
 * A < code > String < / code > which specifies the comparison operator to use .
 * @ param value
 * A < code > java . util . Date < / code > which specifies the value to compare with the property .
 * @ return
 * A < code > String < / code > which represents the formatted filter condition . */
public static String generateFilterCondition ( String propertyName , String operation , final Date value ) { } }

implementation: return generateFilterCondition ( propertyName , operation , Utility . getJavaISO8601Time ( value ) , EdmType . DATE_TIME ) ;


signature:
public class TableQuery { /** * Generates a property filter condition string for a < code > double < / code > value . Creates a formatted string to use
 * in a filter expression that uses the specified operation to compare the property with the value , formatted as
 * a double value , as in the following example :
 * < code > String condition = generateFilterCondition ( " Circumference " , QueryComparisons . EQUAL , 2 * 3.141592 ) ; < / code >
 * This statement sets < code > condition < / code > to the following value :
 * < code > Circumference eq 6.283184 < / code >
 * @ param propertyName
 * A < code > String < / code > which specifies the name of the property to compare .
 * @ param operation
 * A < code > String < / code > which specifies the comparison operator to use .
 * @ param value
 * A < code > double < / code > which specifies the value to compare with the property .
 * @ return
 * A < code > String < / code > which represents the formatted filter condition . */
public static String generateFilterCondition ( String propertyName , String operation , final double value ) { } }

implementation: return generateFilterCondition ( propertyName , operation , Double . toString ( value ) , EdmType . DOUBLE ) ;


signature:
public class TableQuery { /** * Generates a property filter condition string for an < code > int < / code > value . Creates a formatted string to use
 * in a filter expression that uses the specified operation to compare the property with the value , formatted as
 * a numeric value , as in the following example :
 * < code > String condition = generateFilterCondition ( " Population " , QueryComparisons . GREATER _ THAN , 1000 ) ; < / code >
 * This statement sets < code > condition < / code > to the following value :
 * < code > Population gt 1000 < / code >
 * @ param propertyName
 * A < code > String < / code > which specifies the name of the property to compare .
 * @ param operation
 * A < code > String < / code > which specifies the comparison operator to use .
 * @ param value
 * An < code > int < / code > which specifies the value to compare with the property .
 * @ return
 * A < code > String < / code > which represents the formatted filter condition . */
public static String generateFilterCondition ( String propertyName , String operation , final int value ) { } }

implementation: return generateFilterCondition ( propertyName , operation , Integer . toString ( value ) , EdmType . INT32 ) ;


signature:
public class TableQuery { /** * Generates a property filter condition string for a < code > long < / code > value . Creates a formatted string to use
 * in a filter expression that uses the specified operation to compare the property with the value , formatted as
 * a numeric value , as in the following example :
 * < code > String condition = generateFilterCondition ( " StellarMass " , QueryComparisons . GREATER _ THAN , 700000L ) ; < / code >
 * This statement sets < code > condition < / code > to the following value :
 * < code > StellarMass gt 700000 < / code >
 * @ param propertyName
 * A < code > String < / code > which specifies the name of the property to compare .
 * @ param operation
 * A < code > String < / code > which specifies the comparison operator to use .
 * @ param value
 * A < code > long < / code > which specifies the value to compare with the property .
 * @ return
 * A < code > String < / code > which represents the formatted filter condition . */
public static String generateFilterCondition ( String propertyName , String operation , final long value ) { } }

implementation: return generateFilterCondition ( propertyName , operation , Long . toString ( value ) , EdmType . INT64 ) ;


signature:
public class TableQuery { /** * Generates a property filter condition string for a < code > String < / code > value . Creates a formatted string to use
 * in a filter expression that uses the specified operation to compare the property with the value , formatted as
 * a string value , as in the following example :
 * < code > String condition = generateFilterCondition ( " Platform " , QueryComparisons . EQUAL , " Azure " ) ; < / code >
 * This statement sets < code > condition < / code > to the following value :
 * < code > Platform eq ' Azure ' < / code >
 * @ param propertyName
 * A < code > String < / code > which specifies the name of the property to compare .
 * @ param operation
 * A < code > String < / code > which specifies the comparison operator to use .
 * @ param value
 * A < code > String < / code > which specifies the value to compare with the property .
 * @ return
 * A < code > String < / code > which represents the formatted filter condition . */
public static String generateFilterCondition ( String propertyName , String operation , final String value ) { } }

implementation: return generateFilterCondition ( propertyName , operation , value , EdmType . STRING ) ;


signature:
public class TableQuery { /** * Generates a property filter condition string . Creates a formatted string to use in a filter expression that uses
 * the specified operation to compare the property with the value , formatted as the specified { @ link EdmType } .
 * @ param propertyName
 * A < code > String < / code > which specifies the name of the property to compare .
 * @ param operation
 * A < code > String < / code > which specifies the comparison operator to use .
 * @ param value
 * A < code > String < / code > which specifies the value to compare with the property .
 * @ param edmType
 * The { @ link EdmType } to format the value as .
 * @ return
 * A < code > String < / code > which represents the formatted filter condition . */
public static String generateFilterCondition ( String propertyName , String operation , String value , EdmType edmType ) { } }

implementation: String valueOperand = null ; if ( edmType == EdmType . BOOLEAN || edmType == EdmType . DOUBLE || edmType == EdmType . INT32 ) { valueOperand = value ; } else if ( edmType == EdmType . INT64 ) { valueOperand = String . format ( "%sL" , value ) ; } else if ( edmType == EdmType . DATE_TIME ) { valueOperand = String . format ( "datetime'%s'" , value ) ; } else if ( edmType == EdmType . GUID ) { valueOperand = String . format ( "guid'%s'" , value ) ; } else if ( edmType == EdmType . BINARY ) { valueOperand = String . format ( "X'%s'" , value ) ; } else { valueOperand = String . format ( "'%s'" , value . replace ( "'" , "''" ) ) ; } return String . format ( "%s %s %s" , propertyName , operation , valueOperand ) ;


signature:
public class TableQuery { /** * Generates a property filter condition string for a < code > UUID < / code > value . Creates a formatted string to use
 * in a filter expression that uses the specified operation to compare the property with the value , formatted as
 * a UUID value , as in the following example :
 * < code > String condition = generateFilterCondition ( " Identity " , QueryComparisons . EQUAL , UUID . fromString ( < / code >
 * < code > " c9da6455-213d - 42c9-9a79-3e9149a57833 " ) ) ; < / code >
 * This statement sets < code > condition < / code > to the following value :
 * < code > Identity eq guid ' c9da6455-213d - 42c9-9a79-3e9149a57833 ' < / code >
 * @ param propertyName
 * A < code > String < / code > which specifies the name of the property to compare .
 * @ param operation
 * A < code > String < / code > which specifies the comparison operator to use .
 * @ param value
 * A < code > UUID < / code > which specifies the value to compare with the property .
 * @ return
 * A < code > String < / code > which represents the formatted filter condition . */
public static String generateFilterCondition ( String propertyName , String operation , final UUID value ) { } }

implementation: return generateFilterCondition ( propertyName , operation , value . toString ( ) , EdmType . GUID ) ;


signature:
public class TableQuery { /** * Creates a filter condition using the specified logical operator on two filter conditions .
 * @ param filterA
 * A < code > String < / code > which specifies the first formatted filter condition .
 * @ param operator
 * A < code > String < / code > which specifies < code > Operators . AND < / code > or < code > Operators . OR < / code > .
 * @ param filterB
 * A < code > String < / code > which specifies the first formatted filter condition .
 * @ return
 * A < code > String < / code > which represents the combined filter expression . */
public static String combineFilters ( String filterA , String operator , String filterB ) { } }

implementation: return String . format ( "(%s) %s (%s)" , filterA , operator , filterB ) ;


signature:
public class TableQuery { /** * Sets the class type of the table entities returned by the query . A class type is required to execute a table
 * query .
 * Callers may specify { @ link TableServiceEntity } < code > . class < / code > as the class type parameter if no more
 * specialized type is required .
 * @ param clazzType
 * The < code > java . lang . Class < / code > of the class < code > T < / code > that represents the table entity type for
 * the query . Class < code > T < / code > must be a type that implements { @ link TableEntity } and has a nullary
 * constructor , */
public void setClazzType ( final Class < T > clazzType ) { } }

implementation: Utility . assertNotNull ( "class type" , clazzType ) ; Utility . checkNullaryCtor ( clazzType ) ; this . clazzType = clazzType ;


signature:
public class TableQuery { /** * Sets the upper bound for the number of entities the query returns . If this value is not specified in a table
 * query , by default a maximum of 1,000 entries will be returned .
 * If the value specified for the < code > takeCount < / code > parameter is greater than 1,000 , the query will throw a
 * { @ link StorageException } when executed .
 * @ param takeCount
 * An < code > Integer < / code > which represents the maximum number of entities for the table query to return . */
public void setTakeCount ( final Integer takeCount ) { } }

implementation: if ( takeCount != null && takeCount <= 0 ) { throw new IllegalArgumentException ( SR . TAKE_COUNT_ZERO_OR_NEGATIVE ) ; } this . takeCount = takeCount ;


signature:
public class TableQuery { /** * Reserved for internal use . Creates a { @ link UriQueryBuilder } object representing the table query .
 * @ return A { @ link UriQueryBuilder } object representing the table query .
 * @ throws StorageException
 * if an error occurs in adding or encoding the query parameters . */
protected UriQueryBuilder generateQueryBuilder ( ) throws StorageException { } }

implementation: final UriQueryBuilder builder = new UriQueryBuilder ( ) ; if ( ! Utility . isNullOrEmpty ( this . filterString ) ) { builder . add ( TableConstants . FILTER , this . filterString ) ; } if ( this . takeCount != null ) { builder . add ( TableConstants . TOP , this . takeCount . toString ( ) ) ; } if ( this . columns != null && this . columns . length > 0 ) { final StringBuilder colBuilder = new StringBuilder ( ) ; boolean foundRk = false ; boolean foundPk = false ; boolean roundTs = false ; for ( int m = 0 ; m < this . columns . length ; m ++ ) { if ( TableConstants . ROW_KEY . equals ( this . columns [ m ] ) ) { foundRk = true ; } else if ( TableConstants . PARTITION_KEY . equals ( this . columns [ m ] ) ) { foundPk = true ; } else if ( TableConstants . TIMESTAMP . equals ( this . columns [ m ] ) ) { roundTs = true ; } colBuilder . append ( this . columns [ m ] ) ; if ( m < this . columns . length - 1 ) { colBuilder . append ( "," ) ; } } if ( ! foundPk ) { colBuilder . append ( "," ) ; colBuilder . append ( TableConstants . PARTITION_KEY ) ; } if ( ! foundRk ) { colBuilder . append ( "," ) ; colBuilder . append ( TableConstants . ROW_KEY ) ; } if ( ! roundTs ) { colBuilder . append ( "," ) ; colBuilder . append ( TableConstants . TIMESTAMP ) ; } builder . add ( TableConstants . SELECT , colBuilder . toString ( ) ) ; } return builder ;


signature:
public class ServiceClient { /** * Sets the list of URIs for all locations .
 * @ param storageUri
 * A { @ link StorageUri } object which represents the list of URIs for all locations . */
protected final void setStorageUri ( final StorageUri storageUri ) { } }

implementation: this . usePathStyleUris = Utility . determinePathStyleFromUri ( storageUri . getPrimaryUri ( ) ) ; this . storageUri = storageUri ;


signature:
public class TableEntitySerializer { /** * Reserved for internal use . Writes an entity to the stream as an JSON resource , leaving the stream open
 * for additional writing .
 * @ param outStream
 * The < code > OutputStream < / code > to write the entity to . .
 * @ param entity
 * The instance implementing { @ link TableEntity } to write to the output stream .
 * @ param isTableEntry
 * A flag indicating the entity is a reference to a table at the top level of the storage service when
 * < code > true < code > and a reference to an entity within a table when < code > false < / code > .
 * @ param opContext
 * An { @ link OperationContext } object used to track the execution of the operation .
 * @ throws StorageException
 * if a Storage service error occurs .
 * @ throws IOException
 * if an error occurs while accessing the stream . */
static void writeSingleEntity ( final OutputStream outStream , final TableEntity entity , final boolean isTableEntry , final OperationContext opContext ) throws StorageException , IOException { } }

implementation:
JsonGenerator generator = jsonFactory . createGenerator ( outStream ) ; try { // write to stream
writeJsonEntity ( generator , entity , isTableEntry , opContext ) ; } finally { generator . close ( ) ; }


signature:
public class TableEntitySerializer { /** * Reserved for internal use . Writes an entity to the stream as an JSON resource , leaving the stream open
 * for additional writing .
 * @ param strWriter
 * The < code > StringWriter < / code > to write the entity to .
 * @ param entity
 * The instance implementing { @ link TableEntity } to write to the output stream .
 * @ param isTableEntry
 * A flag indicating the entity is a reference to a table at the top level of the storage service when
 * < code > true < code > and a reference to an entity within a table when < code > false < / code > .
 * @ param opContext
 * An { @ link OperationContext } object used to track the execution of the operation .
 * @ throws StorageException
 * if a Storage service error occurs .
 * @ throws IOException
 * if an error occurs while accessing the stream . */
protected static void writeSingleEntity ( final StringWriter strWriter , final TableEntity entity , final boolean isTableEntry , final OperationContext opContext ) throws StorageException , IOException { } }

implementation:
JsonGenerator generator = jsonFactory . createGenerator ( strWriter ) ; try { // write to stream
writeJsonEntity ( generator , entity , isTableEntry , opContext ) ; } finally { generator . close ( ) ; }


signature:
public class TableEntitySerializer { /** * Reserved for internal use . Writes an entity to the specified < code > JsonGenerator < / code > as an JSON resource
 * @ param generator
 * The < code > JsonGenerator < / code > to write the entity to .
 * @ param entity
 * The instance implementing { @ link TableEntity } to write to the output stream .
 * @ param isTableEntry
 * A flag indicating the entity is a reference to a table at the top level of the storage service when
 * < code > true < code > and a reference to an entity within a table when < code > false < / code > .
 * @ param opContext
 * An { @ link OperationContext } object used to track the execution of the operation .
 * @ throws StorageException
 * if a Storage service error occurs .
 * @ throws IOException
 * if an error occurs while accessing the stream . */
private static void writeJsonEntity ( final JsonGenerator generator , final TableEntity entity , final boolean isTableEntry , final OperationContext opContext ) throws StorageException , IOException { } }

implementation:
HashMap < String , EntityProperty > properties = entity . writeEntity ( opContext ) ; if ( properties == null ) { properties = new HashMap < String , EntityProperty > ( ) ; } // start object
generator . writeStartObject ( ) ; if ( ! isTableEntry ) { Utility . assertNotNull ( TableConstants . PARTITION_KEY , entity . getPartitionKey ( ) ) ; Utility . assertNotNull ( TableConstants . ROW_KEY , entity . getRowKey ( ) ) ; Utility . assertNotNull ( TableConstants . TIMESTAMP , entity . getTimestamp ( ) ) ; // PartitionKey
generator . writeStringField ( TableConstants . PARTITION_KEY , entity . getPartitionKey ( ) ) ; // RowKey
generator . writeStringField ( TableConstants . ROW_KEY , entity . getRowKey ( ) ) ; // Timestamp
generator . writeStringField ( TableConstants . TIMESTAMP , Utility . getJavaISO8601Time ( entity . getTimestamp ( ) ) ) ; } for ( final Entry < String , EntityProperty > ent : properties . entrySet ( ) ) { if ( ent . getKey ( ) . equals ( TableConstants . PARTITION_KEY ) || ent . getKey ( ) . equals ( TableConstants . ROW_KEY ) || ent . getKey ( ) . equals ( TableConstants . TIMESTAMP ) || ent . getKey ( ) . equals ( "Etag" ) ) { continue ; } EntityProperty currProp = ent . getValue ( ) ; if ( currProp . getEdmType ( ) . mustAnnotateType ( ) ) { final String edmTypeString = currProp . getEdmType ( ) . toString ( ) ; // property type
generator . writeStringField ( ent . getKey ( ) + ODataConstants . ODATA_TYPE_SUFFIX , edmTypeString ) ; // property key and value
generator . writeStringField ( ent . getKey ( ) , ent . getValue ( ) . getValueAsString ( ) ) ; } else if ( currProp . getEdmType ( ) == EdmType . DOUBLE && currProp . getIsNull ( ) == false ) { final String edmTypeString = currProp . getEdmType ( ) . toString ( ) ; final Double value = currProp . getValueAsDouble ( ) ; // property type , if needed
if ( value . equals ( Double . POSITIVE_INFINITY ) || value . equals ( Double . NEGATIVE_INFINITY ) || value . equals ( Double . NaN ) ) { generator . writeStringField ( ent . getKey ( ) + ODataConstants . ODATA_TYPE_SUFFIX , edmTypeString ) ; // property key and value
generator . writeStringField ( ent . getKey ( ) , ent . getValue ( ) . getValueAsString ( ) ) ; } else { writeJsonProperty ( generator , ent ) ; } } else { writeJsonProperty ( generator , ent ) ; } } // end object
generator . writeEndObject ( ) ;


signature:
public class SharedAccessPolicySerializer { /** * RESERVED FOR INTERNAL USE . Writes a collection of shared access policies to the specified stream in XML format .
 * @ param < T >
 * @ param sharedAccessPolicies
 * A collection of shared access policies
 * @ param outWriter
 * a sink to write the output to .
 * @ throws IOException
 * if there is an error writing the shared access identifiers .
 * @ throws IllegalStateException
 * if there is an error writing the shared access identifiers .
 * @ throws IllegalArgumentException
 * if there is an error writing the shared access identifiers . */
public static < T extends SharedAccessPolicy > void writeSharedAccessIdentifiersToStream ( final HashMap < String , T > sharedAccessPolicies , final StringWriter outWriter ) throws IllegalArgumentException , IllegalStateException , IOException { } }

implementation:
Utility . assertNotNull ( "sharedAccessPolicies" , sharedAccessPolicies ) ; Utility . assertNotNull ( "outWriter" , outWriter ) ; final XmlSerializer xmlw = Utility . getXmlSerializer ( outWriter ) ; if ( sharedAccessPolicies . keySet ( ) . size ( ) > Constants . MAX_SHARED_ACCESS_POLICY_IDENTIFIERS ) { final String errorMessage = String . format ( SR . TOO_MANY_SHARED_ACCESS_POLICY_IDENTIFIERS , sharedAccessPolicies . keySet ( ) . size ( ) , Constants . MAX_SHARED_ACCESS_POLICY_IDENTIFIERS ) ; throw new IllegalArgumentException ( errorMessage ) ; } // default is UTF8
xmlw . startDocument ( Constants . UTF8_CHARSET , true ) ; xmlw . startTag ( Constants . EMPTY_STRING , Constants . SIGNED_IDENTIFIERS_ELEMENT ) ; for ( final Entry < String , T > entry : sharedAccessPolicies . entrySet ( ) ) { final SharedAccessPolicy policy = entry . getValue ( ) ; xmlw . startTag ( Constants . EMPTY_STRING , Constants . SIGNED_IDENTIFIER_ELEMENT ) ; // Set the identifier
Utility . serializeElement ( xmlw , Constants . ID , entry . getKey ( ) ) ; xmlw . startTag ( Constants . EMPTY_STRING , Constants . ACCESS_POLICY ) ; // Set the Start Time
Utility . serializeElement ( xmlw , Constants . START , Utility . getUTCTimeOrEmpty ( policy . getSharedAccessStartTime ( ) ) . toString ( ) ) ; // Set the Expiry Time
Utility . serializeElement ( xmlw , Constants . EXPIRY , Utility . getUTCTimeOrEmpty ( policy . getSharedAccessExpiryTime ( ) ) . toString ( ) ) ; // Set the Permissions
Utility . serializeElement ( xmlw , Constants . PERMISSION , policy . permissionsToString ( ) ) ; // end AccessPolicy
xmlw . endTag ( Constants . EMPTY_STRING , Constants . ACCESS_POLICY ) ; // end SignedIdentifier
xmlw . endTag ( Constants . EMPTY_STRING , Constants . SIGNED_IDENTIFIER_ELEMENT ) ; } // end SignedIdentifiers
xmlw . endTag ( Constants . EMPTY_STRING , Constants . SIGNED_IDENTIFIERS_ELEMENT ) ; // end doc
xmlw . endDocument ( ) ;


signature:
public class QueueMessageSerializer { /** * Generates the message request body from a string containing the message .
 * The message must be encodable as UTF - 8 . To be included in a web request ,
 * this message request body must be written to the output stream of the web
 * request .
 * @ param message
 * A < code > String < code > containing the message to wrap in a message request body .
 * @ return An array of < code > byte < / code > containing the message request body
 * encoded as UTF - 8.
 * @ throws IOException
 * if there is an error writing the queue message .
 * @ throws IllegalStateException
 * if there is an error writing the queue message .
 * @ throws IllegalArgumentException
 * if there is an error writing the queue message . */
public static byte [ ] generateMessageRequestBody ( final String message ) throws IllegalArgumentException , IllegalStateException , IOException { } }

implementation:
final StringWriter outWriter = new StringWriter ( ) ; final XmlSerializer xmlw = Utility . getXmlSerializer ( outWriter ) ; // default is UTF8
xmlw . startDocument ( Constants . UTF8_CHARSET , true ) ; xmlw . startTag ( Constants . EMPTY_STRING , QueueConstants . QUEUE_MESSAGE_ELEMENT ) ; Utility . serializeElement ( xmlw , QueueConstants . MESSAGE_TEXT_ELEMENT , message ) ; // end QueueMessage _ ELEMENT
xmlw . endTag ( Constants . EMPTY_STRING , QueueConstants . QUEUE_MESSAGE_ELEMENT ) ; // end doc
xmlw . endDocument ( ) ; return outWriter . toString ( ) . getBytes ( Constants . UTF8_CHARSET ) ;


signature:
public class TableResult { /** * Reserved for internal use . Sets the result to associate with the table operation as a { @ link TableEntity } .
 * @ param ent
 * An instance of an object implementing { @ link TableEntity } to associate with the table operation .
 * @ throws UnsupportedEncodingException */
protected void updateResultObject ( final TableEntity ent ) throws UnsupportedEncodingException { } }

implementation: this . result = ent ; ent . setEtag ( this . etag ) ; if ( this . etag != null ) { ent . setTimestamp ( parseETagForTimestamp ( this . etag ) ) ; }


signature:
public class TableDeserializer { /** * Reserved for internal use . Parses the operation response as a collection of entities . Reads entity data from the
 * specified input stream using the specified class type and optionally projects each entity result with the
 * specified resolver into an { @ link ODataPayload } containing a collection of { @ link TableResult } objects .
 * @ param inStream
 * The < code > InputStream < / code > to read the data to parse from .
 * @ param clazzType
 * The class type < code > T < / code > implementing { @ link TableEntity } for the entities returned . Set to
 * < code > null < / code > to ignore the returned entities and copy only response properties into the
 * { @ link TableResult } objects .
 * @ param resolver
 * An { @ link EntityResolver } instance to project the entities into instances of type < code > R < / code > . Set
 * to < code > null < / code > to return the entities as instances of the class type < code > T < / code > .
 * @ param options
 * A { @ link TableRequestOptions } object that specifies execution options such as retry policy and timeout
 * settings for the operation .
 * @ param opContext
 * An { @ link OperationContext } object used to track the execution of the operation .
 * @ return
 * An { @ link ODataPayload } containing a collection of { @ link TableResult } objects with the parsed operation
 * response .
 * @ throws InstantiationException
 * if an error occurs while constructing the result .
 * @ throws IllegalAccessException
 * if an error occurs in reflection while parsing the result .
 * @ throws StorageException
 * if a storage service error occurs .
 * @ throws IOException
 * if an error occurs while accessing the stream .
 * @ throws JsonParseException
 * if an error occurs while parsing the stream . */
@ SuppressWarnings ( "unchecked" ) static < T extends TableEntity , R > ODataPayload < ? > parseQueryResponse ( final InputStream inStream , final TableRequestOptions options , Class < T > clazzType , final EntityResolver < R > resolver , final OperationContext opContext ) throws InstantiationException , IllegalAccessException , StorageException , JsonParseException , IOException { } }

implementation:
ODataPayload < T > corePayload = null ; ODataPayload < R > resolvedPayload = null ; ODataPayload < ? > commonPayload = null ; JsonParser parser = createJsonParserFromStream ( inStream ) ; try { if ( resolver != null ) { resolvedPayload = new ODataPayload < R > ( ) ; commonPayload = resolvedPayload ; } else { corePayload = new ODataPayload < T > ( ) ; commonPayload = corePayload ; } if ( ! parser . hasCurrentToken ( ) ) { parser . nextToken ( ) ; } JsonUtilities . assertIsStartObjectJsonToken ( parser ) ; // move into data
parser . nextToken ( ) ; // if there is a clazz type and if JsonNoMetadata , create a classProperties dictionary to use for type inference once
// instead of querying the cache many times
HashMap < String , PropertyPair > classProperties = null ; if ( options . getTablePayloadFormat ( ) == TablePayloadFormat . JsonNoMetadata && clazzType != null ) { classProperties = PropertyPair . generatePropertyPairs ( clazzType ) ; } while ( parser . getCurrentToken ( ) != null ) { if ( parser . getCurrentToken ( ) == JsonToken . FIELD_NAME && parser . getCurrentName ( ) . equals ( ODataConstants . VALUE ) ) { // move to start of array
parser . nextToken ( ) ; JsonUtilities . assertIsStartArrayJsonToken ( parser ) ; // go to properties
parser . nextToken ( ) ; while ( parser . getCurrentToken ( ) == JsonToken . START_OBJECT ) { final TableResult res = parseJsonEntity ( parser , clazzType , classProperties , resolver , options , opContext ) ; if ( corePayload != null ) { corePayload . tableResults . add ( res ) ; } if ( resolver != null ) { resolvedPayload . results . add ( ( R ) res . getResult ( ) ) ; } else { corePayload . results . add ( ( T ) res . getResult ( ) ) ; } parser . nextToken ( ) ; } JsonUtilities . assertIsEndArrayJsonToken ( parser ) ; } parser . nextToken ( ) ; } } finally { parser . close ( ) ; } return commonPayload ;


signature:
public class TableDeserializer { /** * Reserved for internal use . Parses the operation response as an entity . Reads entity data from the specified
 * < code > JsonParser < / code > using the specified class type and optionally projects the entity result with the
 * specified resolver into a { @ link TableResult } object .
 * @ param inStream
 * The < code > InputStream < / code > to read the data to parse from .
 * @ param format
 * The { @ link TablePayloadFormat } to use for parsing .
 * @ param options
 * A { @ link TableRequestOptions } object that specifies execution options such as retry policy and timeout
 * settings for the operation .
 * @ param httpStatusCode
 * The HTTP status code returned with the operation response .
 * @ param clazzType
 * The class type < code > T < / code > implementing { @ link TableEntity } for the entity returned . Set to
 * < code > null < / code > to ignore the returned entity and copy only response properties into the
 * { @ link TableResult } object .
 * @ param resolver
 * An { @ link EntityResolver } instance to project the entity into an instance of type < code > R < / code > . Set
 * to < code > null < / code > to return the entitys as instance of the class type < code > T < / code > .
 * @ param opContext
 * An { @ link OperationContext } object used to track the execution of the operation .
 * @ return
 * A { @ link TableResult } object with the parsed operation response .
 * @ throws InstantiationException
 * if an error occurs while constructing the result .
 * @ throws IllegalAccessException
 * if an error occurs in reflection while parsing the result .
 * @ throws StorageException
 * if a storage service error occurs .
 * @ throws IOException
 * if an error occurs while accessing the stream .
 * @ throws JsonParseException
 * if an error occurs while parsing the stream . */
static < T extends TableEntity , R > TableResult parseSingleOpResponse ( final InputStream inStream , final TableRequestOptions options , final int httpStatusCode , final Class < T > clazzType , final EntityResolver < R > resolver , final OperationContext opContext ) throws InstantiationException , IllegalAccessException , StorageException , JsonParseException , IOException { } }

implementation:
JsonParser parser = createJsonParserFromStream ( inStream ) ; try { final TableResult res = parseJsonEntity ( parser , clazzType , null /* HashMap < String , PropertyPair > classProperties */
, resolver , options , opContext ) ; res . setHttpStatusCode ( httpStatusCode ) ; return res ; } finally { parser . close ( ) ; }