@FunctionalInterface
public static interface SplittingFlushStrategy.FlushBoundaryProvider
SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary for each written item.| Modifier and Type | Interface and Description |
|---|---|
static class |
SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary
An enumeration for boundary of flushes on which this
SplittingFlushStrategy splits writes. |
| Modifier and Type | Method and Description |
|---|---|
SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary |
detectBoundary(java.lang.Object itemWritten)
Detect the
SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary for the passed itemWritten. |
SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary detectBoundary(@Nullable java.lang.Object itemWritten)
SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary for the passed itemWritten.itemWritten - Item written which determines the SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary.SplittingFlushStrategy.FlushBoundaryProvider.FlushBoundary representing the passed itemWritten.