test_class.declarator: folder = new TemporaryFolder(new File("target"))
test_class.modifier: private
test_class.original_string: private TemporaryFolder folder = new TemporaryFolder(new File("target"));
test_class.type: TemporaryFolder
test_class.var_name: folder
test_class.declarator: blobStore = new TemporaryBlobStore(folder) {
  
          @Override
          protected void configureDataStore(FileDataStore dataStore) {
              dataStore.setMinRecordLength(SegmentTestConstants.MEDIUM_LIMIT);
          }
  
      }
test_class.modifier: private
test_class.original_string: private TemporaryBlobStore blobStore = new TemporaryBlobStore(folder) {
  
          @Override
          protected void configureDataStore(FileDataStore dataStore) {
              dataStore.setMinRecordLength(SegmentTestConstants.MEDIUM_LIMIT);
          }
  
      };
test_class.type: TemporaryBlobStore
test_class.var_name: blobStore
test_class.declarator: fileStore = new TemporaryFileStore(folder, blobStore, false)
test_class.modifier: private
test_class.original_string: private TemporaryFileStore fileStore = new TemporaryFileStore(folder, blobStore, false);
test_class.type: TemporaryFileStore
test_class.var_name: fileStore
test_class.declarator: rules = RuleChain.outerRule(folder)
          .around(blobStore)
          .around(fileStore)
test_class.modifier: @Rule
      public
test_class.original_string: @Rule
      public RuleChain rules = RuleChain.outerRule(folder)
          .around(blobStore)
          .around(fileStore);
test_class.type: RuleChain
test_class.var_name: rules
test_class.file: oak-segment-tar/src/test/java/org/apache/jackrabbit/oak/segment/standby/client/RemoteBlobProcessorTest.java
test_class.identifier: RemoteBlobProcessorTest
test_case.body: @Test
      public void inlineBinaryShouldNotBeDownloaded() throws Exception {
          SegmentNodeStore store = SegmentNodeStoreBuilders.builder(fileStore.fileStore()).build();
  
          NodeBuilder root = store.getRoot().builder();
          root.setProperty("b", root.createBlob(new NullInputStream(SegmentTestConstants.MEDIUM_LIMIT - 1)));
          store.merge(root, EmptyHook.INSTANCE, CommitInfo.EMPTY);
  
          RemoteBlobProcessor processor = new RemoteBlobProcessor(blobStore.blobStore(), blobId -> {
              Assert.fail("Inline binaries should not be downloaded");
              return null;
          });
  
          processor.processBinary(store.getRoot().getProperty("b").getValue(Type.BINARY));
      }
test_case.class_method_signature: RemoteBlobProcessorTest.inlineBinaryShouldNotBeDownloaded()
test_case.full_signature: @Test public void inlineBinaryShouldNotBeDownloaded()
test_case.identifier: inlineBinaryShouldNotBeDownloaded
test_case.invocations: build builder fileStore builder getRoot setProperty createBlob merge blobStore fail processBinary getValue getProperty getRoot
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void inlineBinaryShouldNotBeDownloaded()
focal_class.declarator: logger = LoggerFactory.getLogger(RemoteBlobProcessor.class)
focal_class.modifier: private static final
focal_class.original_string: private static final Logger logger = LoggerFactory.getLogger(RemoteBlobProcessor.class);
focal_class.type: Logger
focal_class.var_name: logger
focal_class.declarator: blobStore
focal_class.modifier: private final
focal_class.original_string: private final BlobStore blobStore;
focal_class.type: BlobStore
focal_class.var_name: blobStore
focal_class.declarator: blobDownloader
focal_class.modifier: private final
focal_class.original_string: private final BlobDownloader blobDownloader;
focal_class.type: BlobDownloader
focal_class.var_name: blobDownloader
focal_class.file: oak-segment-tar/src/main/java/org/apache/jackrabbit/oak/segment/standby/client/RemoteBlobProcessor.java
focal_class.identifier: RemoteBlobProcessor
focal_class.interfaces: implements BlobProcessor
focal_class.class_method_signature: RemoteBlobProcessor.RemoteBlobProcessor(BlobStore blobStore, BlobDownloader blobDownloader)
focal_class.full_signature:   RemoteBlobProcessor(BlobStore blobStore, BlobDownloader blobDownloader)
focal_class.identifier: RemoteBlobProcessor
focal_class.parameters: (BlobStore blobStore, BlobDownloader blobDownloader)
focal_class.signature:  RemoteBlobProcessor(BlobStore blobStore, BlobDownloader blobDownloader)
focal_class.class_method_signature: RemoteBlobProcessor.processBinary(Blob b)
focal_class.full_signature: @Override public void processBinary(Blob b)
focal_class.identifier: processBinary
focal_class.modifiers: @Override public
focal_class.parameters: (Blob b)
focal_class.return: void
focal_class.signature: void processBinary(Blob b)
focal_class.class_method_signature: RemoteBlobProcessor.fetchBinary(SegmentBlob blob)
focal_class.full_signature: private void fetchBinary(SegmentBlob blob)
focal_class.identifier: fetchBinary
focal_class.modifiers: private
focal_class.parameters: (SegmentBlob blob)
focal_class.return: void
focal_class.signature: void fetchBinary(SegmentBlob blob)
focal_class.class_method_signature: RemoteBlobProcessor.shouldFetchBinary(SegmentBlob blob)
focal_class.full_signature: private boolean shouldFetchBinary(SegmentBlob blob)
focal_class.identifier: shouldFetchBinary
focal_class.modifiers: private
focal_class.parameters: (SegmentBlob blob)
focal_class.return: boolean
focal_class.signature: boolean shouldFetchBinary(SegmentBlob blob)
focal_class.class_method_signature: RemoteBlobProcessor.fetchAndStoreBlob(String blobId)
focal_class.full_signature: private void fetchAndStoreBlob(String blobId)
focal_class.identifier: fetchAndStoreBlob
focal_class.modifiers: private
focal_class.parameters: (String blobId)
focal_class.return: void
focal_class.signature: void fetchAndStoreBlob(String blobId)
focal_class.class_method_signature: RemoteBlobProcessor.writeBlob(String blobId, InputStream stream)
focal_class.full_signature: private void writeBlob(String blobId, InputStream stream)
focal_class.identifier: writeBlob
focal_class.modifiers: private
focal_class.parameters: (String blobId, InputStream stream)
focal_class.return: void
focal_class.signature: void writeBlob(String blobId, InputStream stream)
focal_class.class_method_signature: RemoteBlobProcessor.downloadBlob(String blobId)
focal_class.full_signature: private InputStream downloadBlob(String blobId)
focal_class.identifier: downloadBlob
focal_class.modifiers: private
focal_class.parameters: (String blobId)
focal_class.return: InputStream
focal_class.signature: InputStream downloadBlob(String blobId)
focal_method.body: @Override
      public void processBinary(Blob b) throws InterruptedException {
          if (b instanceof SegmentBlob) {
              fetchBinary((SegmentBlob) b);
          } else {
              throw new BlobTypeUnknownException();
          }
      }
focal_method.class_method_signature: RemoteBlobProcessor.processBinary(Blob b)
focal_method.full_signature: @Override public void processBinary(Blob b)
focal_method.identifier: processBinary
focal_method.invocations: fetchBinary
focal_method.modifiers: @Override public
focal_method.parameters: (Blob b)
focal_method.return: void
focal_method.signature: void processBinary(Blob b)