KafkaIngester.PartitionRange

java.lang.Object

io.deephaven.kafka.ingest.KafkaIngester.PartitionRange

All Implemented Interfaces:: IntPredicate

Direct Known Subclasses:: KafkaIngester.SinglePartition

Enclosing class:: KafkaIngester

public static class KafkaIngester.PartitionRange
extends Object
implements IntPredicate

A predicate for handling a range of partitions.

Constructor Summary

Constructors

Constructor Description

PartitionRange(int startInclusive, int endInclusive)
Create a predicate for a range of partitions.
Method Summary

Modifier and Type Method Description

boolean test(int value)

String toString()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Methods inherited from interface java.util.function.IntPredicate
and, negate, or

Constructor Details
- PartitionRange
  
  public PartitionRange(int startInclusive, int endInclusive)
  
  Create a predicate for a range of partitions.
  
  Parameters:
  
  startInclusive - the first partition for an ingester
  
  endInclusive - the last partition for an ingester
Method Details
- test
  
  public boolean test(int value)
  
  Specified by:
  
  test in interface IntPredicate
- toString
  
  public String toString()
  
  Overrides:
  
  toString in class Object