@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
.