Package com.splunk.shuttl.archiver.filesystem.transaction

Examples of com.splunk.shuttl.archiver.filesystem.transaction.TransactionExecuter

81
82
83
84
85
86
87
88
  private static ThawBucketTransferer getThawBucketTransferer(
      ArchiveFileSystem archiveFileSystem,
      ThawLocationProvider thawLocationProvider) {
    ThawBucketTransferer thawBucketTransferer = new ThawBucketTransferer(
        thawLocationProvider, archiveFileSystem, new BucketFactory(),
        new TransactionExecuter());
    return thawBucketTransferer;
  }
View Full Code Here
103
104
105
106
107
108
109
110
111
112
113
    BucketExportController bucketExportController = BucketExportController
        .create(CsvExporter.create(bucketToCsvFileExporter), tgzFormatExporter);
    ArchiveBucketTransferer bucketTransferer = new ArchiveBucketTransferer(
        archiveFileSystem, pathResolver, archiveBucketSize,
        new TransactionExecuter());
    BucketDeleter bucketDeleter = BucketDeleter.create();
    List<BucketFormat> archiveFormats = config.getArchiveFormats();

    BucketCopierDependencies deps = new BucketCopierDependencies(
        bucketExportController, bucketTransferer, bucketDeleter, archiveFormats);
View Full Code Here
147
148
149
150
151
152
153
154
  public static MetadataStore create(ArchiveConfiguration config,
      ArchiveFileSystem archiveFileSystem,
      LocalFileSystemPaths localFileSystemPaths) {
    return new MetadataStore(new PathResolver(config), new FlatFileStorage(
        localFileSystemPaths), archiveFileSystem, new TransactionExecuter(),
        localFileSystemPaths);
  }
View Full Code Here
79
80
81
82
83
84
85
  public static ArchiveBucketSize create(PathResolver pathResolver,
      ArchiveFileSystem archiveFileSystem,
      LocalFileSystemPaths localFileSystemPaths) {
    return new ArchiveBucketSize(new MetadataStore(pathResolver,
        new FlatFileStorage(localFileSystemPaths), archiveFileSystem,
        new TransactionExecuter(), localFileSystemPaths));
  }
View Full Code Here
59
60
61
62
63
64
65
66
67
68
69
    pathResolver = new PathResolver(config);
    localFileSystemPaths = new LocalFileSystemPaths(createDirectory());
    flatFileStorage = new FlatFileStorage(localFileSystemPaths);
    metadataStore = new MetadataStore(pathResolver, flatFileStorage,
        localFileSystem, new TransactionExecuter(), localFileSystemPaths);

    remoteBucket = TUtilsBucket.createRemoteBucket();
    expectedData = "data";

    fileName = "FileNameOfMetadataFile.file";
View Full Code Here
TOP

Related Classes of com.splunk.shuttl.archiver.filesystem.transaction.TransactionExecuter

  • com.splunk.shuttl.archiver.archive.BucketShuttlerFactory
  • com.splunk.shuttl.archiver.metastore.ArchiveBucketSize
  • com.splunk.shuttl.archiver.metastore.MetadataStore
  • com.splunk.shuttl.archiver.metastore.MetadataStoreReadIntegrationTest
  • com.splunk.shuttl.archiver.thaw.BucketThawerFactory
    • Copyright © 2018 www.massapicom. All rights reserved.
    All source code are property of their respective owners. Java is a trademark of Sun Microsystems, Inc and owned by ORACLE Inc. Contact coftware#gmail.com.