test_class.declarator: batchFactory
test_class.modifier: private
test_class.original_string: private BatchHelper.Factory batchFactory;
test_class.type: BatchHelper.Factory
test_class.var_name: batchFactory
test_class.declarator: httpRequestInitializer
test_class.modifier: private
test_class.original_string: private TrackingHttpRequestInitializer httpRequestInitializer;
test_class.type: TrackingHttpRequestInitializer
test_class.var_name: httpRequestInitializer
test_class.file: gcsio/src/test/java/com/google/cloud/hadoop/gcsio/BatchHelperTest.java
test_class.identifier: BatchHelperTest
test_case.body: @Test
    public void testIsEmpty() {
      Storage storage = new Storage(HTTP_TRANSPORT, JSON_FACTORY, httpRequestInitializer);
      BatchHelper batchHelper =
          batchFactory.newBatchHelper(httpRequestInitializer, storage, /* maxRequestsPerBatch= */ 2);
  
      assertThat(batchHelper.isEmpty()).isTrue();
    }
test_case.class_method_signature: BatchHelperTest.testIsEmpty()
test_case.full_signature: @Test public void testIsEmpty()
test_case.identifier: testIsEmpty
test_case.invocations: newBatchHelper isTrue assertThat isEmpty
test_case.modifiers: @Test public
test_case.parameters: ()
test_case.return: void
test_case.signature: void testIsEmpty()
focal_class.declarator: logger = GoogleLogger.forEnclosingClass()
focal_class.modifier: private static final
focal_class.original_string: private static final GoogleLogger logger = GoogleLogger.forEnclosingClass();
focal_class.type: GoogleLogger
focal_class.var_name: logger
focal_class.declarator: THREAD_FACTORY =
        new ThreadFactoryBuilder().setNameFormat("gcsfs-batch-helper-%d").setDaemon(true).build()
focal_class.modifier: private static final
focal_class.original_string: private static final ThreadFactory THREAD_FACTORY =
        new ThreadFactoryBuilder().setNameFormat("gcsfs-batch-helper-%d").setDaemon(true).build();
focal_class.type: ThreadFactory
focal_class.var_name: THREAD_FACTORY
focal_class.declarator: pendingRequests = new ConcurrentLinkedQueue<>()
focal_class.modifier: private final
focal_class.original_string: private final Queue<QueueRequestCallback> pendingRequests = new ConcurrentLinkedQueue<>();
focal_class.type: Queue<QueueRequestCallback>
focal_class.var_name: pendingRequests
focal_class.declarator: requestsExecutor
focal_class.modifier: private final
focal_class.original_string: private final ExecutorService requestsExecutor;
focal_class.type: ExecutorService
focal_class.var_name: requestsExecutor
focal_class.declarator: responseFutures = new ConcurrentLinkedQueue<>()
focal_class.modifier: private final
focal_class.original_string: private final Queue<Future<Void>> responseFutures = new ConcurrentLinkedQueue<>();
focal_class.type: Queue<Future<Void>>
focal_class.var_name: responseFutures
focal_class.declarator: requestInitializer
focal_class.modifier: private final
focal_class.original_string: private final HttpRequestInitializer requestInitializer;
focal_class.type: HttpRequestInitializer
focal_class.var_name: requestInitializer
focal_class.declarator: gcs
focal_class.modifier: private final
focal_class.original_string: private final Storage gcs;
focal_class.type: Storage
focal_class.var_name: gcs
focal_class.declarator: maxRequestsPerBatch
focal_class.modifier: private final
focal_class.original_string: private final long maxRequestsPerBatch;
focal_class.type: long
focal_class.var_name: maxRequestsPerBatch
focal_class.declarator: flushLock = new ReentrantLock()
focal_class.modifier: private final
focal_class.original_string: private final Lock flushLock = new ReentrantLock();
focal_class.type: Lock
focal_class.var_name: flushLock
focal_class.file: gcsio/src/main/java/com/google/cloud/hadoop/gcsio/BatchHelper.java
focal_class.identifier: BatchHelper
focal_class.class_method_signature: BatchHelper.BatchHelper(
        HttpRequestInitializer requestInitializer,
        Storage gcs,
        long maxRequestsPerBatch,
        int numThreads)
