PunctuationSchedule (kafka 2.6.1.100-eep-810 API)

java.lang.Object
- org.apache.kafka.streams.processor.internals.Stamped<ProcessorNode>
- - org.apache.kafka.streams.processor.internals.PunctuationSchedule

All Implemented Interfaces:: Comparable

public class PunctuationSchedule
extends Stamped<ProcessorNode>

Field Summary
- Fields inherited from class org.apache.kafka.streams.processor.internals.Stamped
  timestamp, value

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`Cancellable`	`cancellable()`
`boolean`	`equals(Object other)`
`int`	`hashCode()`
`PunctuationSchedule`	`next(long currTimestamp)`
`ProcessorNode`	`node()`
`Punctuator`	`punctuator()`

Methods inherited from class org.apache.kafka.streams.processor.internals.Stamped
compareTo

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

Method Detail

node
```
public ProcessorNode node()
```

punctuator
```
public Punctuator punctuator()
```

cancellable
```
public Cancellable cancellable()
```

next

public PunctuationSchedule next(long currTimestamp)

equals
```
public boolean equals(Object other)
```
Overrides:

equals in class Stamped<ProcessorNode>

hashCode
```
public int hashCode()
```
Overrides:

hashCode in class Stamped<ProcessorNode>