Package com.splunk.shuttl.archiver.listers

Examples of com.splunk.shuttl.archiver.listers.ListsBucketsFiltered

62
63
64
65
66
67
68
69
70
71
72
    ThawLocationProvider thawLocationProvider = new ThawLocationProvider(
        splunkIndexesLayer, localFileSystemPaths);

    ThawBucketTransferer thawBucketTransferer = getThawBucketTransferer(
        archiveFileSystem, thawLocationProvider);
    ListsBucketsFiltered listsBucketsFiltered = ListsBucketsFilteredFactory
        .create(configuration);
    PathResolver pathResolver = new PathResolver(configuration);
    BucketSizeResolver bucketSizeResolver = new BucketSizeResolver(
        ArchiveBucketSize.create(pathResolver, archiveFileSystem,
            localFileSystemPaths));
View Full Code Here
137
138
139
140
141
142
143
144
145
146
147
148
        .put(JsonObjectNames.EXCEPTIONS, peerResponse.exceptions).toString();
  }

  private List<Bucket> getFilteredBucketsAtIndex(String index, Date fromDate,
      Date toDate) {
    ListsBucketsFiltered listsBucketsFiltered = getListsBucketsFiltered();
    if (index == null)
      return listsBucketsFiltered.listFilteredBuckets(fromDate, toDate);
    else
      return listsBucketsFiltered.listFilteredBucketsAtIndex(index, fromDate,
          toDate);
  }
View Full Code Here
88
89
90
91
92
93
94
95
96
97
98
99
100
  public void BucketSize_archiveBucket_remoteBucketHasSameSizeAsBeforeArchiving() {
    LocalBucket bucket = TUtilsBucket.createRealBucket();
    long bucketSize = bucket.getSize();

    TUtilsFunctional.archiveBucket(bucket, bucketArchiver);
    ListsBucketsFiltered listsBucketsFiltered = ListsBucketsFilteredFactory
        .create(config);
    List<Bucket> listBucketsInIndex = listsBucketsFiltered
        .listFilteredBucketsAtIndex(bucket.getIndex(), bucket.getEarliest(),
            bucket.getLatest());

    assertEquals(1, listBucketsInIndex.size());
    Bucket bucketInArchive = listBucketsInIndex.get(0);
View Full Code Here
TOP

Related Classes of com.splunk.shuttl.archiver.listers.ListsBucketsFiltered

  • com.splunk.shuttl.archiver.thaw.BucketThawerFactory
  • com.splunk.shuttl.archiver.usecases.BucketSizeFunctionalTest
  • com.splunk.shuttl.server.mbeans.rest.ListBucketsEndpoint
    • 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.