Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 128 for renames (0.05 sec)

  1. guava/src/com/google/common/util/concurrent/MoreExecutors.java

      // TODO(lukes): provide overloads that take constant strings? Function<Runnable, String>s to
      // calculate names?
    
      /**
       * Creates an {@link Executor} that renames the {@link Thread threads} that its tasks run in.
       *
       * <p>The names are retrieved from the {@code nameSupplier} on the thread that is being renamed
       * right before each task is run. The renaming is best effort, if a {@link SecurityManager}
    Registered: Fri Nov 01 12:43:10 UTC 2024
    - Last Modified: Sat Oct 19 00:51:36 UTC 2024
    - 44.1K bytes
    - Viewed (0)
  2. cmd/prepare-storage.go

    		go removeAll(file)
    	}
    
    	// Remove the entire folder in case there are leftovers that didn't get cleaned up before restart.
    	go removeAll(pathJoin(diskPath, minioMetaTmpBucket+"-old"))
    
    	// Renames and schedules for purging all bucket metacache.
    	go renameAllBucketMetacache(diskPath)
    }
    
    // Following error message is added to fix a regression in release
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 20:51:54 UTC 2024
    - 11.1K bytes
    - Viewed (1)
  3. cmd/storage-rest-client.go

    	}
    
    	for i, dErr := range dErrResp.Errs {
    		if dErr != "" {
    			errs[i] = toStorageErr(errors.New(dErr))
    		} else {
    			errs[i] = nil
    		}
    	}
    
    	return errs
    }
    
    // RenamePart - renames multipart part file
    func (client *storageRESTClient) RenamePart(ctx context.Context, srcVolume, srcPath, dstVolume, dstPath string, meta []byte) (err error) {
    	ctx, cancel := context.WithTimeout(ctx, globalDriveConfig.GetMaxTimeout())
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Oct 13 13:07:21 UTC 2024
    - 30.2K bytes
    - Viewed (0)
  4. cmd/erasure-multipart.go

    	g := errgroup.WithNErrs(len(disks))
    
    	// Rename file on all underlying storage disks.
    	for index := range disks {
    		index := index
    		g.Go(func() error {
    			if disks[index] == nil {
    				return errDiskNotFound
    			}
    			return disks[index].RenamePart(ctx, srcBucket, srcEntry, dstBucket, dstEntry, optsMeta)
    		}, index)
    	}
    
    	// Wait for all renames to finish.
    	errs := g.Wait()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  5. docs/bigdata/README.md

    stores such as MinIO. MapReduce workloads typically interact with object stores in the same way they do with HDFS. These workloads rely on HDFS atomic rename functionality to complete writing data to the datastore. Object storage operations are atomic by nature and they do not require/implement rename API. The default S3A committer emulates renames through copy and delete APIs. This interaction pattern causes significant loss of performance because of the write amplification. _Netflix_, for example,...
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 29 04:28:45 UTC 2022
    - 14.7K bytes
    - Viewed (0)
  6. cmd/storage-rest-server.go

    	return &resp, grid.NewRemoteErr(err)
    }
    
    // RenameDataInlineHandler - renames a meta object and data dir to destination.
    func (s *storageRESTServer) RenameDataInlineHandler(p *RenameDataInlineHandlerParams) (*RenameDataResp, *grid.RemoteErr) {
    	defer p.Recycle()
    	return s.RenameDataHandler(&p.RenameDataHandlerParams)
    }
    
    // RenameFileHandler - rename a file from source to destination
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Aug 14 17:11:51 UTC 2024
    - 45.7K bytes
    - Viewed (0)
  7. internal/config/config.go

    func LookupWorm() (bool, error) {
    	return ParseBool(env.Get(EnvWorm, EnableOff))
    }
    
    // Carries all the renamed sub-systems from their
    // previously known names
    var renamedSubsys = map[string]string{
    	CrawlerSubSys: ScannerSubSys,
    	// Add future sub-system renames
    }
    
    const ( // deprecated keys
    	apiReplicationWorkers       = "replication_workers"
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 37.7K bytes
    - Viewed (0)
  8. src/test/java/jcifs/tests/FileOperationsTest.java

                f.createNewFile();
                boolean renamed = false;
                try {
                    f.renameTo(f2);
                    try {
                        assertTrue(f2.exists());
                        renamed = true;
                    }
                    finally {
                        f2.delete();
                    }
                }
                finally {
                    if ( !renamed && f.exists() ) {
                        f.delete();
    Registered: Sun Nov 03 00:10:13 UTC 2024
    - Last Modified: Thu Jan 05 13:17:59 UTC 2023
    - 16.3K bytes
    - Viewed (0)
  9. callbacks/query.go

    			selectColumns, _ := db.Statement.SelectAndOmitColumns(false, false)
    			clauseSelect.Columns = make([]clause.Column, 0, len(db.Statement.Schema.DBNames))
    			for _, dbName := range db.Statement.Schema.DBNames {
    				if v, ok := selectColumns[dbName]; (ok && v) || !ok {
    					clauseSelect.Columns = append(clauseSelect.Columns, clause.Column{Table: db.Statement.Table, Name: dbName})
    				}
    			}
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Thu Aug 22 11:03:42 UTC 2024
    - 10.1K bytes
    - Viewed (1)
  10. migrator/migrator.go

    		).Row().Scan(&count)
    	})
    
    	return count > 0
    }
    
    // RenameIndex rename index from oldName to newName
    func (m Migrator) RenameIndex(value interface{}, oldName, newName string) error {
    	return m.RunWithValue(value, func(stmt *gorm.Statement) error {
    		return m.DB.Exec(
    			"ALTER TABLE ? RENAME INDEX ? TO ?",
    			m.CurrentTable(stmt), clause.Column{Name: oldName}, clause.Column{Name: newName},
    		).Error
    Registered: Sun Nov 03 09:35:10 UTC 2024
    - Last Modified: Fri Apr 26 07:15:49 UTC 2024
    - 29K bytes
    - Viewed (0)
Back to top