@Evolving public final class ReadAllAvailable extends Object implements ReadLimit
MicroBatchStreammust scan all the data available at the streaming source. This is meant to be a hard specification as being able to return all available data is necessary for Trigger.Once() to work correctly. If a source is unable to scan all available data, then it must throw an error.
|Modifier and Type||Method and Description|