private void initializeDelegationTokenSupport ( Configuration config , URI path ) throws IOException { logger . atFine ( ) . log ( "GHFS.initializeDelegationTokenSupport" ) ; // Load delegation token binding, if support is configured GcsDelegationTokens dts = new GcsDelegationTokens ( ) ; Text service = new Text ( getScheme ( ) + "://" + path . getAuthority ( ) ) ; dts . bindToFileSystem ( this , service ) ; try { dts . init ( config ) ; delegationTokens = dts ; if ( delegationTokens . isBoundToDT ( ) ) { logger . atFine ( ) . log ( "GHFS.initializeDelegationTokenSupport: Using existing delegation token." ) ; } } catch ( IllegalStateException e ) { logger . atInfo ( ) . log ( "GHFS.initializeDelegationTokenSupport: %s" , e . getMessage ( ) ) ; } }
Initialize the delegation token support for this filesystem .