Package io.deephaven.kafka.ingest

Class 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