focal_class.full_signature: private  BatchHelper(
        HttpRequestInitializer requestInitializer,
        Storage gcs,
        long maxRequestsPerBatch,
        int numThreads)
focal_class.identifier: BatchHelper
focal_class.modifiers: private
focal_class.parameters: (
        HttpRequestInitializer requestInitializer,
        Storage gcs,
        long maxRequestsPerBatch,
        int numThreads)
focal_class.signature:  BatchHelper(
        HttpRequestInitializer requestInitializer,
        Storage gcs,
        long maxRequestsPerBatch,
        int numThreads)
focal_class.class_method_signature: BatchHelper.newRequestsExecutor(int numThreads)
focal_class.full_signature: private static ExecutorService newRequestsExecutor(int numThreads)
focal_class.identifier: newRequestsExecutor
focal_class.modifiers: private static
focal_class.parameters: (int numThreads)
focal_class.return: ExecutorService
focal_class.signature: ExecutorService newRequestsExecutor(int numThreads)
focal_class.class_method_signature: BatchHelper.queue(StorageRequest<T> req, JsonBatchCallback<T> callback)
focal_class.full_signature: public void queue(StorageRequest<T> req, JsonBatchCallback<T> callback)
focal_class.identifier: queue
focal_class.modifiers: public
focal_class.parameters: (StorageRequest<T> req, JsonBatchCallback<T> callback)
focal_class.return: void
focal_class.signature: void queue(StorageRequest<T> req, JsonBatchCallback<T> callback)
focal_class.class_method_signature: BatchHelper.execute(StorageRequest<T> req, JsonBatchCallback<T> callback)
focal_class.full_signature: private static void execute(StorageRequest<T> req, JsonBatchCallback<T> callback)
focal_class.identifier: execute
focal_class.modifiers: private static
focal_class.parameters: (StorageRequest<T> req, JsonBatchCallback<T> callback)
focal_class.return: void
focal_class.signature: void execute(StorageRequest<T> req, JsonBatchCallback<T> callback)
focal_class.class_method_signature: BatchHelper.flushIfPossibleAndRequired()
focal_class.full_signature: private void flushIfPossibleAndRequired()
focal_class.identifier: flushIfPossibleAndRequired
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void flushIfPossibleAndRequired()
focal_class.class_method_signature: BatchHelper.flushIfPossible(boolean flushAll)
focal_class.full_signature: private void flushIfPossible(boolean flushAll)
focal_class.identifier: flushIfPossible
focal_class.modifiers: private
focal_class.parameters: (boolean flushAll)
focal_class.return: void
focal_class.signature: void flushIfPossible(boolean flushAll)
focal_class.class_method_signature: BatchHelper.flushPendingRequests()
focal_class.full_signature: private void flushPendingRequests()
focal_class.identifier: flushPendingRequests
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void flushPendingRequests()
focal_class.class_method_signature: BatchHelper.flush()
focal_class.full_signature: public void flush()
focal_class.identifier: flush
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void flush()
focal_class.class_method_signature: BatchHelper.isEmpty()
focal_class.full_signature: public boolean isEmpty()
focal_class.identifier: isEmpty
focal_class.modifiers: public
focal_class.parameters: ()
focal_class.return: boolean
focal_class.signature: boolean isEmpty()
focal_class.class_method_signature: BatchHelper.awaitRequestsCompletion()
focal_class.full_signature: private void awaitRequestsCompletion()
focal_class.identifier: awaitRequestsCompletion
focal_class.modifiers: private
focal_class.parameters: ()
focal_class.return: void
focal_class.signature: void awaitRequestsCompletion()
focal_method.body: public boolean isEmpty() {
      return pendingRequests.isEmpty();
    }
focal_method.class_method_signature: BatchHelper.isEmpty()
focal_method.full_signature: public boolean isEmpty()
focal_method.identifier: isEmpty
focal_method.invocations: isEmpty
focal_method.modifiers: public
focal_method.parameters: ()
focal_method.return: boolean
focal_method.signature: boolean isEmpty()