Package io.deephaven.kafka.ingest

Class KafkaIngester.SinglePartition

java.lang.Object

io.deephaven.kafka.ingest.KafkaIngester.PartitionRange

io.deephaven.kafka.ingest.KafkaIngester.SinglePartition

All Implemented Interfaces:

IntPredicate

Enclosing class:

KafkaIngester

public static class KafkaIngester.SinglePartition
extends KafkaIngester.PartitionRange

A predicate for handling a single partition.

Constructor Summary

Constructors

Constructor	Description
SinglePartition(int partition)	Create a predicate for a single partition.

Method Summary

Methods inherited from class io.deephaven.kafka.ingest.KafkaIngester.PartitionRange

test, 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

SinglePartition

public SinglePartition(int partition)

Create a predicate for a single partition.

Parameters:

partition - the partition to ingest